我很難理解多處理隊列如何在python上工作以及如何實現它。假設我有兩個python模塊，它們從共享文件中訪問數據，我們將這兩個模塊稱為writer和Reader。我的計劃是讓讀取器和寫入器都將請求放入兩個單獨的多處理隊列中，然后讓第三個進程將這些請求循環彈出并照此執行。

我的主要問題是我真的不知道如何正確實現multiprocessing.queue，您不能為每個進程真正實例化對象，因為它們將是單獨的隊列，如何確保所有進程都與一個共享隊列相關(或在這種情況下，排隊)

參考方案

我的主要問題是我真的不知道如何正確實現multiprocessing.queue，您不能為每個進程真正實例化對象，因為它們將是單獨的隊列，如何確保所有進程都與一個共享隊列相關(或在這種情況下，排隊)

這是讀取器和寫入器共享一個隊列的簡單示例。寫入器向讀取器發送一堆整數。當寫入器的數字用完時，它將發送“DONE”(完成)，讓讀取器知道退出讀取循環。

from multiprocessing import Process, Queue

import time

import sys

def reader_proc(queue):

## Read from the queue; this will be spawned as a separate Process

while True:

msg = queue.get() # Read from the queue and do nothing

if (msg == 'DONE'):

break

def writer(count, queue):

## Write to the queue

for ii in range(0, count):

queue.put(ii) # Write 'count' numbers into the queue

queue.put('DONE')

if __name__=='__main__':

pqueue = Queue() # writer() writes to pqueue from _this_ process

for count in [10**4, 10**5, 10**6]:

### reader_proc() reads from pqueue as a separate process

reader_p = Process(target=reader_proc, args=((pqueue),))

reader_p.daemon = True

reader_p.start() # Launch reader_proc() as a separate python process

_start = time.time()

writer(count, pqueue) # Send a lot of stuff to reader()

reader_p.join() # Wait for the reader to finish

print("Sending {0} numbers to Queue() took {1} seconds".format(count,

(time.time() - _start)))

Python GPU資源利用 - python

我有一個Python腳本在某些深度學習模型上運行推理。有什么辦法可以找出GPU資源的利用率水平？例如，使用著色器，float16乘法器等。我似乎在網上找不到太多有關這些GPU資源的文檔。謝謝！ 參考方案 您可以嘗試在像Renderdoc這樣的GPU分析器中運行pyxthon應用程序。它將分析您的跑步情況。您將能夠獲得有關已使用資源，已用緩沖區，不同渲染狀態上…Python:圖像處理可產生皺紋紙效果 - python

也許很難描述我的問題。我正在尋找Python中的算法，以在帶有某些文本的白色圖像上創建皺紋紙效果。我的第一個嘗試是在帶有文字的圖像上添加一些真實的皺紋紙圖像(具有透明度)。看起來不錯，但副作用是文本沒有真正起皺。所以我正在尋找更好的解決方案，有什么想法嗎？謝謝 參考方案 除了使用透明性之外，假設您有兩張相同尺寸的圖像，一張在皺紋紙上明亮，一張在白色背景上有深…Python uuid4，如何限制唯一字符的長度 - python

在Python中，我正在使用uuid4()方法創建唯一的字符集。但是我找不到將其限制為10或8個字符的方法。有什么辦法嗎？uuid4()ffc69c1b-9d87-4c19-8dac-c09ca857e3fc謝謝。 參考方案 嘗試：x = uuid4() str(x)[:8] 輸出："ffc69c1b" Is there a way to…Python sqlite3數據庫已鎖定 - python

我在Windows上使用Python 3和sqlite3。我正在開發一個使用數據庫存儲聯系人的小型應用程序。我注意到，如果應用程序被強制關閉(通過錯誤或通過任務管理器結束)，則會收到sqlite3錯誤(sqlite3.OperationalError：數據庫已鎖定)。我想這是因為在應用程序關閉之前，我沒有正確關閉數據庫連接。我已經試過了： connectio…python:ConfigParser對象，然后再閱讀一次 - python

場景：我有一個配置文件，其中包含要執行的自動化測試的列表。這些測試是長期循環執行的。???配置文件的設計方式使ConfigParser可以讀取它。由于有兩個三個參數，因此我需要通過每個測試。現在，此配置文件由script(s1)調用，并且按照配置文件中的列表執行測試。Script(s1)第一次讀取配置，并且在每次測試完成后都會執行。閱讀兩次的要求：由于可能會…

總結

以上是生活随笔為你收集整理的python队列怎么用_如何在Python中使用多处理队列？ - python的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。