zthreadpool 1.0.1

线程池, 固定指定数量的线程来执行任务, 避免重复创建和销毁线程时的资源消耗

线程池, 固定指定数量的线程来执行任务, 避免重复创建和销毁线程时的资源消耗

注意:
如果任务数量超过线程数量, 超出的任务会等待有正在执行的任务执行完毕后, 在有空闲线程时才会执行

测试代码:
if __name__ == '__main__':
import time
import threading

p = ThreadPool(2)


@p.task()
def fun(a, c):
print(a, '开始', time.strftime(' %H:%M:%S', time.localtime()))
for i in range(c):
time.sleep(0.01)
print(a, ' 结束', time.strftime(' %H:%M:%S', time.localtime()))


fun('aa', 100)
fun('bb', 100)
fun('cc', 100)
fun('dd', 100)
p.close()
p.join()
print('--end--')