| /external/mesa3d/src/gallium/state_trackers/nine/ |
| threadpool.h | 33 struct threadpool { struct
53 struct threadpool *_mesa_threadpool_create(struct NineSwapChain9 *swapchain);
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,
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| Http2Client.java | 86 private ListeningExecutorService threadpool; field in class:Http2Client
156 if (threadpool != null) {
157 threadpool.shutdownNow();
274 threadpool = MoreExecutors.listeningDecorator(newFixedThreadPool(numThreads));
277 workerFutures.add(threadpool.submit(new MaxStreamsWorker(i, simpleRequest)));
|
| StressTestClient.java | 122 private ListeningExecutorService threadpool; field in class:StressTestClient
225 threadpool = MoreExecutors.listeningDecorator(newFixedThreadPool(numThreads));
238 workerFutures.add(threadpool.submit(worker));
280 if (threadpool != null) {
281 threadpool.shutdownNow();
284 log.log(Level.WARNING, "Error shutting down threadpool.", t);
|
| /external/tensorflow/tensorflow/core/kernels/lookup_tables/ |
| op_kernel_templates.h | 39 #include "tensorflow/core/lib/core/threadpool.h"
341 // table, keys, prefetch_lookahead, num_keys_per_thread, threadpool, out).
400 auto* threadpool = ctx->device()->tensorflow_cpu_worker_threads()->workers; variable
407 num_keys_per_thread, threadpool, out));
411 num_keys_per_thread, threadpool, out));
|
