清华大佬耗费三个月吐血整理的几百G的资源,免费分享!....>>>
很多场景为了不阻塞,都需要异步回调机制。这是一个简单的例子。
python的多线程异步常用到queue和threading模块
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 | #!/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() |