server_common/f7
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2020-01-13 17:55:58 +08:00
parent ae2892cd49
commit 1d7840b984
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
f7/app.py
View File

@ -99,7 +99,7 @@ class _App:
if msgid == _IM_DoneCallback: if msgid == _IM_DoneCallback:
self._IMDoneCallback(callback) self._IMDoneCallback(callback)
except Exception as e: except Exception as e:
f7.udplog.error('_dispatchIMMsg ' + str(e)) f7.udplog.error('_dispatchIMMsg %d %s' % (msgid, str(e)))
def _addIMMsg(self, msgid, callback): def _addIMMsg(self, msgid, callback):
self._immsgLock.acquire() self._immsgLock.acquire()
@ -112,8 +112,12 @@ class _App:
callback() callback()
def createAsyncTask(self, done_callback, func, *args): def createAsyncTask(self, done_callback, func, *args):
assert self._listened
def thread_func(args): def thread_func(args):
try:
func(args) func(args)
except Exception as e:
f7.udplog.error('_dispatchIMMsg ' + str(e))
if done_callback: if done_callback:
self._addIMMsg(_IM_DoneCallback, done_callback) self._addIMMsg(_IM_DoneCallback, done_callback)
thread = threading.Thread(target = thread_func, args = args) thread = threading.Thread(target = thread_func, args = args)