Home
last modified time | relevance | path

Searched refs:pending_work_items (Results 1 – 1 of 1) sorted by relevance

/external/python/cpython3/Lib/concurrent/futures/
Dprocess.py174 def __init__(self, max_size=0, *, ctx, pending_work_items, thread_wakeup): argument
175 self.pending_work_items = pending_work_items
183 work_item = self.pending_work_items.pop(obj.work_id, None)
326 self.pending_work_items = executor._pending_work_items
378 if not self.pending_work_items:
393 work_item = self.pending_work_items[work_id]
402 del self.pending_work_items[work_id]
440 work_item = self.pending_work_items.pop(result_item.work_id, None)
482 for work_id, work_item in self.pending_work_items.items():
493 self.pending_work_items.clear()
[all …]