Searched refs:canceled_flag (Results 1 – 1 of 1) sorted by relevance
47 def __init__(self, queue_impl, canceled_flag): argument48 self.canceled_flag = canceled_flag60 self.canceled_flag.value = 164 if self.canceled_flag.value:219 canceled_flag = multiprocessing.Value('i', 0)230 canceled_flag = LockedValue(0)234 provider = TestProvider(queue_impl, canceled_flag)