很多场景为了不阻塞,都需要异步回调机制。这是一个简单的例子,大家参考使用吧
#!/usr/bin/env python
# -*- coding: UTF-8 -*-
import logging
import queue
import threading
def func_a(a,b):
return a + b
def func_b():
pass
def func_c(a,b,c):
return a,c
# 异步任务队列
_task_queue = queue.Queue()
def async_call(function,callback,*args,**kwargs):
_task_queue.put({
'function': function,
'callback': callback,
'args': args,
'kwargs': kwargs
})
def _task_queue_consumer():
"""
异步任务队列消费者
"""
while True:
try:
task = _task_queue.get()
function = task.get('function')
callback = task.get('callback')
args = task.get('args')
kwargs = task.get('kwargs')
try:
if callback:
callback(function(*args,**kwargs))
except Exception as ex:
if callback:
callback(ex)
finally:
_task_queue.task_done()
except Exception as ex:
logging.warning(ex)
def handle_result(result):
print(type(result),result)
if __name__ == '__main__':
t = threading.Thread(target=_task_queue_consumer)
t.daemon = True
t.start()
async_call(func_a,handle_result,1,2)
async_call(func_b,handle_result)
async_call(func_c,2,3)
async_call(func_c,3,4)
_task_queue.join()
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。