Python快速实现一个线程池的示例代码_python_

""" 将函数提交到线程池里面运行时，会立即返回一个对象 这个对象就叫做 Future 对象，里面包含了函数的执行状态等等 当然我们也可以手动创建一个Future对象。 """ from concurrent.futures import Future # 创建 Future 对象 future future = Future() # 给 future 绑定回调 def callback(f: Future):     print("当set_result的时候会执行回调，result:",           f.result()) future.add_done_callback(callback) # 通过 add_done_callback 方法即可给 future 绑定回调 # 调用的时候会自动将 future 作为参数 # 如果需要多个参数，那么就使用偏函数 # 回调函数什么时候执行呢？ # 显然是当 future 执行 set_result 的时候 # 如果 future 是向线程池提交函数时返回的 # 那么当函数执行完毕时会自动执行 future.set_result(xx) # 并将自身的返回设置进去 # 而这里的 future 是我们手动创建的，因此需要手动执行 future.set_result("嘿嘿") """ 当set_result的时候会执行回调，result: 嘿嘿 """

from concurrent.futures import Future future = Future() future.set_result("哼哼") print(future.result())  # 哼哼 print(future.result())  # 哼哼 print(future.result())  # 哼哼

from concurrent.futures import ThreadPoolExecutor import time def task(name, n):     time.sleep(n)     return f"{name} 睡了 {n} 秒" # 创建一个线程池 # 里面还可以指定 max_workers 参数，表示最多创建多少个线程 # 如果不指定，那么每提交一个函数，都会为其创建一个线程 executor = ThreadPoolExecutor() # 通过 submit 即可将函数提交到线程池，一旦提交，就会立刻运行 # 因为开启了一个新的线程，主线程会继续往下执行 # 至于 submit 的参数，按照函数名，对应参数提交即可 # 切记不可写成task("古明地觉", 3)，这样就变成调用了 future = executor.submit(task, "古明地觉", 3) # 由于函数里面出现了 time.sleep，并且指定的 n 是 3 # 所以函数内部会休眠 3 秒，显然此时处于运行状态 print(future) """  """ # 我们说 future 相当于一个容器，包含了内部函数的执行状态 # 函数是否正在运行中 print(future.running()) """ True """ # 函数是否执行完毕 print(future.done()) """ False """ # 主程序也 sleep 3 秒 time.sleep(3) # 显然此时函数已经执行完毕了 # 并且打印结果还告诉我们返回值类型是 str print(future) """  """ print(future.running()) """ False """ print(future.done()) """ True """ # 函数执行完毕时，会将返回值设置在 future 里 # 也就是说一旦执行了 future.set_result # 那么就表示函数执行完毕了，然后外界可以调用 result 拿到返回值 print(future.result()) """ 古明地觉 睡了 3 秒 """

# 提交函数 future = executor.submit(task, "古明地觉", 3) start = time.perf_counter() future.result() end = time.perf_counter() print(end - start)  # 3.00331525

from concurrent.futures import (     ThreadPoolExecutor,     TimeoutError ) import time def task(name, n):     time.sleep(n)     return f"{name} 睡了 {n} 秒" executor = ThreadPoolExecutor() future = executor.submit(task, "古明地觉", 3) try:     # 1 秒之内获取不到值，抛出 TimeoutError     res = future.result(1) except TimeoutError:     pass # 再 sleep 2 秒，显然函数执行完毕了 time.sleep(2) # 获取返回值 print(future.result()) """ 古明地觉 睡了 3 秒 """

from concurrent.futures import ThreadPoolExecutor import time def task(name, n):     time.sleep(n)     return f"{name} 睡了 {n} 秒" def callback(f):     print(f.result()) executor = ThreadPoolExecutor() future = executor.submit(task, "古明地觉", 3) # 绑定回调，3 秒之后自动调用 future.add_done_callback(callback) """ 古明地觉 睡了 3 秒 """

from concurrent.futures import ThreadPoolExecutor import time def task(name, n):     time.sleep(n)     return f"{name} 睡了 {n} 秒" executor = ThreadPoolExecutor() futures = [executor.submit(task, "古明地觉", 3),            executor.submit(task, "古明地觉", 4),            executor.submit(task, "古明地觉", 1)] # 此时都处于running print(futures) """ [,  ,   ] """ time.sleep(3) # 主程序 sleep 3s 后 # futures[0]和futures[2]处于 finished # futures[1]仍处于 running print(futures) """ [,   ,   ] """

executor = ThreadPoolExecutor() futures = [executor.submit(task, "古明地觉", 5),            executor.submit(task, "古明地觉", 2),            executor.submit(task, "古明地觉", 4),            executor.submit(task, "古明地觉", 3),            executor.submit(task, "古明地觉", 6)] for future in futures:     print(future.result()) """ 古明地觉 睡了 5 秒 古明地觉 睡了 2 秒 古明地觉 睡了 4 秒 古明地觉 睡了 3 秒 古明地觉 睡了 6 秒 """

executor = ThreadPoolExecutor() # map 内部也是使用了 submit results = executor.map(task,                        ["古明地觉"] * 3,                        [3, 1, 2]) # 并且返回的是迭代器 print(results) """  """ # 此时遍历得到的是不再是 future # 而是 future.result() for result in results:     print(result) """ 古明地觉 睡了 3 秒 古明地觉 睡了 1 秒 古明地觉 睡了 2 秒 """

executor = ThreadPoolExecutor() results = executor.map(task,                        ["古明地觉"] * 3,                        [3, 1, 2]) print(list(results)) """ ['古明地觉 睡了 3 秒',   '古明地觉 睡了 1 秒',   '古明地觉 睡了 2 秒'] """

from concurrent.futures import (     ThreadPoolExecutor,     as_completed ) import time def task(name, n):     time.sleep(n)     return f"{name} 睡了 {n} 秒" executor = ThreadPoolExecutor() futures = [executor.submit(task, "古明地觉", 5),            executor.submit(task, "古明地觉", 2),            executor.submit(task, "古明地觉", 1),            executor.submit(task, "古明地觉", 3),            executor.submit(task, "古明地觉", 4)] for future in as_completed(futures):     print(future.result()) """ 古明地觉 睡了 1 秒 古明地觉 睡了 2 秒 古明地觉 睡了 3 秒 古明地觉 睡了 4 秒 古明地觉 睡了 5 秒 """

executor = ThreadPoolExecutor() future1 = executor.submit(task, "古明地觉", 1) future2 = executo
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                
                

                

                                            
上一篇：python开发sdk模块的方法_python_
                                                                
下一篇：Python判断和循环语句的分析与应用_python_