本文實(shí)例講述了python實(shí)現(xiàn)通過(guò)隊(duì)列完成進(jìn)程間的多任務(wù)功能。分享給大家供大家參考,具體如下:
import multiprocessing def download_data(q): """下載數(shù)據(jù)""" # 模擬從網(wǎng)上下載數(shù)據(jù) data = [11, 22, 33, 44] # 向隊(duì)列中寫入數(shù)據(jù) for temp in data: q.put(temp) print("----數(shù)據(jù)下載完成并且已存入隊(duì)列----") def analysis_data(q): """數(shù)據(jù)處理""" waitting_analysis_data = list() # 從隊(duì)列中獲取數(shù)據(jù) while True: data = q.get() waitting_analysis_data.append(data) if q.empty(): break print(waitting_analysis_data) def main(): # 1.創(chuàng)建一個(gè)隊(duì)列 q = multiprocessing.Queue() q1 = multiprocessing.Process(target=download_data, args=(q,)) q2 = multiprocessing.Process(target=analysis_data, args=(q,)) q1.start() q2.start() if __name__ == '__main__': main()
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn,海內(nèi)外云服務(wù)器15元起步,三天無(wú)理由+7*72小時(shí)售后在線,公司持有idc許可證,提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案,具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì),專為企業(yè)上云打造定制,能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。