python默认没有提供线程池的功能,所以要想使用线程池,就必要使用第三方的模块或者自定义线程
线程并不是越多越好,线程的上下文切换会影响到服务器的性能
线程池:一个容器,有最大数,取一个少一个,无线程时等待,线程执行完毕,交还线程
__author__ = ‘alex‘ #coding:utf-8 import queue import threading import time class ThreadPool: def __init__(self,maxsize=5): self.maxsize = maxsize self._q = queue.Queue() for i in range(5): self._q.put(threading.Thread) def get_thread(self): return self._q.get() def add_thread(self): self._q.put(threading.Thread) pool = ThreadPool(5) def task(args,p): print (args ) time.sleep(2) p.add_thread() for i in range(100): t = pool.get_thread() obj = t(target=task,args =(i,pool)) obj.start()
这个简单的程序实现了线程池的基本功能,每次只能有5个线程产生,但是也有很大的局限性,1,线程不能回收回来,每次产生了5个线程,但是线程确不能收回来(垃圾回收机制回收回来),每5个线程结束以后,只是重新生成了新的线程;2,如果需要的线程数range(100)小于我们定义的创建池的数值(5),那就浪费了,根本没有必要初始就创立5个线程(线程池一下子就开到了最大)。
时间: 2024-10-11 05:02:45