Python异步任务队列代码,Python代码库,德仔网

代码语言

代码分类

【Python】 Python异步任务队列

作者:liangjw0504 / 发布于2013/9/13/ 1309


	#!/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()

试试其它关键字

　异步任务队列　

同语言下

可能有用的

liangjw0504贡献的其它代码(36)