+ data = LockedVar(None)
+ liquidities = LockedVar({})
+ last_date = LockedVar(None)
+ report = LockedVar(ReportStore(None))
+ worker = None
+ worker_started = False
+ worker_notify = None
+ callback = None
+
+ @classmethod
+ def start_worker(cls, poll=30):
+ import threading
+
+ cls.worker = threading.Thread(name="portfolio", daemon=True,
+ target=cls.wait_for_notification, kwargs={"poll": poll})
+ cls.worker_notify = threading.Event()
+ cls.callback = threading.Event()
+
+ cls.last_date.start_lock()
+ cls.liquidities.start_lock()
+ cls.report.start_lock()
+
+ cls.worker_started = True
+ cls.worker.start()
+
+ @classmethod
+ def is_worker_thread(cls):
+ if cls.worker is None:
+ return False
+ else:
+ import threading
+ return cls.worker == threading.current_thread()