这是一个简单的例子。
python的多线程异步常用到queue和threading模块
#!...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, b, c
异步任务队列
_task_queue = queue.Queue()
def async_call(function, callback, *args...callback,
'args': args,
'kwargs': kwargs
})
def _task_queue_consumer():
"""
异步任务队列消费者...handle_result, 1, 2, 3)
async_call(func_c, handle_result, 1, 2, 3, 4)
_task_queue.join()