中斷一個Queue.get

Question

我怎麼能中斷在Python 3.X阻塞Queue.get()？

在Python 2.X setting a long timeout似乎工作，但同樣不能爲Python 3.5可說的。

運行在Windows 7上，CPython的3.5.1，64位機都和Python。 似乎它在Ubuntu上表現不一樣。

Answer 1

它在Python 2上工作的原因是，在Python 2上超時的Queue.get執行得非常糟糕，as a polling loop with increasing sleeps between non-blocking attempts to acquire the underlying lock; Python 2實際上並不具有支持定時阻塞獲取的鎖定原語（這是變量需要的內部變量，但缺少，因此它使用繁忙循環）。當你想這對Python 2中，你檢查所有是Ctrl-C是否的（短）一個後處理time.sleep通話結束，並the longest sleep in Condition is only 0.05 seconds，這是如此之短，你可能就算你按Ctrl不會注意到-C即刻開始新的睡眠。

的Python 3具有真定時鎖獲取支持（由於縮小目標的操作系統的數目的那些配有本地定時互斥或某種旗語）。因此，您實際上在整個超時期間阻止了鎖的獲取，在輪詢嘗試之間的時間不會阻塞0.05s。

它看起來像Windows允許用於註冊處理程序按Ctrl-C是不是意味着Ctrl-C doesn't necessarily generate a true signal，所以獲取鎖不被中斷來處理它。當定時鎖獲取最終失敗時，Python會被告知Ctrl-C，所以如果超時時間很短，您最終將看到KeyboardInterrupt，但直到超時失敗纔會看到它。由於Python 2 Condition一次只能睡眠0.05秒（或更少），因此Ctrl-C總是被快速處理，但是Python 3將一直處於睡眠狀態直到獲取鎖定。

Ctrl-Break保證表現爲信號，但它也不能由Python正確處理（它只是殺死進程），這可能不是你想要的。

如果你想Ctrl-C工作，你在一定程度上堅持投票，但至少（不像Python 2），你可以有效地輪詢Ctrl-C，而其餘時間在隊列上實時阻塞（所以你提醒一件物品立即變得空閒，這是常見的情況）。

import time 
import queue 

def get_timed_interruptable(q, timeout): 
    stoploop = time.monotonic() + timeout - 1 
    while time.monotonic() < stoploop: 
     try: 
      return q.get(timeout=1) # Allow check for Ctrl-C every second 
     except queue.Empty: 
      pass 
    # Final wait for last fraction of a second 
    return q.get(timeout=max(0, stoploop + 1 - time.monotonic()))     

此塊用於在第二時間，直到：

1. 剩餘的時間是小於第二（它對於剩餘的時間塊，然後允許Empty正常傳播）
2. Ctrl-C在一秒間隔內被按下（在該秒的剩餘時間過去之後，KeyboardInterrupt被提出）
3. 一個項目被獲取（如果Ctrl-C被按下，它將在此時上升t OO）

Answer 2

正如評論跟帖中提到上面提供的巨大答案@ShadowRanger，這裏是他的功能的另一種簡化形式：

import queue 


def get_timed_interruptable(in_queue, timeout): 
    '''                   
    Perform a queue.get() with a short timeout to avoid       
    blocking SIGINT on Windows.             
    ''' 
    while True: 
     try: 
      # Allow check for Ctrl-C every second        
      return in_queue.get(timeout=min(1, timeout)) 
     except queue.Empty: 
      if timeout < 1: 
       raise 
      else: 
       timeout -= 1 

而作爲@Bharel在評論中指出，這可能比絕對超時運行幾毫秒，這可能是不可取的。因此這裏是顯著更高精度版本：

import time 
import queue 


def get_timed_interruptable_precise(in_queue, timeout): 
    '''                   
    Perform a queue.get() with a short timeout to avoid       
    blocking SIGINT on Windows. Track the time closely 
    for high precision on the timeout.             
    ''' 
    timeout += time.monotonic() 
    while True: 
     try: 
      # Allow check for Ctrl-C every second        
      return in_queue.get(timeout=min(1, timeout - time.monotonic())) 
     except queue.Empty: 
      if time.monotonic() > timeout: 
       raise 
      else: 
       pass