Lines Matching refs:get
103 get = inqueue.get
114 task = get()
360 return self.apply_async(func, args, kwds).get()
367 return self._map_async(func, iterable, mapstar, chunksize).get()
375 return self._map_async(func, iterable, starmapstar, chunksize).get()
504 change_notifier.get()
531 for taskseq, set_length in iter(taskqueue.get, None):
574 def _handle_results(outqueue, get, cache):
579 task = get()
602 task = get()
626 get()
767 def get(self, timeout=None):
936 self._quick_get = self._outqueue.get
950 inqueue.get(block=False)