线程池

古城微笑少年丶 2022-05-11 09:12 37阅读 0赞

传统多线程方案会使用“即时创建， 即时销毁”的策略。尽管与创建进程相比，创建线程的时间已经大大的缩短，但是如果提交给线程的任务是执行时间较短，而且执行次数极其频繁，那么服务器将处于不停的创建线程，销毁线程的状态。  
一个线程的运行时间可以分为3部分：线程的启动时间、线程体的运行时间和线程的销毁时间。在多线程处理的情景中，如果线程不能被重用，就意味着每次创建都需要经过启动、销毁和运行3个过程。这必然会增加系统相应的时间，降低了效率。

使用线程池：  
由于线程预先被创建并放入线程池中，同时处理完当前任务之后并不销毁而是被安排处理下一个任务，因此能够避免多次创建线程，从而节省线程创建和销毁的开销，能带来更好的性能和系统稳定性。

# 一.创建线程池 #

Python标准库为我们提供了threading模块编写相应的多线程。从Python3.2开始，标准库为我们提供了concurrent.futures模块，它提供了ThreadPoolExecutor类，实现了对threading的更高级的抽象，对编写线程池提供了直接的支持。  
concurrent.futures基础模块是executor和future。

**Executor**是一个抽象类，它不能被直接使用。它为具体的异步执行定义了一些基本的方法。  
ThreadPoolExecutor继承了Executor，被用来创建线程池代码。

**submit()方法**  
Executor中定义了submit()方法，这个方法的作用是提交一个可执行的回调task，并返回一个future实例。future对象代表的就是给定的调用。  
例：

from concurrent.futures import  ThreadPoolExecutor
        import time
        
        # 需要执行的任务
    
        def job():
            print("this is a job")
            return  "hello"
        
        if __name__ == '__main__':
            # 实例化对象，创建一个线程池 ，线程池包含10个线程来处理任务;
            pool = ThreadPoolExecutor(max_workers=10)
        
            # 往线程池里面扔需要执行的任务， 返回一个对象，( _base.Future实例化出来的)
            f1 = pool.submit(job)
            f2 = pool.submit(job)
        
            # 判断任务是否执行结束
            print(f1.done())
            time.sleep(1)
            print(f2.done())
        
            # 获取任务执行的结果
            print(f1.result())
            print(f2.result())

![标题][70]

[70]: /images/20220511/b1b6df9315194955b177a1a26293f951.png