Searched refs:task_done (Results 1 – 20 of 20) sorted by relevance
73 :meth:`task_done` to indicate that the item was retrieved and all92 .. method:: task_done()97 fetch a task, a subsequent call to :meth:`task_done` tells the101 items have been processed (meaning that a :meth:`task_done`174 queue.task_done()
167 .. method:: Queue.task_done()171 :meth:`task_done` tells the queue that the processing on the task is complete.174 processed (meaning that a :meth:`task_done` call was received for every item186 The count goes down whenever a consumer thread calls :meth:`task_done` to202 q.task_done()
693 :meth:`~queue.Queue.task_done` and :meth:`~queue.Queue.join` methods introduced697 :meth:`JoinableQueue.task_done` for each task removed from the queue or else the778 :meth:`~queue.Queue.task_done` and :meth:`~queue.Queue.join`.908 additionally has :meth:`task_done` and :meth:`join` methods.910 .. method:: task_done()914 call to :meth:`task_done` tells the queue that the processing on the task918 items have been processed (meaning that a :meth:`task_done` call was931 :meth:`task_done` to indicate that the item was retrieved and all work on
156 q.task_done()160 q.task_done()184 q.task_done()197 q.task_done()
3722 log_queue.task_done()
1095 q.task_done()
97 operator()(const task_sptr& task_done);
96 queue.task_done()
187 def task_done(self): member in Queue
57 def task_done(self): member in Queue
607 self.assertRaises(ValueError, q.task_done)626 q.task_done()
1166 task_done = False1170 nonlocal task_done1177 task_done = True1186 self.assertTrue(task_done)1194 task_done = False1198 nonlocal task_done1205 task_done = True1214 self.assertTrue(task_done)
322 def task_done(self): member in JoinableQueue
1545 q.task_done()1549 q.task_done()
724 self.queue.task_done()
2668 operator()(const task_sptr& task_done) in operator ()() argument2670 compare_task_sptr comp_task = dynamic_pointer_cast<compare_task>(task_done); in operator ()()
1133 Fix :class:`~logging.handlers.QueueListener` to call ``queue.task_done()``
815 :meth:`Queue.task_done() <asyncio.Queue.task_done>` queue methods.
1504 the other new method, :meth:`task_done`, to signal that processing for an item
18972 - Queue.Queue objects now support .task_done() and .join() methods