def handle_read(self):
self.recv(8192)
try:
self.lock.acquire()
for thunk in self.thunks:
try:
thunk()
except:
(file, fun, line), t, v, tbinfo = \
asyncore.compact_traceback()
print('exception in trigger thunk: (%s:%s %s)' % (
t, v, tbinfo))
self.thunks = []
finally:
self.lock.release()
评论列表
文章目录