Searched refs:call_queue (Results 1 – 5 of 5) sorted by relevance
| /third_party/python/Lib/concurrent/futures/ |
| D | process.py | 215 def _process_worker(call_queue, result_queue, initializer, initargs): argument
237 call_item = call_queue.get(block=True)
297 self.call_queue = executor._call_queue
347 if self.call_queue.full():
357 self.call_queue.put(_CallItem(work_id,
503 self.call_queue.put_nowait(None)
511 self.call_queue.close()
512 self.call_queue.join_thread()
|
| /third_party/grpc/src/ruby/ext/grpc/ |
| D | rb_server.c | 204 grpc_completion_queue* call_queue = in grpc_rb_server_request_call() local
217 call_queue, s->queue, tag); in grpc_rb_server_request_call()
241 grpc_rb_md_ary_to_h(&st.md_ary), grpc_rb_wrap_call(call, call_queue), in grpc_rb_server_request_call()
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | server.pyx.pxi | 33 self, CompletionQueue call_queue not None,
46 call_queue.c_completion_queue, server_queue.c_completion_queue,
|
| /third_party/protobuf/python/ |
| D | mox.py | 519 def __init__(self, method_name, call_queue, replay_mode): argument
534 self._call_queue = call_queue
535 if not isinstance(call_queue, deque):
|
| /third_party/python/Lib/test/ |
| D | test_concurrent_futures.py | 537 call_queue = executor._call_queue
547 call_queue.join_thread()
559 call_queue = executor._call_queue
568 call_queue.join_thread()
|