Python多线程异步任务队列(实例),python多线程,这是一个简单的例子
Python多线程异步任务队列(实例),python多线程,这是一个简单的例子
很多场景为了不阻塞,都需要异步回调机制。这是一个简单的例子。
python的多线程异步常用到queue和threading模块
#!/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()
相关内容
- PyPy 和 CPython 的性能比较测试,pypycpython,它由这些部分
- 纯Python的ODBC库 PyPyODBC 1.0 发布,odbcpypyodbc,PyPyODBC是一
- 用50行Python代码制作一个计算器,50行python计算器,当我
- 用Python备份MYSQL 数据库,python备份mysql,个人已知的一些
- Python 支持重启的异步 IO,python重启io,研究从PEP 315
- Python连接Redis连接配置,python连接redis,[root@njdy
- 用Python写一个简单的中文分词器,python中文分词,3 源代
- 使用Python读取和写入mp3文件的id3v1信息,,#_* itunes
- python多线程编程1— python对多线程的支持,python多线程
- python多线程编程2—线程的创建、启动、挂起和退出,
评论关闭