#!/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, b, 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, handle_result, 1, 2, 3)     async_call(func_c, handle_result, 1, 2, 3, 4)     _task_queue.join()