| /third_party/grpc/src/python/grpcio/grpc/beta/ |
| D | implementations.py | 144 metadata_transformer, thread_pool, thread_pool_size): argument
160 thread_pool=None, argument
243 response_serializers, thread_pool, thread_pool_size, argument
260 thread_pool=None, argument
|
| D | _server_adaptations.py | 372 request_deserializers, response_serializers, thread_pool, argument
|
| /third_party/mindspore/mindspore/lite/src/ |
| D | executor.cc | 28 auto thread_pool = ctx_->thread_pool(); in Run() local
|
| D | mindrt_executor.cc | 175 auto thread_pool = ctx_->thread_pool(); in Run() local
|
| D | inner_context.cc | 387 ThreadPool *InnerContext::thread_pool() const { return thread_pool_; } in thread_pool() function in mindspore::lite::InnerContext
|
| D | lite_session.cc | 997 ThreadPool *thread_pool = this->context_->thread_pool(); in InitGPURuntime() local
1031 ThreadPool *thread_pool = this->context_->thread_pool(); in InitGPURuntime() local
|
| D | lite_mindrt.cc | 793 ActorThreadPool *thread_pool = reinterpret_cast<ActorThreadPool *>(ctx->thread_pool()); in CreateOpActor() local
|
| /third_party/boost/libs/thread/test/ |
| D | test_scheduling_adaptor.cpp | 27 typedef boost::executors::basic_thread_pool thread_pool; typedef
|
| D | test_scheduler.cpp | 26 typedef boost::executors::basic_thread_pool thread_pool; typedef
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
| D | server.pxd.pxi | 91 cdef thread_pool(self) member in AioServer
|
| D | common.pyx.pxi | 137 async def generator_to_async_generator(object gen, object loop, object thread_pool):
|
| D | server.pyx.pxi | 820 def __init__(self, loop, thread_pool, generic_handlers, interceptors, argument
1045 cdef thread_pool(self): member in AioServer
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _cancel_many_calls_test.py | 94 def _serve(state, server, server_completion_queue, thread_pool): argument
|
| /third_party/grpc/src/python/grpcio/grpc/ |
| D | _server.py | 706 def _handle_with_method_handler(rpc_event, method_handler, thread_pool): argument
729 def _handle_call(rpc_event, generic_handlers, interceptor_pipeline, thread_pool, argument
766 interceptor_pipeline, thread_pool, maximum_concurrent_rpcs): argument
947 def __init__(self, thread_pool, generic_handlers, interceptors, options, argument
991 def create_server(thread_pool, generic_rpc_handlers, interceptors, options, argument
|
| D | __init__.py | 2017 def server(thread_pool, argument
|
| /third_party/grpc/src/python/grpcio_tests/tests/health_check/ |
| D | _health_servicer_test.py | 48 def start_server(self, non_blocking=False, thread_pool=None): argument
|
| /third_party/glib/tests/ |
| D | asyncqueue-test.c | 33 static GThreadPool *thread_pool = NULL; variable
|
| /third_party/glib/gio/ |
| D | gthreadedsocketservice.c | 55 GThreadPool *thread_pool; member
|
| /third_party/mindspore/mindspore/ccsrc/backend/kernel_compiler/cpu/ |
| D | cpu_kernel.cc | 150 auto thread_pool = actor_manager->GetActorThreadPool(); in GetActorMgrInnerThreadPool() local
172 auto thread_pool = GetActorMgrInnerThreadPool(); in ParallelLaunch() local
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | _rpc_test_helpers.py | 64 def __init__(self, control, thread_pool): argument
|
| D | _rpc_test.py | 65 def __init__(self, control, thread_pool): argument
|
| /third_party/boost/libs/asio/include/boost/asio/ |
| D | thread_pool.hpp | 75 class thread_pool class
|
| /third_party/boost/boost/asio/ |
| D | thread_pool.hpp | 75 class thread_pool class
|
| /third_party/gstreamer/gstplugins_bad/ext/dtls/ |
| D | gstdtlsconnection.c | 107 GThreadPool *thread_pool; member
|