/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,
|
D | _server_adaptations.py | 377 request_deserializers, response_serializers, thread_pool, argument 382 if thread_pool is None: 387 effective_thread_pool = thread_pool
|
/external/eigen/unsupported/test/ |
D | cxx11_tensor_notification.cpp | 37 ThreadPool thread_pool(1); in test_notification_single() local 42 thread_pool.Schedule(func); in test_notification_single() 61 ThreadPool thread_pool(1); in test_notification_multiple() local 66 thread_pool.Schedule(func); in test_notification_multiple() 67 thread_pool.Schedule(func); in test_notification_multiple() 68 thread_pool.Schedule(func); in test_notification_multiple() 69 thread_pool.Schedule(func); in test_notification_multiple()
|
/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 62 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/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/tensorflow/tensorflow/python/data/experimental/ops/ |
D | threadpool.py | 66 def __init__(self, input_dataset, thread_pool): argument 68 self._thread_pool = thread_pool 78 def override_threadpool(dataset, thread_pool): argument 90 return _ThreadPoolDataset(dataset, thread_pool)
|
/external/tensorflow/tensorflow/contrib/boosted_trees/lib/learner/common/partitioners/ |
D | example_partitioner.cc | 25 const int desired_parallelism, thread::ThreadPool* const thread_pool, in UpdatePartitions() argument 52 thread_pool, partition_examples_subset); in UpdatePartitions() 58 const int desired_parallelism, thread::ThreadPool* const thread_pool, in PartitionExamples() argument 85 thread_pool, partition_examples_subset); in PartitionExamples()
|
D | example_partitioner.h | 36 thread::ThreadPool* const thread_pool, 45 thread::ThreadPool* const thread_pool,
|
/external/tensorflow/tensorflow/core/kernels/ |
D | sparse_matmul_op.cc | 797 const DeviceBase::CpuWorkerThreads* thread_pool, 819 const DeviceBase::CpuWorkerThreads* thread_pool); 827 int num_cols, const DeviceBase::CpuWorkerThreads* thread_pool, 836 const DeviceBase::CpuWorkerThreads* thread_pool, MatrixR* buffer); 945 const DeviceBase::CpuWorkerThreads* thread_pool, 1142 const DeviceBase::CpuWorkerThreads* thread_pool) { in CreateSparseSlices() argument 1182 thread_pool->workers->Schedule( in CreateSparseSlices() 1238 const DeviceBase::CpuWorkerThreads* thread_pool, MatrixR* buffer) { in ShuffleMatrix() argument 1241 int num_threads = std::min(thread_pool->num_threads, 16); in ShuffleMatrix() 1283 thread_pool->workers->Schedule([=]() { shuffle_work(start, end); }); in ShuffleMatrix() [all …]
|
D | bincount_op.cc | 55 ThreadPool* thread_pool = in Compute() local 57 const int64 num_threads = thread_pool->NumThreads() + 1; in Compute() 64 thread_pool->ParallelForWithWorkerId( in Compute()
|
D | matrix_set_diag_op.cc | 131 auto thread_pool = in Compute() local 134 thread_pool->ParallelFor(output.dimension(0), cost_per_batch, in Compute()
|
/external/tensorflow/tensorflow/contrib/boosted_trees/lib/utils/ |
D | parallel_for.cc | 23 thread::ThreadPool* thread_pool, in ParallelFor() argument 38 thread_pool->Schedule([&do_work, &counter, start, end]() { in ParallelFor()
|
D | parallel_for.h | 26 thread::ThreadPool* thread_pool,
|
/external/tensorflow/tensorflow/cc/client/ |
D | client_session_test.cc | 78 thread::ThreadPool thread_pool(Env::Default(), "pool", 2); in TEST() local 79 thread_pool.Schedule([&session, a]() { in TEST() 85 thread_pool.Schedule([&session, b]() { in TEST()
|
/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()
|
D | function.h | 59 thread::ThreadPool* thread_pool, const OptimizerOptions& optimizer_options, 69 thread::ThreadPool* thread_pool, const OptimizerOptions& optimizer_options,
|
/external/tensorflow/tensorflow/core/distributed_runtime/ |
D | master_test.cc | 281 thread::ThreadPool thread_pool(Env::Default(), "extend_pool", 100); in TEST_F() local 283 thread_pool.Schedule(extend_fn); in TEST_F() 353 thread::ThreadPool thread_pool(Env::Default(), "extend_pool", 3); in TEST_F() local 354 thread_pool.Schedule(get_a_fn); in TEST_F() 355 thread_pool.Schedule(get_a_and_b_fn); in TEST_F() 356 thread_pool.Schedule(extend_fn); in TEST_F()
|
/external/tensorflow/tensorflow/core/util/ |
D | example_proto_fast_parsing.h | 104 thread::ThreadPool* thread_pool, Result* result); 120 thread::ThreadPool* thread_pool, example::Result* context_result,
|
/external/tensorflow/tensorflow/core/grappler/ |
D | utils_test.cc | 182 std::unique_ptr<thread::ThreadPool> thread_pool( in TEST_F() local 189 1000 /* timeout_in_ms */, thread_pool.get())); in TEST_F() 195 1 /* timeout_in_ms */, thread_pool.get())); in TEST_F() 201 thread_pool.get())); in TEST_F() 204 thread_pool.reset(); in TEST_F()
|
/external/libxcam/xcore/ |
D | Makefile.am | 32 thread_pool.cpp \ 114 thread_pool.h \
|
/external/tensorflow/tensorflow/core/framework/ |
D | device_base.h | 260 void set_tensorflow_device_thread_pool(thread::ThreadPool* thread_pool) { in set_tensorflow_device_thread_pool() argument 261 device_thread_pool_ = thread_pool; in set_tensorflow_device_thread_pool()
|
/external/tensorflow/tensorflow/core/debug/ |
D | debug_grpc_io_utils_test.cc | 36 std::unique_ptr<thread::ThreadPool> thread_pool; member 52 server_data->thread_pool.reset( in SetUpInProcessServer() 54 server_data->thread_pool->Schedule( in SetUpInProcessServer() 63 server_data->thread_pool.reset(); in TearDownInProcessServer()
|