Lines Matching defs:queue
29 - adds the id of the _WorkItem to the "Work Ids" queue
32 - reads work ids from the "Work Ids" queue and looks up the corresponding
50 import queue
103 # Controls how many more calls than processes will be queued in the call queue.
106 # (Futures in the call queue cannot be cancelled).
112 # - the result queue reader
246 # Wake up queue management thread
298 # will wake up the queue management thread so that it can terminate
320 # A queue.Queue of work ids e.g. Queue([5, 6, ...]).
386 except queue.Empty:
519 # add items to the call queue.
523 except queue.Empty:
540 except queue.Full:
545 # Release the queue's resources as soon as possible.
707 # Make the call queue slightly larger than the number of processes to
709 # because futures in the call queue cannot be cancelled.
717 # tracebacks in the queue's own worker thread. But we detect killed
721 self._work_ids = queue.Queue()
783 # Wake up queue management thread
826 # Wake up queue management thread