def flush_cache(self):
while True:
gevent.sleep(1)
if not len(self.cache):
continue
with self.lock:
Event.insert_many(filter(bool, [
Event.prepare(self.session_id, event) for event in self.cache
])).execute()
self.cache = []
评论列表
文章目录