【移動(dòng)應(yīng)用開(kāi)發(fā)技術(shù)】python concurrent.futures模塊如何使用

【移動(dòng)應(yīng)用開(kāi)發(fā)技術(shù)】pythonconcurrent.futures模塊如何使用

這篇文章主要介紹了pythonconcurrent.futures模塊如何使用的相關(guān)知識(shí)，內(nèi)容詳細(xì)易懂，操作簡(jiǎn)單快捷，具有一定借鑒價(jià)值，相信大家閱讀完這篇pythonconcurrent.futures模塊如何使用文章都會(huì)有所收獲，下面我們一起來(lái)看看吧。concurrent.futures是3.2中引入的新模塊，它為異步執(zhí)行可調(diào)用對(duì)象提供了高層接口?？梢允褂肨hreadPoolExecutor來(lái)進(jìn)行多線程編程，ProcessPoolExecutor進(jìn)行多進(jìn)程編程，兩者實(shí)現(xiàn)了同樣的接口，這些接口由抽象類(lèi)Executor定義。這個(gè)模塊提供了兩大類(lèi)型，一個(gè)是執(zhí)行器類(lèi)Executor，另一個(gè)是Future類(lèi)。執(zhí)行器用來(lái)管理工作池，future用來(lái)管理工作計(jì)算出來(lái)的結(jié)果，通常不用直接操作future對(duì)象，因?yàn)橛胸S富的API。Python3.2開(kāi)始，標(biāo)準(zhǔn)庫(kù)為我們提供了concurrent.futures模塊，它提供了ThreadPoolExecutor和ProcessPoolExecutor兩個(gè)類(lèi)，實(shí)現(xiàn)了對(duì)threading和multiprocessing的進(jìn)一步抽象，對(duì)編寫(xiě)線程池/進(jìn)程池提供了直接的支持.#!

/usr/bin/env

python

#

-*-

coding:

utf-8

-*-#

#

#

Name:

demo3

#

Author:

yunhgu

#

Date:

2021/7/8

15:17

#

Description:

#

import

os

import

time

import

threading

from

concurrent.futures

import

ProcessPoolExecutor,

ThreadPoolExecutor,

as_completed

def

work(x):

time.sleep(1)

temp

=

f"父進(jìn)程{os.getppid()}:子進(jìn)程{os.getpid()}:線程{threading.get_ident()}:{x}"

return

temp

def

sub_thread():

temp_list

=

[]

with

ThreadPoolExecutor(max_workers=3)

as

t:

task_list

=

[t.submit(work,

i)

for

i

in

range(5)]

for

task

in

as_completed(task_list):

if

task.done():

temp_list.append(task.result())

return

temp_list

def

main():

print(f"主進(jìn)程:{os.getpid()}")

path_list

=

[]

with

ProcessPoolExecutor(max_workers=3)

as

p:

task_list

=

[p.submit(sub_thread)

for

i

in

range(5)]

for

task

in

as_completed(task_list):

if

task.done():

path_list.append(task.result())