併發編程-進~線程-07進程池線程池-concurrent模塊

一丶進程池和線程池統一模塊

concurrent.futures

1.1 介紹

1. concurrent.futures模塊提供了高度封裝的異步調用接口
2. ThreadPoolExecutor：線程池，提供異步調用
3. ProcessPoolExecutor: 進程池，提供異步調用

1.2基本方法

1. submit(fn, *args, **kwargs)
   異步提交任務

2. map(func, *iterables, timeout=None, chunksize=1)
   取代for循環submit的操做

3. shutdown(wait=True)
   至關於進程池的pool.close()+pool.join()操做
   wait=True，等待池內全部任務執行完畢回收完資源後才繼續
   wait=False，當即返回，並不會等待池內的任務執行完畢
   但無論wait參數爲什麼值，整個程序都會等到全部任務執行完畢
   submit和map必須在shutdown以前

4. result(timeout=None)
   取得結果

5. add_done_callback(fn)
   回調函數

6. done()

   判斷某一個線程是否完成

7. cancle()

   取消某個任務

二丶進程池實現異步代碼

from concurrent.futures import ThreadPoolExecutor,ProcessPoolExecutor
import time
import os

# pool = ThreadPoolExecutor(5)  # 括號內能夠傳參數指定線程池內的線程個數
# # 也能夠不傳  不傳默認是當前所在計算機的cpu個數乘5
pool = ProcessPoolExecutor()  # 默認是當前計算機cpu的個數
"""
池子中建立的進程/線程建立一次就不會再建立了
至始至終用的都是最初的那幾個
這樣的話節省了反覆開闢進程/線程的資源
"""

def task(n):
    print(n,os.getpid())  # 查看當前進程號
    time.sleep(2)
    return n**2


def call_back(n):
    print('拿到了異步提交任務的返回結果:',n.result())
"""
提交任務的方式
    同步：提交任務以後 原地等待任務的返回結果 期間不作任何事
    異步：提交任務以後 不等待任務的返回結果(異步的結果怎麼拿？？？) 直接執行下一行代碼
"""

# pool.submit(task,1)  # 朝線程池中提交任務   異步提交
# print('主')
"""
異步回調機制:當異步提交的任務有返回結果以後，會自動觸發回調函數的執行

"""
if __name__ == '__main__':

    t_list = []
    for i in range(20):
        res = pool.submit(task,i).add_done_callback(call_back)  # 提交任務的時候 綁定一個回調函數 一旦該任務有結果 馬上執行對於的回調函數
        # print(res.result())  # 原地等待任務的返回結果
        t_list.append(res)

    # pool.shutdown()  # 關閉池子 等待池子中全部的任務執行完畢以後 纔會往下運行代碼
    # for p in t_list:
    #     print('>>>:',p.result())

ps:回調函數傳的函數名本質就是函數名()吧submit的對象進行結果真後返回