阻止版本StringIO.readlines（）

Question

有沒有辦法讓StringIO.readlines（）阻塞，直到流關閉或通過write（）使新數據可用？

我正在寫一個接口，希望像對象一樣阻塞文件，並且在將數據寫入到StringIO實例之前立即返回。使用initial_value參數也不是一個選項，因爲我需要使用中間結果。

另外還有任何其他（文本）文件就像在Python中的FIFO /流？

Answer 1

如果您使用threads那麼您應該使用Queue。如果您使用其他結構進行線程間通信，它將爲您節省一些嚴重的麻煩。

如果您只需要readlines()和write()，然後你可以用Queue：

class QueueStream(object): 
    def __init__(self): 
     self._queue = Queue() 

    def write(self, line): 
     self._queue.put(line) 

    def readlines(self): 
     while True: 
      item = self._queue.get() 
      yield item 
      self._queue.task_done()