????????在計(jì)算機(jī)編程領(lǐng)域，多進(jìn)程編程是一種常見的并發(fā)編程技術(shù)，特別適用于利用多核處理器來(lái)提高程序性能和并行處理任務(wù)。Python作為一種功能強(qiáng)大的編程語(yǔ)言，提供了多種方法來(lái)實(shí)現(xiàn)多進(jìn)程編程。其中，multiprocessing模塊為我們提供了一種簡(jiǎn)單而強(qiáng)大的方式來(lái)創(chuàng)建和管理進(jìn)程。本文將深入介紹Python中使用multiprocessing模塊創(chuàng)建進(jìn)程的方法和技巧。

一、multiprocessing模塊簡(jiǎn)介
????????multiprocessing模塊是Python標(biāo)準(zhǔn)庫(kù)中的一個(gè)內(nèi)置模塊，主要用于實(shí)現(xiàn)多進(jìn)程編程。它提供了創(chuàng)建進(jìn)程、子進(jìn)程管理、進(jìn)程間通信等功能，使得我們可以輕松地編寫并發(fā)程序。與Python的threading模塊相比，multiprocessing模塊更適合執(zhí)行CPU密集型任務(wù)，因?yàn)樗褂枚鄠€(gè)進(jìn)程而不是多個(gè)線程，并充分利用了多核處理器的優(yōu)勢(shì)。

二、創(chuàng)建進(jìn)程的方法
????????使用multiprocessing模塊創(chuàng)建進(jìn)程非常簡(jiǎn)單。下面是一個(gè)基本的示例：

import multiprocessing

def worker():
? ? print("子進(jìn)程執(zhí)行")

if __name__ == '__main__':
? ? p = multiprocessing.Process(target=worker)
? ? p.start()
? ? p.join()
? ? print("主進(jìn)程執(zhí)行")

????????在上述示例中，我們首先導(dǎo)入了multiprocessing模塊，然后定義了一個(gè)名為worker的函數(shù)，用于在子進(jìn)程中執(zhí)行的任務(wù)。在`if __name__ == '__main__':`的條件下，我們創(chuàng)建了一個(gè)進(jìn)程`p`，并將目標(biāo)函數(shù)設(shè)為`worker`。最后，我們使用`p.start()`啟動(dòng)子進(jìn)程，使用`p.join()`等待子進(jìn)程執(zhí)行完畢，然后打印出"主進(jìn)程執(zhí)行"。運(yùn)行該程序，你將看到子進(jìn)程和主進(jìn)程交替執(zhí)行的結(jié)果。

三、進(jìn)程間通信
????????在實(shí)際并發(fā)編程中，進(jìn)程之間的通信是非常重要的。multiprocessing模塊提供了多種方法來(lái)實(shí)現(xiàn)進(jìn)程間的通信，包括隊(duì)列、管道、共享內(nèi)存等。

1. 隊(duì)列
????????隊(duì)列是一種常見的進(jìn)程間通信方式，它可以安全地傳遞數(shù)據(jù)，使得多個(gè)進(jìn)程之間可以方便地共享信息。以下是使用隊(duì)列實(shí)現(xiàn)進(jìn)程間通信的示例：

import multiprocessing

def producer(queue):
? ? for i in range(5):
? ? ? ? queue.put(i)
? ? ? ? print("生產(chǎn)者生產(chǎn)：", i)

def consumer(queue):
? ? while True:
? ? ? ? item = queue.get()
? ? ? ? if item is None:
? ? ? ? ? ? break
? ? ? ? print("消費(fèi)者消費(fèi)：", item)

if __name__ == '__main__':
? ? queue = multiprocessing.Queue()
? ? p = multiprocessing.Process(target=producer, args=(queue,))
? ? c = multiprocessing.Process(target=consumer, args=(queue,))
? ? p.start()
? ? c.start()
? ? p.join()
? ? c.join()

????????在上述示例中，我們首先創(chuàng)建了一個(gè)隊(duì)列`queue`，然后定義了一個(gè)生產(chǎn)者函數(shù)`producer`，用于向隊(duì)列中放入數(shù)據(jù)。接著，我們定義了一個(gè)消費(fèi)者函數(shù)`consumer`，用于從隊(duì)列中取出數(shù)據(jù)并進(jìn)行處理。在主程序中，我們創(chuàng)建了一個(gè)生產(chǎn)者進(jìn)程`p`和一個(gè)消費(fèi)者進(jìn)程`c`，并將隊(duì)列`queue`作為參數(shù)傳遞給它們。最后，我們啟動(dòng)并等待這兩個(gè)進(jìn)程執(zhí)行完畢。運(yùn)行該程序，你將看到生產(chǎn)者不斷向隊(duì)列中放入數(shù)據(jù)，而消費(fèi)者則不斷從隊(duì)列中取出并處理數(shù)據(jù)。

2. 管道
????????管道是另一種常用的進(jìn)程間通信方式，它提供了一個(gè)全雙工的通信機(jī)制，使得兩個(gè)進(jìn)程可以互相發(fā)送和接收數(shù)據(jù)。以下是使用管道實(shí)現(xiàn)進(jìn)程間通信的示例：

import multiprocessing

def sender(conn, messages):
? ? for message in messages:
? ? ? ? conn.send(message)
? ? ? ? print("發(fā)送消息：", message)
? ? conn.close()

def receiver(conn):
? ? while True:
? ? ? ? message = conn.recv()
? ? ? ? if message is None:
? ? ? ? ? ? break
? ? ? ? print("接收消息：", message)

if __name__ == '__main__':
? ? parent_conn, child_conn = multiprocessing.Pipe()
? ? messages = ['Hello', 'World', 'Bye']
? ? p = multiprocessing.Process(target=sender, args=(child_conn, messages,))
? ? c = multiprocessing.Process(target=receiver, args=(parent_conn,))
? ? p.start()
? ? c.start()
? ? p.join()
? ? c.join()

????????在上述示例中，我們首先使用`multiprocessing.Pipe()`創(chuàng)建了一對(duì)管道`parent_conn`和`child_conn`。然后，我們定義了一個(gè)發(fā)送者函數(shù)`sender`，用于向管道發(fā)送消息。接著，我們定義了一個(gè)接收者函數(shù)`receiver`，用于從管道接收消息。在主程序中，我們創(chuàng)建了一個(gè)發(fā)送者進(jìn)程`p`和一個(gè)接收者進(jìn)程`c`，并將管道`child_conn`和`parent_conn`傳遞給它們。最后，我們啟動(dòng)并等待這兩個(gè)進(jìn)程執(zhí)行完畢。運(yùn)行該程序，你將看到發(fā)送者不斷向管道發(fā)送消息，而接收者則不斷接收并打印出消息。

四、進(jìn)程池
????????在實(shí)際并發(fā)編程中，我們常常需要?jiǎng)?chuàng)建多個(gè)進(jìn)程來(lái)執(zhí)行任務(wù)。然而，頻繁地創(chuàng)建和銷毀進(jìn)程會(huì)帶來(lái)較大的開銷。為了減少這種開銷，我們可以使用multiprocessing模塊提供的進(jìn)程池。以下是使用進(jìn)程池實(shí)現(xiàn)并行任務(wù)執(zhí)行的示例：

import multiprocessing

def worker(task):
? ? print("執(zhí)行任務(wù)：", task)

if __name__ == '__main__':
? ? tasks = range(10)
? ? pool = multiprocessing.Pool()
? ? pool.map(worker, tasks)
? ? pool.close()
? ? pool.join()

????????在上述示例中，我們首先定義了一個(gè)任務(wù)函數(shù)`worker`，用于執(zhí)行具體的任務(wù)。在主程序中，我們創(chuàng)建了一個(gè)進(jìn)程池`pool`，然后使用`pool.map()`方法將任務(wù)函數(shù)`worker`和任務(wù)列表`tasks`傳遞給進(jìn)程池。進(jìn)程池會(huì)自動(dòng)分配任務(wù)給多個(gè)進(jìn)程來(lái)執(zhí)行，并返回結(jié)果。最后，我們使用`pool.close()`關(guān)閉進(jìn)程池，并使用`pool.join()`等待所有進(jìn)程執(zhí)行完畢。運(yùn)行該程序，你將看到任務(wù)并行執(zhí)行的結(jié)果。

不知道人工智能如何學(xué)習(xí)？不知道單片機(jī)如何運(yùn)作？不知道嵌入式究竟是何方神圣？搞不清楚什么是物聯(lián)網(wǎng)？遇到問(wèn)題無(wú)人可問(wèn)？來(lái)我的綠泡泡交流群吧！里面有豐富的人工智能資料，幫助你自主學(xué)習(xí)人工智能相關(guān)內(nèi)容，不論是基礎(chǔ)的Python教程、OpenCV教程以及機(jī)器學(xué)習(xí)等，都可以在群中找到；單片機(jī)畢設(shè)項(xiàng)目、單片機(jī)從入門到高階的詳細(xì)解讀、單片機(jī)的一系列資料也備好放入群中！關(guān)于嵌入式，我這里不僅僅有嵌入式相關(guān)書籍的電子版本，更是有豐富的嵌入式學(xué)習(xí)資料，100G stm32綜合項(xiàng)目實(shí)戰(zhàn)提升包，70G 全網(wǎng)最全嵌入式&物聯(lián)網(wǎng)資料包，嵌入式面試、筆試的資料，物聯(lián)網(wǎng)操作系統(tǒng)FreeRTOS課件源碼！群內(nèi)高手云集，各位大佬能夠?yàn)槟艖n解難，讓您在學(xué)習(xí)的過(guò)程中如虎添翼！掃碼進(jìn)群即可擁有這一切！還在等什么？趕快拿起手機(jī)，加入群聊吧！二維碼詳情

文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-835718.html

到了這里，關(guān)于Python中使用multiprocessing模塊創(chuàng)建進(jìn)程的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！