取消線程中的任務執行並從隊列中刪除任務

Question

Python應用程序我正在開發一個文件夾的監視器並將某些新的或更改的文件上載到服務器。作爲一個任務隊列，我使用了Queue模塊和一個工作線程池。

有時在上傳過程中文件發生變化，上傳需要被取消並全部開始。

我知道如何使用threading.Event來停止線程執行，但是如何移除或移動Queue中的任務？

Answer 1

這樣做將標誌着你已經裝載到Queue作爲取消實例的最簡單的方法：在你的消費線程

class Task(object): 
    def __init__(self, data): 
     self.cancelled = False 
     self.data = data 

    def cancel(self): 
     self.cancelled = True 

q = Queue.Queue() 
t = Task("some data to put in the queue") 
q.put(t) 

# Later 
t.cancel() 

然後：

task = q.get() 
if task.cancelled: 
    # Skip it 
else: 
    # handle it. 

也可以與直接交互Queue在內部使用，前提是您獲取用於同步訪問Queue的內部互斥鎖：

>>> import Queue 
>>> q = Queue.Queue() 
>>> q.put("a") 
>>> q.put("b") 
>>> q.put("c") 
>>> q.put("d") 
>>> q.queue[2] 
'c' 
>>> q.queue[3] 
'd' 
>>> with q.mutex: # Always acquire the lock first in actual usage 
... q.queue[3] 
... 
'd' 

雖然這應該工作，不建議用Queue的內部搞亂，並且可以跨Python版本打破如果Queue變更的實現。此外，請記住append/appendleft和pop/popleft以外的操作在deque上的執行效果不如在list實例上的效果;甚至像__getitem__那樣簡單的東西是O(n)。