asyncio.Queue.putを除いて間違っていますか？私の見解では

Question

asyncioの\のqueues.py

@coroutine 
def put(self, item): 
    """Put an item into the queue. 

    Put an item into the queue. If the queue is full, wait until a free 
    slot is available before adding item. 

    This method is a coroutine. 
    """ 
    while self.full(): 
     putter = futures.Future(loop=self._loop) 
     self._putters.append(putter) 
     try: 
      yield from putter 
     except: 
      putter.cancel() # Just in case putter is not done yet. 
      if not self.full() and not putter.cancelled(): 
       # We were woken up by get_nowait(), but can't take 
       # the call. Wake up the next in line. 
       self._wakeup_next(self._putters) 
      raise 
    return self.put_nowait(item) 

、putterはcancel、set_exceptionまたはset_resultによって行うことができます。 get_nowaitset_resultを使用してください。 cancelとset_exceptionのみが例外をスローすると、except:が発生する可能性があります。私はexcept:は必要ないと思う。

なぜexcept:〜Wake up the next in lineが追加されますか？

更新： @Vincent _wakeup_nextコールset_result。 set_resultはself._state = _FINISHEDを実行します。 task1.cancel()self._fut_waiter.cancel()はFalseを返します。したがって、task1はをキャンセルしていないになります。

@Vincentおかげで非常に多くの

キー原因は、タスクが待っている未来はset_resultメソッドしたがtask.cancelは（self._state = _FINISHED）タスクをキャンセルすることができます。

Answer 1

putterを待つタスクがキャンセルされた場合、yield from putterはCancelledErrorを発生させます。これはget_nowait()が呼び出された後に発生し、キュー内で新しいスロットが使用可能であることを他のパターに通知する必要があります。

はここに例を示します

async def main(): 
    # Create a full queue 
    queue = asyncio.Queue(1) 
    await queue.put('A') 
    # Schedule two putters as tasks 
    task1 = asyncio.ensure_future(queue.put('B')) 
    task2 = asyncio.ensure_future(queue.put('C')) 
    await asyncio.sleep(0) 
    # Make room in the queue, print 'A' 
    print(queue.get_nowait()) 
    # Cancel task 1 before giving the control back to the event loop 
    task1.cancel() 
    # Thankfully, the putter in task 2 has been notified 
    await task2 
    # Print 'C' 
    print(await queue.get()) 

---

EDIT：内部で何が起こるのかについての詳細情報：

• queue.get_nowait()：putter.set_result(None)が呼び出されます。パターの状態は今やFINISHEDであり、制御がイベントループに戻されるとtask1は目を覚ます。
• task1.cancel()：task1._fut_waiterはすでに終了しているので、task1が実行されたときにはCancelledErrorを発生させるためにtask1._must_cancelがTrueに設定されます。
• await task2：
  • 制御は、制御ループ、及びtask1._step()実行に戻って与えられます。コルーチン内にCancelledErrorがスローされます。task1._coro.throw(CancelledError())
  • queue.putは例外をキャッチします。キューがいっぱいではなく、'B'が挿入されないため、キュー内の次のパターに通知する必要があります。self._wakeup_next(self._putters)。
  • そして、CancelledErrorが再発生され、task1._step()に捕らえられます。 task1は実際にはそれ自体をキャンセルします（super().cancel()）。