fix
This commit is contained in:
parent
db554001aa
commit
0573d6beff
@ -1,7 +1,9 @@
|
|||||||
import queue
|
import queue
|
||||||
|
|
||||||
|
from app.utils.singleton import Singleton
|
||||||
|
|
||||||
class MessageHelper:
|
|
||||||
|
class MessageHelper(metaclass=Singleton):
|
||||||
"""
|
"""
|
||||||
消息队列管理器
|
消息队列管理器
|
||||||
"""
|
"""
|
||||||
@ -12,4 +14,4 @@ class MessageHelper:
|
|||||||
self.queue.put(message)
|
self.queue.put(message)
|
||||||
|
|
||||||
def get(self):
|
def get(self):
|
||||||
return self.queue.get(block=True)
|
return self.queue.get(block=False)
|
||||||
|
@ -37,6 +37,7 @@ class Scheduler(metaclass=Singleton):
|
|||||||
})
|
})
|
||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
|
return
|
||||||
# CookieCloud定时同步
|
# CookieCloud定时同步
|
||||||
if settings.COOKIECLOUD_INTERVAL:
|
if settings.COOKIECLOUD_INTERVAL:
|
||||||
self._scheduler.add_job(CookieCloudChain().process,
|
self._scheduler.add_job(CookieCloudChain().process,
|
||||||
|
Loading…
x
Reference in New Issue
Block a user