Name	Size	Mode	Actions
__pycache__/	-	0755	rm
asyncio.py	1893	0644	editdlrm
background.py	1476	0644	editdlrm
base.py	48342	0644	editdlrm
blocking.py	872	0644	editdlrm
gevent.py	987	0644	editdlrm
qt.py	1241	0644	editdlrm
tornado.py	1890	0644	editdlrm
twisted.py	1778	0644	editdlrm
__init__.py	406	0644	editdlrm

from threading import TIMEOUT_MAX, Event from apscheduler.schedulers.base import STATE_STOPPED, BaseScheduler class BlockingScheduler(BaseScheduler): """ A scheduler that runs in the foreground (:meth:`~apscheduler.schedulers.base.BaseScheduler.start` will block). """ _event = None def start(self, *args, **kwargs): if self._event is None or self._event.is_set(): self._event = Event() super().start(*args, **kwargs) self._main_loop() def shutdown(self, wait=True): super().shutdown(wait) self._event.set() def _main_loop(self): wait_seconds = TIMEOUT_MAX while self.state != STATE_STOPPED: self._event.wait(wait_seconds) self._event.clear() wait_seconds = self._process_jobs() def wakeup(self): self._event.set()