緩衝區生成器

Question

我有一個消費者從我的生成器獲取數據。現在，消費者和發電機約需同一時間來處理，所以我總運行時間爲：

(t_generator + t_consumer) * number_of_items

我現在要運行，而我的消費過程中的當前項目的下一個項目發生器，使得我的消費者不必等待t_generator

這是如何在Python3中實現的？

EDIT（加小樣本）：

g = my_generator() # cannot change this 

intermediate = ??? # Do whatever you want. Maybe something like a queue which takes n from g and yields to consumer whenever ready? 

processed p = consume(intermediate) # cannot change this 

Answer 1

你可以使用一個Thread。

你沒有提供任何示例代碼，所以我只能指出你的文檔。如果您遇到問題，請參閱python的多線程tutorialspoint的this教程。

Answer 2

你可以線程（因爲你生產&消費者沒有使用相同的資源）：

from threading import Queue, Thread 
g = my_generator() # cannot change this 

q = Queue() 
def fill_up(): 
    for stuff in g: 
     q.put(stuff) 


Thread(target=fill_up).start() 

consume((q.get() for _ in range(2**32))