Python线程池的实现浅析_python_

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("嘿嘿")

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 参数，表示最多创建多少个线程 # Python学习交流裙279199867 # 如果不指定，那么每提交一个函数，都会为其创建一个线程 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) futu
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

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

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

                

                                            
上一篇：详解Python中的枚举类型_python_
                                                                
下一篇：Python快速生成随机密码超简单实现_python_