Home
last modified time | relevance | path

Searched defs:thread_pool (Results 1 – 25 of 62) sorted by relevance

123

/external/libiio/src/iiod/
Dthread-pool.c38 struct thread_pool { struct
46 struct thread_pool *pool; argument
79 void (*f)(struct thread_pool *, void *), in thread_pool_add_thread() argument
/external/eigen/unsupported/test/
Dcxx11_tensor_notification.cpp20 ThreadPool thread_pool(1); in test_notification_single() local
44 ThreadPool thread_pool(1); in test_notification_multiple() local
Dcxx11_tensor_thread_local.cpp38 Eigen::ThreadPool thread_pool(num_threads); in test_simple_thread_local() local
78 Eigen::ThreadPool thread_pool(num_threads); in test_large_number_of_tasks_no_spill() local
113 Eigen::ThreadPool thread_pool(num_threads); in test_large_number_of_tasks_with_spill() local
/external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/
Dclient_server_test.cc94 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
176 tensorflow::thread::ThreadPool thread_pool( in TEST() local
223 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
272 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
332 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
376 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
414 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
/external/grpc-grpc/src/python/grpcio/grpc/beta/
Dimplementations.py144 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
/external/tensorflow/tensorflow/core/lib/core/
Dnotification_test.cc27 thread::ThreadPool* thread_pool = in TEST() local
56 thread::ThreadPool* thread_pool = in TEST() local
Dblocking_counter_test.cc38 thread::ThreadPool* thread_pool = in TEST() local
55 std::unique_ptr<thread::ThreadPool> thread_pool( in BM_BlockingCounter() local
/external/tensorflow/tensorflow/core/util/
Ddebug_events_writer_test.cc102 thread::ThreadPool* thread_pool = in TEST_F() local
127 thread::ThreadPool* thread_pool = in TEST_F() local
207 thread::ThreadPool* thread_pool = in TEST_F() local
430 thread::ThreadPool* thread_pool = in TEST_F() local
471 thread::ThreadPool* thread_pool = in TEST_F() local
513 thread::ThreadPool* thread_pool = in TEST_F() local
641 thread::ThreadPool* thread_pool = in TEST_F() local
760 thread::ThreadPool* thread_pool = in TEST_F() local
804 thread::ThreadPool* thread_pool = in TEST_F() local
/external/grpc-grpc/src/python/grpcio/grpc/
D_server.py523 def _handle_unary_unary(rpc_event, state, method_handler, thread_pool): argument
532 def _handle_unary_stream(rpc_event, state, method_handler, thread_pool): argument
541 def _handle_stream_unary(rpc_event, state, method_handler, thread_pool): argument
550 def _handle_stream_stream(rpc_event, state, method_handler, thread_pool): argument
592 def _handle_with_method_handler(rpc_event, method_handler, thread_pool): argument
615 def _handle_call(rpc_event, generic_handlers, interceptor_pipeline, thread_pool, argument
652 interceptor_pipeline, thread_pool, maximum_concurrent_rpcs): argument
805 def __init__(self, thread_pool, generic_handlers, interceptors, options, argument
835 def create_server(thread_pool, generic_rpc_handlers, interceptors, options, argument
/external/rust/crates/rayon-core/src/thread_pool/
Dtest.rs14 let thread_pool = ThreadPoolBuilder::new().build().unwrap(); in panic_propagate() localVariable
26 let thread_pool = ThreadPoolBuilder::new().num_threads(22).build().unwrap(); in workers_stop() localVariable
55 let thread_pool = ThreadPoolBuilder::new().num_threads(22).build().unwrap(); in sleeper_stop() localVariable
/external/rust/crates/futures-executor/src/
Dlib.rs64 mod thread_pool; module
/external/libgav1/libgav1/src/
Dthreading_strategy.h74 ThreadPool* thread_pool() const { return thread_pool_.get(); } in thread_pool() function
/external/ruy/ruy/
Dcontext.cc39 const ThreadPool& Context::thread_pool() const { return ctx().thread_pool(); } in thread_pool() function in ruy::Context
Dctx.cc42 const ThreadPool& Ctx::thread_pool() const { return impl().thread_pool_; } in thread_pool() function in ruy::Ctx
/external/tensorflow/tensorflow/core/kernels/
Dbincount_op.cc56 ThreadPool* thread_pool = in Compute() local
101 ThreadPool* thread_pool = in Compute() local
175 ThreadPool* thread_pool = in Compute() local
/external/tensorflow/tensorflow/core/common_runtime/
Dsingle_threaded_cpu_device.cc34 static thread::ThreadPool* thread_pool = in GraphRunnerThreadPool() local
/external/tensorflow/tensorflow/cc/client/
Dclient_session_test.cc121 thread::ThreadPool thread_pool(Env::Default(), "pool", 2); in TEST() local
161 thread::ThreadPool thread_pool(Env::Default(), "pool", 2); in TEST() local
/external/tensorflow/tensorflow/compiler/mlir/tfrt/benchmarks/
Dbenchmark_mlir_function.cc128 Eigen::ThreadPool thread_pool(num_threads); in RunEigenBenchmark() local
/external/tensorflow/tensorflow/compiler/xla/service/
Dplatform_util.cc182 tensorflow::thread::ThreadPool thread_pool( in GetStreamExecutors() local
Dcompiler.h171 tensorflow::thread::ThreadPool* thread_pool = nullptr; member
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/
D_cancel_many_calls_test.py94 def _serve(state, server, server_completion_queue, thread_pool): argument
/external/tensorflow/tensorflow/core/kernels/linalg/
Dmatrix_diag_op.cc400 auto thread_pool = in Compute() local
460 auto thread_pool = in Compute() local
/external/tensorflow/tensorflow/compiler/xla/tools/
Dreplay_computation.cc308 Eigen::ThreadPoolDevice thread_pool(pool.AsEigenThreadPool(), in ReplayComputation() local
459 tensorflow::thread::ThreadPool thread_pool( in RealMain() local
/external/rust/crates/tokio/src/runtime/thread_pool/
Dmod.rs55 let thread_pool = ThreadPool { spawner }; in new() localVariable
/external/rust/crates/rayon-core/src/spawn/
Dtest.rs64 let thread_pool = ThreadPoolBuilder::new().build().unwrap(); in termination_while_things_are_executing() localVariable

123