36 lines
1.2 KiB
Python
36 lines
1.2 KiB
Python
from queue import Queue
|
|
from threading import Thread
|
|
from typing import Any, Callable
|
|
|
|
import pyglet
|
|
|
|
|
|
class StoppableThread(Thread):
|
|
"""
|
|
Un thread pouvant être arrêté.
|
|
La méthode "run" doit souvent vérifier la variable self.stopped et faire un return manuellement si cette variable
|
|
est vrai.
|
|
"""
|
|
|
|
def __init__(self, *args, **kwargs):
|
|
super().__init__(*args, **kwargs)
|
|
self.stopped = False
|
|
|
|
def stop(self) -> None:
|
|
# indique que le thread devrait s'arrêter dès que possible
|
|
self.stopped = True
|
|
|
|
|
|
def in_pyglet_context(func: Callable, *args, **kwargs) -> Any:
|
|
"""
|
|
Cette fonction doit être appelée dans un thread. Elle appellera une fonction dans la boucle d'événement de pyglet,
|
|
ce qui permet d'éviter certaines opérations illégales en dehors de ce contexte et renvoie le résultat.
|
|
:param func: la fonction à appeler
|
|
:param args: les arguments de la fonction
|
|
:param kwargs: les arguments à clé de la fonction
|
|
:return: le résultat de la fonction
|
|
"""
|
|
|
|
queue = Queue()
|
|
pyglet.clock.schedule_once(lambda dt: queue.put(func(*args, **kwargs)), 0)
|
|
return queue.get()
|