concurrent.futures用法
阿新 • • 發佈:2018-12-04
submit | 非同步提交 | |
map(func, *iterables, timeout=None, chunksize=1) | 類似 map(func, *iterables)除了以下: 迭代器是立即收集的而不是延遲收集的 func是非同步執行的和對func的多個呼叫可以併發執行 | |
shutdown(wait=True) | 相當於程序池的pool.close()+pool.join()操作 wait=True,等待池內所有任務執行完畢回收完資源後才繼續 wait=False,立即返回,並不會等待池內的任務執行完畢 但不管wait引數為何值,整個程式都會等到所有任務執行完畢 submit和map必須在shutdown之前 | |
result(timeout=None) | 取得結果,如果在for中引用將會形成阻塞 | |
add_done_callback(fn) | 回撥函式,非同步執行 |