Home
last modified time | relevance | path

Searched refs:thread_pool (Results 1 – 25 of 60) sorted by relevance

123

/external/grpc-grpc/src/python/grpcio/grpc/beta/
Dimplementations.py144 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.py377 request_deserializers, response_serializers, thread_pool, argument
382 if thread_pool is None:
387 effective_thread_pool = thread_pool
/external/eigen/unsupported/test/
Dcxx11_tensor_notification.cpp37 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/
Dnotification_test.cc27 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()
Dblocking_counter_test.cc38 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.py523 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.py85 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.py63 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/
Dthreadpool.py66 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/
Dexample_partitioner.cc25 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()
Dexample_partitioner.h36 thread::ThreadPool* const thread_pool,
45 thread::ThreadPool* const thread_pool,
/external/tensorflow/tensorflow/core/kernels/
Dsparse_matmul_op.cc797 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 …]
Dbincount_op.cc55 ThreadPool* thread_pool = in Compute() local
57 const int64 num_threads = thread_pool->NumThreads() + 1; in Compute()
64 thread_pool->ParallelForWithWorkerId( in Compute()
Dmatrix_set_diag_op.cc131 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/
Dparallel_for.cc23 thread::ThreadPool* thread_pool, in ParallelFor() argument
38 thread_pool->Schedule([&do_work, &counter, start, end]() { in ParallelFor()
Dparallel_for.h26 thread::ThreadPool* thread_pool,
/external/tensorflow/tensorflow/cc/client/
Dclient_session_test.cc78 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/
Dsingle_threaded_cpu_device.cc34 static thread::ThreadPool* thread_pool = in GraphRunnerThreadPool() local
36 return thread_pool; in GraphRunnerThreadPool()
Dfunction.h59 thread::ThreadPool* thread_pool, const OptimizerOptions& optimizer_options,
69 thread::ThreadPool* thread_pool, const OptimizerOptions& optimizer_options,
/external/tensorflow/tensorflow/core/distributed_runtime/
Dmaster_test.cc281 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/
Dexample_proto_fast_parsing.h104 thread::ThreadPool* thread_pool, Result* result);
120 thread::ThreadPool* thread_pool, example::Result* context_result,
/external/tensorflow/tensorflow/core/grappler/
Dutils_test.cc182 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/
DMakefile.am32 thread_pool.cpp \
114 thread_pool.h \
/external/tensorflow/tensorflow/core/framework/
Ddevice_base.h260 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/
Ddebug_grpc_io_utils_test.cc36 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()

123