Searched refs:pending_work_items (Results 1 – 1 of 1) sorted by relevance
160 def __init__(self, max_size=0, *, ctx, pending_work_items, shutdown_lock, argument162 self.pending_work_items = pending_work_items171 work_item = self.pending_work_items.pop(obj.work_id, None)307 self.pending_work_items = executor._pending_work_items339 if not self.pending_work_items:354 work_item = self.pending_work_items[work_id]363 del self.pending_work_items[work_id]412 work_item = self.pending_work_items.pop(result_item.work_id, None)454 for work_id, work_item in self.pending_work_items.items():458 self.pending_work_items.clear()[all …]