Python 线程池

Posted 2020-08-06 Alex0425

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个线程（线程池一下子就开到了最大）。