| /external/mesa3d/src/gallium/state_trackers/nine/ |
| D | threadpool.h | 33 struct threadpool { struct
53 struct threadpool *_mesa_threadpool_create(struct NineSwapChain9 *swapchain); argument
54 void _mesa_threadpool_destroy(struct NineSwapChain9 *swapchain, struct threadpool *pool);
55 struct threadpool_task *_mesa_threadpool_queue_task(struct threadpool *pool,
58 void _mesa_threadpool_wait_for_task(struct threadpool *pool,
|
| D | threadpool.c | 43 struct threadpool *pool = data; in threadpool_worker()
79 struct threadpool *
82 struct threadpool *pool = calloc(1, sizeof(*pool)); in _mesa_threadpool_create()
99 _mesa_threadpool_destroy(struct NineSwapChain9 *swapchain, struct threadpool *pool) in _mesa_threadpool_destroy()
132 _mesa_threadpool_queue_task(struct threadpool *pool, in _mesa_threadpool_queue_task()
174 _mesa_threadpool_wait_for_task(struct threadpool *pool, in _mesa_threadpool_wait_for_task()
|
| D | Makefile.sources | 71 threadpool.c \
72 threadpool.h \
|
| D | swapchain9.h | 73 struct threadpool *pool;
|
| D | meson.build | 54 'threadpool.c',
|
| /external/tensorflow/tensorflow/core/kernels/lookup_tables/ |
| D | generic_table_op_kernels.cc | 102 thread::ThreadPool* threadpool, Tensor* values) { in TensorLookup() argument
109 num_keys_per_thread, threadpool, values); in TensorLookup()
122 thread::ThreadPool* threadpool, Tensor* values) { in TensorLookupHelper() argument
129 value_span, threadpool); in TensorLookupHelper()
139 thread::ThreadPool* threadpool, Tensor* values) { in TensorLookupHelper() argument
152 value_span, threadpool); in TensorLookupHelper()
161 thread::ThreadPool* threadpool) { in MultithreadedTensorLookup() argument
173 threadpool->TransformRangeConcurrently( in MultithreadedTensorLookup()
|
| D | op_kernel_templates.h | 400 auto* threadpool = ctx->device()->tensorflow_cpu_worker_threads()->workers; in Compute() local
407 num_keys_per_thread, threadpool, out)); in Compute()
411 num_keys_per_thread, threadpool, out)); in Compute()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_state.h | 45 thread::ThreadPool* threadpool, int32 max_retries = 0)
47 call_opts, threadpool, /*fail_fast=*/false,
54 thread::ThreadPool* threadpool, bool fail_fast, int64 timeout_in_ms, in RPCState() argument
57 threadpool_(threadpool), in RPCState()
|
| /external/tensorflow/tensorflow/contrib/data/python/ops/ |
| D | threadpool.py | 21 from tensorflow.python.data.experimental.ops.threadpool import override_threadpool
22 from tensorflow.python.data.experimental.ops.threadpool import PrivateThreadPool
|
| D | BUILD | 196 name = "threadpool",
197 srcs = ["threadpool.py"],
200 "//tensorflow/python/data/experimental/ops:threadpool",
251 ":threadpool",
|
| /external/tensorflow/tensorflow/python/data/experimental/kernel_tests/ |
| D | override_threadpool_test.py | 27 from tensorflow.python.data.experimental.ops import threadpool
87 return threadpool.override_threadpool(
89 threadpool.PrivateThreadPool(
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | Http2Client.java | 86 private ListeningExecutorService threadpool; field in Http2Client
156 if (threadpool != null) { in shutdown()
157 threadpool.shutdownNow(); in shutdown()
274 threadpool = MoreExecutors.listeningDecorator(newFixedThreadPool(numThreads)); in maxStreams()
277 workerFutures.add(threadpool.submit(new MaxStreamsWorker(i, simpleRequest))); in maxStreams()
|
| D | StressTestClient.java | 122 private ListeningExecutorService threadpool; field in StressTestClient
225 threadpool = MoreExecutors.listeningDecorator(newFixedThreadPool(numThreads)); in runStressTest()
238 workerFutures.add(threadpool.submit(worker)); in runStressTest()
280 if (threadpool != null) { in shutdown()
281 threadpool.shutdownNow(); in shutdown()
|
| /external/tensorflow/tensorflow/core/api_def/base_api/ |
| D | api_def_ExperimentalThreadPoolHandle.pbtxt | 20 threadpool.
28 threadpool.
|
| D | api_def_ExperimentalPrivateThreadPoolDataset.pbtxt | 6 Identifies the number of threads to use for the private threadpool.
|
| D | api_def_MapDefun.pbtxt | 50 set a private threadpool on the dataset using `tf.data.Options`'s
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | quantization_utils_test.cc | 214 thread::ThreadPool threadpool(Env::Default(), "test", 2 /* num_threads */); in TestRequantizeManyInNewRangeEigenVsNonEigen() local
215 EigenThreadPoolWrapper wrapper(&threadpool); in TestRequantizeManyInNewRangeEigenVsNonEigen()
296 thread::ThreadPool threadpool(Env::Default(), "test", 4 /* num_threads */); in TimeRequantizeManyInNewRange() local
297 EigenThreadPoolWrapper wrapper(&threadpool); in TimeRequantizeManyInNewRange()
608 thread::ThreadPool threadpool(Env::Default(), "test", 2 /* num_threads */); in TestRequantizeManyInNewRange32To8BitUsingEigen() local
609 EigenThreadPoolWrapper wrapper(&threadpool); in TestRequantizeManyInNewRange32To8BitUsingEigen()
639 thread::ThreadPool threadpool(Env::Default(), "test", 2 /* num_threads */); in TestFloatToQuantizedInPlaceUsingEigen() local
640 EigenThreadPoolWrapper wrapper(&threadpool); in TestFloatToQuantizedInPlaceUsingEigen()
650 thread::ThreadPool threadpool(Env::Default(), "test", 2 /* num_threads */); in TestOverflowWithEigen() local
651 EigenThreadPoolWrapper wrapper(&threadpool); in TestOverflowWithEigen()
[all …]
|
| D | nn_ops_test.cc | 737 thread::ThreadPool threadpool(Env::Default(), "test", num_threads); in BM_LRNFloat() local
738 EigenThreadPoolWrapper wrapper(&threadpool); in BM_LRNFloat()
819 thread::ThreadPool threadpool(Env::Default(), "test", num_threads); in BM_AvgPool() local
820 EigenThreadPoolWrapper wrapper(&threadpool); in BM_AvgPool()
911 thread::ThreadPool threadpool(Env::Default(), "test", num_threads); in BM_AvgPoolBk() local
912 EigenThreadPoolWrapper wrapper(&threadpool); in BM_AvgPoolBk()
1015 thread::ThreadPool threadpool(Env::Default(), "test", num_threads); in BM_MaxPool() local
1016 EigenThreadPoolWrapper wrapper(&threadpool); in BM_MaxPool()
1195 thread::ThreadPool threadpool(Env::Default(), "test", num_threads); in BM_ReluFloat() local
1196 EigenThreadPoolWrapper wrapper(&threadpool); in BM_ReluFloat()
|
| D | quantized_batch_norm_op_test.cc | 220 thread::ThreadPool threadpool(Env::Default(), "test", 1); in TEST_F() local
221 EigenThreadPoolWrapper wrapper(&threadpool); in TEST_F()
|
| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| D | gpu_event_mgr.cc | 58 void InitThreadpoolLabels(thread::ThreadPool* threadpool) { in InitThreadpoolLabels() argument
65 const int num_threads = threadpool->NumThreads(); in InitThreadpoolLabels()
67 threadpool->Schedule([num_threads, &mu, &init_count, &all_initialized, in InitThreadpoolLabels()
|
| /external/autotest/site_utils/ |
| D | add_detected_host_labels.py | 124 threadpool = pool.ThreadPool()
131 successes = sum(threadpool.imap_unordered(
|
| /external/tensorflow/tensorflow/python/data/experimental/kernel_tests/optimization/ |
| D | optimize_dataset_test.py | 29 from tensorflow.python.data.experimental.ops import threadpool
184 dataset = threadpool.override_threadpool(
186 threadpool.PrivateThreadPool(
|
| /external/tensorflow/tensorflow/contrib/eager/python/ |
| D | datasets_test.py | 29 from tensorflow.python.data.experimental.ops import threadpool
220 dataset = threadpool.override_threadpool(
222 threadpool.PrivateThreadPool(
|
| /external/tensorflow/tensorflow/python/data/experimental/ops/ |
| D | BUILD | 382 name = "threadpool",
383 srcs = ["threadpool.py"],
472 ":threadpool",
|
| /external/eigen/unsupported/Eigen/CXX11/ |
| D | ThreadPool | 19 * This module provides 2 threadpool implementations
|