不斷檢查清單，並做一些事情，如果列表中有項目

Question

我有一個全球性的列表，其中的項目不斷增加（從網絡客戶端）：

mylist = [] 
def additem(uuid,work): 
    mylist.append(uuid,work) 

而且一個函數，它應該檢查該列表，如果有物品繼續他們：

def proceeditems(): 

    while True: 
    itemdone = [] 
    if len(mylist) > 0: 
    for item in mylist: 
     try: 
      #This can go wrong and than need to be done again 
      result = gevent.spawn(somework(item)) 
      #result returns the uuid 
      itemdone.append(result.value) 
     except: 
      pass 
    for item in itemdone: 
     mylist[:] = [value for value in mylist if value[0]!=item] 

所以我希望你現在是我嘗試做得到一個想法，但我覺得無限循環似乎是不正確的解決方案。

Answer 1

在這種情況下，你必須使用，也可以多線程或者多（視網絡客戶端是否在不同的線程或者不同的進程中運行。

在這兩種情況下，你應該使用Queue管理輸入數據，然後存儲到itemdone事後

你這樣定義的隊列：

my_queue = queue.Queue() # or multiprocessing.Queue() 

後來的後來，你應該包括參數的隊列（或者，如果你使用線程ING，你可以使用全局隊列，像你這樣）

def additem(uuid,work,the_queue): 
    the_queue.put((uuid,word)) # Queue in a tuple containing the data 

def proceeditems(the_queue): 
    while True: 
     item = the_queue.get() # This will block until something is inside the queue 
     try: 
      result = somework(item) 
      itemdone.append(result) 
     except: 
      the_queue.put(item) # If failed, put back to queue for retry. 
     # You don't need the last two lines 

要停止的全過程，可以使additem功能，插入特殊標記，和proceeditems，收到了特殊標記，只會退出循環。