| /external/libiio/src/iiod/ |
| D | thread-pool.h | 21 struct thread_pool;
23 struct thread_pool * thread_pool_new(void);
25 int thread_pool_get_poll_fd(const struct thread_pool *pool);
26 void thread_pool_stop(struct thread_pool *pool);
27 void thread_pool_stop_and_wait(struct thread_pool *pool);
29 void thread_pool_destroy(struct thread_pool *pool);
31 int thread_pool_add_thread(struct thread_pool *pool,
32 void (*func)(struct thread_pool *, void *),
|
| D | thread-pool.c | 38 struct thread_pool { struct
46 struct thread_pool *pool; argument
47 void (*f)(struct thread_pool *, void *);
51 static void thread_pool_thread_started(struct thread_pool *pool) in thread_pool_thread_started()
58 static void thread_pool_thread_stopped(struct thread_pool *pool) in thread_pool_thread_stopped()
78 int thread_pool_add_thread(struct thread_pool *pool, in thread_pool_add_thread()
79 void (*f)(struct thread_pool *, void *), in thread_pool_add_thread() argument
123 struct thread_pool * thread_pool_new(void) in thread_pool_new()
125 struct thread_pool *pool; in thread_pool_new()
149 int thread_pool_get_poll_fd(const struct thread_pool *pool) in thread_pool_get_poll_fd()
[all …]
|
| D | ops.h | 49 struct thread_pool;
50 extern struct thread_pool *main_thread_pool;
69 struct thread_pool *pool;
78 bool is_socket, bool use_aio, struct thread_pool *pool);
82 struct thread_pool *pool);
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| D | implementations.py | 144 metadata_transformer, thread_pool, thread_pool_size): argument
149 self.thread_pool = thread_pool
160 thread_pool=None, argument
183 metadata_transformer, thread_pool, thread_pool_size)
243 response_serializers, thread_pool, thread_pool_size, argument
248 self.thread_pool = thread_pool
260 thread_pool=None, argument
289 response_serializers, thread_pool, thread_pool_size,
309 effective_options.response_serializers, effective_options.thread_pool,
|
| /external/eigen/unsupported/test/ |
| D | cxx11_tensor_notification.cpp | 20 ThreadPool thread_pool(1); in test_notification_single() local
25 thread_pool.Schedule(func); in test_notification_single()
44 ThreadPool thread_pool(1); in test_notification_multiple() local
49 thread_pool.Schedule(func); in test_notification_multiple()
50 thread_pool.Schedule(func); in test_notification_multiple()
51 thread_pool.Schedule(func); in test_notification_multiple()
52 thread_pool.Schedule(func); in test_notification_multiple()
|
| D | cxx11_tensor_thread_local.cpp | 38 Eigen::ThreadPool thread_pool(num_threads); in test_simple_thread_local() local
45 thread_pool.Schedule([&counter, &barrier]() { in test_simple_thread_local()
78 Eigen::ThreadPool thread_pool(num_threads); in test_large_number_of_tasks_no_spill() local
85 thread_pool.Schedule([&counter, &barrier]() { in test_large_number_of_tasks_no_spill()
113 Eigen::ThreadPool thread_pool(num_threads); in test_large_number_of_tasks_with_spill() local
120 thread_pool.Schedule([&counter, &barrier]() { in test_large_number_of_tasks_with_spill()
|
| /external/tensorflow/tensorflow/core/lib/core/ |
| D | notification_test.cc | 27 thread::ThreadPool* thread_pool = in TEST() local
33 thread_pool->Schedule([&start, &proceed, &counter] { in TEST()
48 delete thread_pool; // Wait for closure to finish. in TEST()
56 thread::ThreadPool* thread_pool = in TEST() local
64 thread_pool->Schedule([&n, &lock, &counter] { in TEST()
77 delete thread_pool; // Wait for all closures to finish. in TEST()
|
| D | blocking_counter_test.cc | 38 thread::ThreadPool* thread_pool = in TEST() local
43 thread_pool->Schedule([&bc] { bc.DecrementCount(); }); in TEST()
47 delete thread_pool; in TEST()
55 std::unique_ptr<thread::ThreadPool> thread_pool( in BM_BlockingCounter() local
61 thread_pool->Schedule([&bc, shards_per_thread] { in BM_BlockingCounter()
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _server.py | 523 def _handle_unary_unary(rpc_event, state, method_handler, thread_pool): argument
526 return thread_pool.submit(_unary_response_in_pool, rpc_event, state,
532 def _handle_unary_stream(rpc_event, state, method_handler, thread_pool): argument
535 return thread_pool.submit(_stream_response_in_pool, rpc_event, state,
541 def _handle_stream_unary(rpc_event, state, method_handler, thread_pool): argument
544 return thread_pool.submit(
550 def _handle_stream_stream(rpc_event, state, method_handler, thread_pool): argument
553 return thread_pool.submit(
592 def _handle_with_method_handler(rpc_event, method_handler, thread_pool): argument
602 method_handler, thread_pool)
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/ |
| D | client_server_test.cc | 94 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
97 thread_pool.Schedule([&, i]() { statuses[i] = thread_fn(i); }); in TEST()
176 tensorflow::thread::ThreadPool thread_pool( in TEST() local
179 thread_pool.Schedule([&, i]() { statuses[i] = functions[i](); }); in TEST()
223 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
226 thread_pool.Schedule([&, i]() { statuses[i] = thread_fn(i); }); in TEST()
272 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
275 thread_pool.Schedule([&, i]() { statuses[i] = thread_fn(i); }); in TEST()
332 tensorflow::thread::ThreadPool thread_pool(tensorflow::Env::Default(), in TEST() local
335 thread_pool.Schedule([&, i]() { statuses[i] = thread_fn(i); }); in TEST()
[all …]
|
| /external/tensorflow/tensorflow/core/util/ |
| D | debug_events_writer_test.cc | 102 thread::ThreadPool* thread_pool = in TEST_F() local
116 thread_pool->Schedule(fn); in TEST_F()
118 delete thread_pool; in TEST_F()
127 thread::ThreadPool* thread_pool = in TEST_F() local
145 thread_pool->Schedule(fn); in TEST_F()
147 delete thread_pool; in TEST_F()
207 thread::ThreadPool* thread_pool = in TEST_F() local
211 thread_pool->Schedule(fn); in TEST_F()
213 delete thread_pool; in TEST_F()
430 thread::ThreadPool* thread_pool = in TEST_F() local
[all …]
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _channel_connectivity_test.py | 85 thread_pool = _thread_pool.RecordingThreadPool(max_workers=None)
86 server = grpc.server(thread_pool, options=(('grpc.so_reuseport', 0),))
124 self.assertFalse(thread_pool.was_used())
127 thread_pool = _thread_pool.RecordingThreadPool(max_workers=None)
128 server = grpc.server(thread_pool, options=(('grpc.so_reuseport', 0),))
141 self.assertFalse(thread_pool.was_used())
|
| D | _channel_ready_future_test.py | 63 thread_pool = _thread_pool.RecordingThreadPool(max_workers=None)
64 server = grpc.server(thread_pool, options=(('grpc.so_reuseport', 0),))
84 self.assertFalse(thread_pool.was_used())
|
| /external/rust/crates/rayon-core/src/thread_pool/ |
| D | test.rs | 14 let thread_pool = ThreadPoolBuilder::new().build().unwrap(); in panic_propagate() localVariable
15 thread_pool.install(|| { in panic_propagate()
26 let thread_pool = ThreadPoolBuilder::new().num_threads(22).build().unwrap(); in workers_stop() localVariable
27 registry = thread_pool.install(|| { in workers_stop()
31 thread_pool.registry.clone() in workers_stop()
55 let thread_pool = ThreadPoolBuilder::new().num_threads(22).build().unwrap(); in sleeper_stop() localVariable
56 registry = thread_pool.registry.clone(); in sleeper_stop()
|
| /external/tensorflow/tensorflow/cc/client/ |
| D | client_session_test.cc | 121 thread::ThreadPool thread_pool(Env::Default(), "pool", 2); in TEST() local
122 thread_pool.Schedule([&session, a]() { in TEST()
128 thread_pool.Schedule([&session, b]() { in TEST()
161 thread::ThreadPool thread_pool(Env::Default(), "pool", 2); in TEST() local
162 thread_pool.Schedule([&session, a]() { in TEST()
169 thread_pool.Schedule([&session, b]() { in TEST()
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/ |
| D | BUILD.bazel | 148 ":thread_pool",
183 name = "thread_pool",
185 hdrs = ["internal/thread_pool.h"],
205 ":thread_pool",
227 ":thread_pool",
|
| /external/angle/third_party/abseil-cpp/absl/synchronization/ |
| D | BUILD.bazel | 150 ":thread_pool",
185 name = "thread_pool",
187 hdrs = ["internal/thread_pool.h"],
207 ":thread_pool",
229 ":thread_pool",
|
| /external/abseil-cpp/absl/synchronization/ |
| D | BUILD.bazel | 148 ":thread_pool",
183 name = "thread_pool",
185 hdrs = ["internal/thread_pool.h"],
205 ":thread_pool",
227 ":thread_pool",
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | bincount_op.cc | 56 ThreadPool* thread_pool = in Compute() local
58 const int64_t num_threads = thread_pool->NumThreads() + 1; in Compute()
64 thread_pool->ParallelForWithWorkerId( in Compute()
101 ThreadPool* thread_pool = in Compute() local
103 const int64_t num_threads = thread_pool->NumThreads() + 1; in Compute()
137 thread_pool->ParallelForWithWorkerId( in Compute()
175 ThreadPool* thread_pool = in Compute() local
177 thread_pool->ParallelForWithWorkerId( in Compute()
|
| D | sparse_matmul_op.cc | 796 const DeviceBase::CpuWorkerThreads* thread_pool,
818 const DeviceBase::CpuWorkerThreads* thread_pool);
826 int num_cols, const DeviceBase::CpuWorkerThreads* thread_pool,
835 const DeviceBase::CpuWorkerThreads* thread_pool, MatrixR* buffer);
944 const DeviceBase::CpuWorkerThreads* thread_pool,
1145 const DeviceBase::CpuWorkerThreads* thread_pool) { in CreateSparseSlices() argument
1185 thread_pool->workers->Schedule( in CreateSparseSlices()
1241 const DeviceBase::CpuWorkerThreads* thread_pool, MatrixR* buffer) { in ShuffleMatrix() argument
1246 int num_threads = std::min(thread_pool->num_threads, 8); in ShuffleMatrix()
1288 thread_pool->workers->Schedule([=]() { shuffle_work(start, end); }); in ShuffleMatrix()
[all …]
|
| /external/rust/crates/futures-executor/src/ |
| D | lib.rs | 64 mod thread_pool; module
71 pub use crate::thread_pool::{ThreadPool, ThreadPoolBuilder};
|
| /external/ruy/ruy/ |
| D | context.cc | 39 const ThreadPool& Context::thread_pool() const { return ctx().thread_pool(); } in thread_pool() function in ruy::Context
|
| /external/rust/crates/tokio/src/runtime/ |
| D | spawner.rs | 7 use crate::runtime::thread_pool;
14 ThreadPool(thread_pool::Spawner),
|
| /external/zstd/contrib/pzstd/utils/ |
| D | BUCK | 47 name='thread_pool',
72 ':thread_pool',
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | single_threaded_cpu_device.cc | 34 static thread::ThreadPool* thread_pool = in GraphRunnerThreadPool() local
36 return thread_pool; in GraphRunnerThreadPool()
|