Searched refs:call_queue (Results 1 – 6 of 6) sorted by relevance
| /external/python/futures/concurrent/futures/ |
| D | process.py | 108 def _process_worker(call_queue, result_queue): argument
122 call_item = call_queue.get(block=True)
139 call_queue): argument
155 if call_queue.full():
165 call_queue.put(_CallItem(work_id,
178 call_queue, argument
201 call_queue.put(None)
206 call_queue)
236 call_queue.close()
|
| /external/python/cpython3/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()
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_server.c | 200 grpc_completion_queue* call_queue = in grpc_rb_server_request_call() local
213 call_queue, s->queue, tag); in grpc_rb_server_request_call()
237 grpc_rb_md_ary_to_h(&st.md_ary), grpc_rb_wrap_call(call, call_queue), in grpc_rb_server_request_call()
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | server.pyx.pxi | 44 self, CompletionQueue call_queue not None,
57 call_queue.c_completion_queue, server_queue.c_completion_queue,
|
| /external/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):
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 520 call_queue = executor._call_queue
529 call_queue.join_thread()
541 call_queue = executor._call_queue
550 call_queue.join_thread()
|