| /third_party/mindspore/mindspore-src/source/mindspore/lite/src/litert/ |
| D | thread_pool_reuse_manager.cc | 30 for (auto &thread_pool : pair.second) { in ~ThreadPoolReuseManager() local
52 auto thread_pool = thread_pool_container_[hash_key].back(); in GetThreadPool() local
66 ThreadPool *thread_pool) { in RetrieveThreadPool()
|
| D | executor.cc | 28 auto thread_pool = ctx_->thread_pool_; in Run() local
|
| D | parallel_lite_actor.cc | 132 auto thread_pool = reinterpret_cast<ActorThreadPool *>(ctx_->thread_pool_); in KernelActorInit() local
|
| D | mindrt_executor.cc | 339 auto thread_pool = ctx_->thread_pool_; in Run() local
|
| /third_party/grpc/src/python/grpcio/grpc/beta/ |
| D | implementations.py | 149 thread_pool, argument
168 thread_pool=None, argument
264 thread_pool, argument
285 thread_pool=None, argument
|
| /third_party/grpc/test/core/event_engine/windows/ |
| D | iocp_test.cc | 59 auto thread_pool = grpc_event_engine::experimental::MakeThreadPool(8); in TEST_F() local
144 auto thread_pool = grpc_event_engine::experimental::MakeThreadPool(8); in TEST_F() local
211 auto thread_pool = grpc_event_engine::experimental::MakeThreadPool(8); in TEST_F() local
236 auto thread_pool = grpc_event_engine::experimental::MakeThreadPool(8); in TEST_F() local
271 auto thread_pool = grpc_event_engine::experimental::MakeThreadPool(8); in TEST_F() local
|
| D | windows_endpoint_test.cc | 43 auto thread_pool = MakeThreadPool(8); in TEST_F() local
89 auto thread_pool = MakeThreadPool(8); in TEST_F() local
|
| /third_party/grpc/src/core/lib/event_engine/thread_pool/ |
| D | thread_pool_factory.cc | 39 auto thread_pool = std::make_shared<WorkStealingThreadPool>(reserve_threads); in MakeThreadPool() local
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
| D | server.pxd.pxi | 92 cdef thread_pool(self) member in AioServer
|
| D | common.pyx.pxi | 141 async def generator_to_async_generator(object gen, object loop, object thread_pool):
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/plugin/device/cpu/kernel/pyboost/ |
| D | pyboost_cpu_kernel_extra_func.cc | 31 auto thread_pool = kernel::GetActorMgrInnerThreadPool(); in SetThreadPool() local
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/plugin/device/cpu/optimizer/ |
| D | cpu_pass_utils.cc | 79 auto thread_pool = kernel::GetActorMgrInnerThreadPool(); in AddCastOpNodeToGraph() local
|
| /third_party/grpc/src/core/lib/event_engine/windows/ |
| D | windows_engine.h | 101 ThreadPool* thread_pool() { return thread_pool_.get(); } in thread_pool() function
|
| D | windows_endpoint.h | 107 ThreadPool* thread_pool; member
|
| D | iocp.cc | 35 IOCP::IOCP(ThreadPool* thread_pool) noexcept in IOCP()
|
| D | windows_endpoint.cc | 55 const EndpointConfig& /* config */, ThreadPool* thread_pool, in WindowsEndpoint()
379 ThreadPool* thread_pool) in AsyncIOState()
|
| D | windows_engine.cc | 100 ThreadPool* thread_pool) { in FinishConnectingAndMakeEndpoint()
155 WindowsEventEngine::IOCPWorkClosure::IOCPWorkClosure(ThreadPool* thread_pool, in IOCPWorkClosure()
|
| D | win_socket.cc | 42 WinSocket::WinSocket(SOCKET socket, ThreadPool* thread_pool) noexcept in WinSocket()
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/plugin/device/cpu/hal/profiler/ |
| D | cpu_profiling.cc | 74 auto thread_pool = actor_manager->GetActorThreadPool(); in SetRuntimeStart() local
92 auto thread_pool = actor_manager->GetActorThreadPool(); in SetRuntimeEnd() local
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/plugin/device/cpu/kernel/ |
| D | cpu_kernel.cc | 186 auto thread_pool = actor_manager->GetActorThreadPool(); in GetActorMgrInnerThreadPool() local
206 auto thread_pool = pool == nullptr ? GetActorMgrInnerThreadPool() : pool; in ParallelLaunch() local
232 auto thread_pool = pool == nullptr ? GetActorMgrInnerThreadPool() : pool; in ParallelLaunch() local
258 auto thread_pool = pool == nullptr ? GetActorMgrInnerThreadPool() : pool; in ParallelLaunchAutoSearch() local
|
| /third_party/grpc/src/core/lib/event_engine/posix_engine/ |
| D | timer_manager.cc | 87 std::shared_ptr<grpc_event_engine::experimental::ThreadPool> thread_pool) in TimerManager()
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _cancel_many_calls_test.py | 102 def _serve(state, server, server_completion_queue, 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/mindspore/mindspore-src/source/mindspore/ccsrc/plugin/device/cpu/kernel/mkldnn/ |
| D | mkl_cpu_kernel.h | 211 auto thread_pool = pool_ == nullptr ? GetActorMgrInnerThreadPool() : pool_; in MKLCpuKernelMod() local
|
| /third_party/mindspore/mindspore-src/source/mindspore/core/mindrt/src/thread/ |
| D | parallel_thread_pool_manager.cc | 84 ParallelThreadPool *thread_pool = static_cast<ParallelThreadPool *>(pool); in GetThreadPoolSize() local
|