多任务多线程任务管理类代码,Python代码库,德仔网

代码语言

代码分类

【Python】多任务多线程任务管理类

作者:小原周 / 发布于2015/8/3/ 550

最近在学习Python，尝试写了一个多任务多线程任务的管理类，可以设置多个任务并行执行，每个任务的并发数；可以设置每个任务的执行次数，也可以通过自定义函数控制每个任务是否结束。是个Python新手写的，大家勿喷。 task_manage.py：管理类代码 task_test.py：简单测试代码


	task_manage.py

	#coding=utf-8
	import threading
	import logging
	import time
	
	# 多任务多线程任务管理类
	class task_manage():
	 # name 任务名称
	 # task_func 任务函数指针
	 # task_args 任务函数参数，默认空
	 # check_func 任务是否执行完检测函数指针，返回True表示还有任务没有执行，默认调用自身的runtimes_control函数
	 # check_args 任务检测函数指针参数，默认空
	 # max_thread_count 最大线程数
	 # run_time 任务运行次数，设置check_func后，该参数无效
	 def __init__(self,name,task_func,task_args=(),check_func=None,check_args=(),max_thread_count=1,run_time=1):
	 self._is_finished = False
	 self._task_func = task_func
	 self._task_args = task_args
	 self._max_thread_count = max_thread_count
	 self._threads = []
	 self._name = name
	 self._check_args = check_args
	 self._run_time = run_time
	 self._task_index = 0
	 if check_func is None:
	 self._check_func = self.runtimes_control
	 self._check_args = ()
	 else:
	 self._check_func = check_func
	 # 任务运行次数控制函数
	 def runtimes_control(self):
	 if self._run_time > 0:
	 self._run_time -= 1
	 return True
	 return False
	 # 清除已退出线程
	 def clear_exit_threads(self):
	 for t in self._threads[:]:
	 if not t.is_alive() :
	 self._threads.remove(t)
	 # 运行任务
	 def run(self):
	 while(len(self._threads)<self._max_thread_count and not self._is_finished):
	 if self._check_func(*self._check_args):
	 t = threading.Thread(target=self._task_func,args=self._task_args)
	 self._threads.append(t)
	 t.setDaemon(True)
	 t.start()
	 self._task_index += 1
	 logging.debug("%s run %s" %(self._name,self._task_index))
	 else:
	 self._is_finished = True
	 break
	 # 对外接口，检测是否所有任务都执行完成
	 def is_finish(self):
	 self.clear_exit_threads()
	 self.run()
	 return self._is_finished and len(self._threads)==0
	
	
	def run_task_until_all_finished(manages=[]):
	 while True:
	 all_finished = True
	 for manage in manages:
	 all_finished = manage.is_finish() and all_finished
	 if all_finished : break
	 time.sleep(1)
	 logging.debug('all have finished!')

	

	

	task_test.py

	#coding=utf-8
	
	from base.task_manage import *
	
	def watch_movie(move_name):
	 print("I am watching movie %s now." %(move_name))
	
	def listen_music(music_name):
	 print("I am listening music %s now." %(music_name))
	
	
	manages=[]
	manages.append( task_manage(name="watching movie",task_func=watch_movie,task_args=(u"捉妖记",),run_time=10,max_thread_count=3))
	manages.append( task_manage(name="listening music",task_func=listen_music,task_args=(u"笨小孩",),run_time=10,max_thread_count=3))
	
	run_task_until_all_finished(manages)
	print('all have finished!')
	quit()

	

	运行结果：
	I am watching movie 捉妖记 now.
	I am watching movie 捉妖记 now.
	I am watching movie 捉妖记 now.
	I am listening music 笨小孩 now.
	I am listening music 笨小孩 now.
	I am listening music 笨小孩 now.
	I am watching movie 捉妖记 now.
	I am watching movie 捉妖记 now.
	I am watching movie 捉妖记 now.
	I am listening music 笨小孩 now.
	I am listening music 笨小孩 now.
	I am listening music 笨小孩 now.
	I am watching movie 捉妖记 now.
	I am watching movie 捉妖记 now.
	I am watching movie 捉妖记 now.
	I am listening music 笨小孩 now.
	I am listening music 笨小孩 now.
	I am listening music 笨小孩 now.
	I am watching movie 捉妖记 now.
	I am listening music 笨小孩 now.
	all have finished!

评论列表

本站所提供的代码，版权归原作者所有，若有侵犯作者版权，请与我们联系，我们将立即删除或修改。谢谢!
本站所有代码发布及提供者。

试试其它关键字

　多任务　　多线程　

同语言下

可能有用的

小原周贡献的其它代码(2)