Python多進程中如何使用Queue傳輸數(shù)據(jù)
1. 準備工作打開VMware虛擬化軟件，啟動Ubuntu虛擬機，并登錄系統(tǒng)。在終端中使用gedit工具創(chuàng)建一個名為的文件。2. 編寫代碼骨架在文件中編寫以下代碼：```pythonimport qu
1. 準備工作
打開VMware虛擬化軟件，啟動Ubuntu虛擬機，并登錄系統(tǒng)。在終端中使用gedit工具創(chuàng)建一個名為的文件。
2. 編寫代碼骨架
在文件中編寫以下代碼：
```python
import queue
from multiprocessing import Process
def readqu(q):
pass
def writequ(q):
pass
if __name__ '__main__':
print('ok')
```
這段代碼只是程序的骨架，定義了讀隊列和寫隊列兩個進程，實現(xiàn)了進程間的數(shù)據(jù)傳輸。
3. 驗證程序運行
在終端中運行上一步的代碼：
```
python3
```
如果打印出"ok"，則表示程序沒有問題。
4. 創(chuàng)建隊列實例
接下來我們繼續(xù)編寫代碼，創(chuàng)建一個隊列實例，并實現(xiàn)隊列的寫入和讀取操作。
```python
import queue
from multiprocessing import Process
def readqu(q):
print(())
print(())
print(())
def writequ(q):
q.put('abc')
q.put('e')
q.put('f')
if __name__ '__main__':
q queue.Queue()
writequ(q)
readqu(q)
```
盡管以上代碼實現(xiàn)了隊列的寫入和讀取，但是只有一個主進程在運行。
5. 多進程中使用Queue
我們修改代碼，將寫入隊列和讀取隊列的操作分別放在兩個不同的進程中。
```python
from multiprocessing import Process, Queue
def readqu(q):
print(())
print(())
print(())
def writequ(q):
q.put('abc')
q.put('e')
q.put('f')
if __name__ '__main__':
q Queue()
pw Process(targetwritequ, args(q,))
pr Process(targetreadqu, args(q,))
()
()
()
()
print('ok')
```
這里需要特別注意，我們使用了多進程導(dǎo)入的Queue。
6. 驗證多進程數(shù)據(jù)傳輸
在終端中運行上一步的代碼：
```
python3
```
如果打印出隊列的內(nèi)容，并且最后打印出"ok"，則表示在多進程中實現(xiàn)了數(shù)據(jù)的傳輸。