Home
last modified time | relevance | path

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

1234

/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/tensorflow/tensorflow/compiler/xla/pjrt/
Dtracked_tfrt_cpu_device_buffer_test.cc35 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
68 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
105 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
134 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
Dpjrt_client_test.cc241 tensorflow::thread::ThreadPool thread_pool( in TEST_P() local
288 tensorflow::thread::ThreadPool thread_pool( in TEST_P() local
378 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
422 tensorflow::thread::ThreadPool thread_pool( in TEST() local
/external/libgav1/src/utils/
Dthreadpool_test.cc82 std::unique_ptr<ThreadPool> thread_pool = ThreadPool::Create(100); in TEST() local
95 std::unique_ptr<ThreadPool> thread_pool = ThreadPool::Create(100); in TEST() local
107 std::unique_ptr<ThreadPool> thread_pool = ThreadPool::Create(100); in TEST() local
114 std::unique_ptr<ThreadPool> thread_pool = ThreadPool::Create(0); in TEST() local
/external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/
Dclient_server_test.cc168 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST_P() local
251 tensorflow::thread::ThreadPool thread_pool( in TEST_P() local
287 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST_P() local
324 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST_P() local
374 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST_P() local
423 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST_P() local
464 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST_P() local
499 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST_P() local
529 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST_P() local
567 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST_P() local
[all …]
/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/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/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/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/tensorflow/tensorflow/core/tfrt/eager/
Dtfrt_context.h45 explicit ThreadPoolInterfaceWrapper(Eigen::ThreadPoolInterface* thread_pool) in ThreadPoolInterfaceWrapper()
67 Eigen::ThreadPoolInterface& thread_pool() const { in thread_pool() function
/external/rust/crates/rayon-core/src/thread_pool/
Dtest.rs12 let thread_pool = ThreadPoolBuilder::new().build().unwrap(); in panic_propagate() localVariable
25 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/src/
Dthreading_strategy.h74 ThreadPool* thread_pool() const { return thread_pool_.get(); } in thread_pool() function
Dthreading_strategy_test.cc215 ThreadPool* const thread_pool = in VerifyFrameParallel() local
286 ThreadPool* const thread_pool = in TEST() local
/external/tensorflow/tensorflow/core/kernels/
Dsearchsorted_op.cc56 thread::ThreadPool* thread_pool = worker_threads.workers; in Compute() local
85 thread::ThreadPool* thread_pool = worker_threads.workers; in Compute() local
Dbincount_op.cc58 ThreadPool* thread_pool = in Compute() local
103 ThreadPool* thread_pool = in Compute() local
177 ThreadPool* thread_pool = in Compute() local
/external/ruy/ruy/
Dcontext.cc39 const ThreadPool& Context::thread_pool() const { return ctx().thread_pool(); } in thread_pool() function in ruy::Context
/external/tensorflow/tensorflow/compiler/xla/tests/
Dmultithreaded_compilation_test.cc83 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in XLA_TEST_F() local
/external/cronet/base/task/thread_pool/
Dthread_pool_instance.cc111 void ThreadPoolInstance::Set(std::unique_ptr<ThreadPoolInstance> thread_pool) { in Set()
/external/tensorflow/tensorflow/core/common_runtime/
Dsingle_threaded_cpu_device.cc34 static thread::ThreadPool* thread_pool = in GraphRunnerThreadPool() local
/external/tensorflow/tensorflow/compiler/xla/runtime/
Dasync_runtime.h231 Eigen::ThreadPoolInterface* thread_pool) in EigenThreadPoolAsyncTaskRunner()
/external/tensorflow/tensorflow/examples/custom_ops_doc/sleep/
Dsleep_kernel.cc64 auto thread_pool = ctx->device()->tensorflow_cpu_worker_threads()->workers; in ComputeAsync() local

1234