這篇文章主要介紹“如何實(shí)現(xiàn)多個(gè)線程的等待同時(shí)結(jié)束”，在日常操作中，相信很多人在如何實(shí)現(xiàn)多個(gè)線程的等待同時(shí)結(jié)束問(wèn)題上存在疑惑，小編查閱了各式資料，整理出簡(jiǎn)單好用的操作方法，希望對(duì)大家解答”如何實(shí)現(xiàn)多個(gè)線程的等待同時(shí)結(jié)束”的疑惑有所幫助！接下來(lái)，請(qǐng)跟著小編一起來(lái)學(xué)習(xí)吧！

河池ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場(chǎng)景，ssl證書(shū)未來(lái)市場(chǎng)廣闊！成為創(chuàng)新互聯(lián)建站的ssl證書(shū)銷售渠道，可以享受市場(chǎng)價(jià)格4-6折優(yōu)惠！如果有意向歡迎電話聯(lián)系或者加微信：18982081108（備注：SSL證書(shū)合作）期待與您的合作！

我們?cè)趯?xiě)多線程代碼的時(shí)候，可能會(huì)需要等待多個(gè)線程同時(shí)結(jié)束，然后再進(jìn)行后續(xù)的流程。例如，我做了一個(gè)聚合搜索引擎，用戶輸入一個(gè)關(guān)鍵詞，我需要同時(shí)在很多個(gè)搜索引擎上搜索，然后把搜索結(jié)果匯總以后返回給用戶。

示例代碼如下：

@app.get('/api/search') def search(keyword: str):     google_result = requests.get('Google 搜索地址').text     baidu_result = requests.get('百度搜索地址').text     bing_result = requests.get('Bing搜索地址').text     result = combine(google_result, baidu_result, bing_result)     return {'success': True, 'result': result}

從上面這段代碼，大家可能會(huì)發(fā)現(xiàn)一個(gè)問(wèn)題，就是在請(qǐng)求多個(gè)搜索引擎的時(shí)候是串行的，先訪問(wèn) Google，訪問(wèn)完成再訪問(wèn)百度，訪問(wèn)完成最后訪問(wèn)  Bing。這樣顯然會(huì)浪費(fèi)大量的時(shí)間。

如果你不會(huì)async/await，那么為了解決這個(gè)問(wèn)題，你能想到的顯然就是使用多線程。使用3個(gè)線程同時(shí)訪問(wèn) Google、百度和  Bing，然后把結(jié)果匯總傳入combine函數(shù)，不就解決問(wèn)題了嗎?

如果僅僅是啟動(dòng)多個(gè)線程，那么做法很簡(jiǎn)單：

import threading  def get_url(url):     result = requests.get(url, headers=HEADERS).text     return result  @app.get('/api/search') def search(keyword: str):     google_thead = threading.Thread(target=get_url, 'Google 搜索地址')     baidu_thread = threading.Thread(target=get_url, '百度搜索地址')     bing_thread = threading.Thread(target=get_url, 'Bing搜索地址')     google_thread.start()     baidu_thread.start()     bing_thread.start()     ...

現(xiàn)在問(wèn)題來(lái)了，三個(gè)線程確實(shí)已經(jīng)啟動(dòng)了，但你怎么知道到什么時(shí)候?yàn)橹梗芯€程都運(yùn)行完畢?

這里我們給出幾個(gè)方法。

使用 join

調(diào)用線程的.join()方法，就可以卡住主線程，直到這個(gè)子線程運(yùn)行完畢才能讓主線程繼續(xù)運(yùn)行后面的代碼。所以我們可以修改代碼為：

import threading  def get_url(url):     result = requests.get(url, headers=HEADERS).text     return result  @app.get('/api/search') def search(keyword: str):     google_thead = threading.Thread(target=get_url, 'Google 搜索地址')     baidu_thread = threading.Thread(target=get_url, '百度搜索地址')     bing_thread = threading.Thread(target=get_url, 'Bing搜索地址')     google_thread.start()     baidu_thread.start()     bing_thread.start()          google_thread.join()     baidu_thread.join()     bing_thread.join()

但等一等，我怎么拿到子線程的返回呢?在默認(rèn)情況下，你確實(shí)拿不到返回的數(shù)據(jù)。所以你需要傳入一個(gè)東西去子線程接收結(jié)果。所以代碼可以改為：

import threading  def get_url(url, output):     result = requests.get(url, headers=HEADERS).text     output.append(result)  @app.get('/api/search') def search(keyword: str):     result = []     google_thead = threading.Thread(target=get_url, args=['Google 搜索地址', result])     baidu_thread = threading.Thread(target=get_url, args=['百度搜索地址', result])     bing_thread = threading.Thread(target=get_url, args=['Bing搜索地址', result])     google_thread.start()     baidu_thread.start()     bing_thread.start()          google_thread.join()     baidu_thread.join()     bing_thread.join()     combine(*result)

因?yàn)榫€程是共享內(nèi)存的，所以他們可以直接修改主線程傳入的列表。

在使用.join()的時(shí)候，需要小心不要把.join()放錯(cuò)了地方，否則你的多線程就會(huì)變成單線程。詳情可以看我的這篇文章： 等一等，你的多線程可別再亂  join 了。

ThreadPoolExecutor

Python  自帶了一個(gè)concurrent模塊，它就是專門(mén)用來(lái)處理并發(fā)問(wèn)題的。我們也可以使用這個(gè)模塊中的ThreadPoolExecutor來(lái)解決問(wèn)題：

from concurrent.futures import ThreadPoolExecutor, as_completed  def get_url(url):     result = requests.get(url, headers=HEADERS).text     return result  @app.get('/api/search') def search(keyword: str):     tasks = []     with ThreadPoolExecutor() as executor:         for url in ['Google 搜索地址', '百度搜索地址', 'Bing搜索地址']             task = executor.submit(get_url, url)             tasks.append(task)         result = [x.result() for x in as_completed(tasks)]       combine(*result)     ...

concurrent.futures里面的as_completed函數(shù)接收一個(gè)列表，列表里面是多個(gè)并發(fā)任務(wù)。當(dāng)所有并發(fā)任務(wù)都運(yùn)行結(jié)束時(shí)，它才會(huì)返回一個(gè)可迭代對(duì)象。對(duì)它進(jìn)行迭代以后，每個(gè)元素的.result()就是每個(gè)子線程運(yùn)行的返回結(jié)果。

其他方法

除了上面兩個(gè)方法外，還可以使用multiprocessing.dummy里面的Pool來(lái)實(shí)現(xiàn)更簡(jiǎn)單的多線程。

到此，關(guān)于“如何實(shí)現(xiàn)多個(gè)線程的等待同時(shí)結(jié)束”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)?lái)更多實(shí)用的文章！

當(dāng)前名稱：如何實(shí)現(xiàn)多個(gè)線程的等待同時(shí)結(jié)束
本文來(lái)源：http://vcdvsql.cn/article44/pegehe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站設(shè)計(jì)、全網(wǎng)營(yíng)銷推廣、網(wǎng)站導(dǎo)航、定制網(wǎng)站、網(wǎng)站收錄、網(wǎng)站設(shè)計(jì)公司

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)