Searched refs:MultiprocessingRequestQueue (Results 1 – 2 of 2) sorted by relevance
16 from torch.distributed.elastic.timer.local_timer import MultiprocessingRequestQueue138 request_queue = MultiprocessingRequestQueue(mp_queue)160 request_queue = MultiprocessingRequestQueue(mp_queue)185 request_queue = MultiprocessingRequestQueue(mp_queue)
47 class MultiprocessingRequestQueue(RequestQueue): class90 super().__init__(MultiprocessingRequestQueue(mp_queue), max_interval, daemon)