From 28da41e6f70c40f14f23fde87e9482df1f614544 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Mon, 13 Jan 2020 17:08:37 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0im=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 f7/app.py | 41 +++++++++++++++++++++++++++++++++++++++++
 1 file changed, 41 insertions(+)

diff --git a/f7/app.py b/f7/app.py
index e8cf826..06dafa7 100644
--- a/f7/app.py
+++ b/f7/app.py
@@ -4,6 +4,7 @@
 import f7
 
 import json
+import threading
 import traceback
 import tornado.web
 import tornado.ioloop
@@ -13,6 +14,8 @@ class _mainHandler(tornado.web.RequestHandler):
     def get(self):
         instance()._dispatchRequest(self)
 
+_IM_DoneCallback = 100
+
 class _App:
     _instance = None
 
@@ -29,6 +32,9 @@ class _App:
             (r"/webapp/index[\.]php", _mainHandler),
         ])
         self.registerHandler('Ops', 'selfChecking', self.__selfChecking)
+        self._immsgLock = threading.Lock()
+        self._immsgList = []
+        tornado.ioloop.IOLoop.PeriodicCallback(self._processIMMsg, 100)
 
     def init(self, log_dir):
         f7.udplog.init()
@@ -78,5 +84,40 @@ class _App:
             'max_rundelay': 10
         })
 
+    def _processIMMsg(self):
+        self._immsgLock.acquire()
+        try:
+            if len(self._immsgList) > 0:
+                for node in self._immsgList:
+                    self._dispatchIMMsg(node[0], node[1])
+        finally:
+            self._immsgList = []
+            self._immsgLock.release()
+
+    def _dispatchIMMsg(self, msgid, callback):
+        try:
+            if msgid == _IM_DoneCallback:
+                self._IMDoneCallback(callback)
+        except Exception as e:
+            f7.udplog.error('_dispatchIMMsg ' + str(e))
+
+    def _addIMMsg(self, msgid, callback):
+        self._immsgLock.acquire()
+        try:
+            self._immsgList.append((msgid, callback))
+        finally:
+            self._immsgLock.release()
+
+    def _IMDoneCallback(self, callback):
+        callback()
+
+    def createAsyncTask(self, done_callback, func, *args):
+        def thread_func(args):
+            func(args)
+            if done_callback:
+                self._addIMMsg(_IM_DoneCallback, done_callback)
+        thread = threading.Thread(target = thread_func, args = args)
+        thread.start()
+
 def instance():
     return _App.instance()