python自定义线程池

python自定义线程池

# coding=utf-8 import threading import queue class ThreadPoll: def __init__(self,maxsize): self.max=maxsize self.p=queue.Queue(self.max) for i in range(maxsize): self.p.put(threading.Thread) def get_thread(self): return self.p.get() def add_thread(self): self.p.put(threading.Thread) def call_bj(i,p): print(i) p.add_thread() pool=ThreadPoll(5) for i in range(100): obj=pool.get_thread() tar=obj(target=call_bj,args=(i,pool)) tar.start()

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。