Home
last modified time | relevance | path

Searched defs:executor (Results 1 – 25 of 151) sorted by relevance

1234567

/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
DMoreExecutorsDirectExecutorBenchmark.java42 @Override Executor executor() { in executor() method
47 @Override Executor executor() { in executor() method
51 abstract Executor executor(); in executor() method in MoreExecutorsDirectExecutorBenchmark.Impl
55 Executor executor; field in MoreExecutorsDirectExecutorBenchmark
96 final Executor executor = this.executor; in timeUncontendedExecute() local
105 final Executor executor = this.executor; in timeContendedExecute() local
DExecutionListBenchmark.java53 void add(Runnable runnable, Executor executor); in add()
64 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
82 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
100 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
DFuturesCombineBenchmark.java39 @Override <V> ListenableFuture<V> combine(final Callable<V> combiner, Executor executor, in combine()
54 }, executor); in combine() field in FuturesCombineBenchmark
/external/guava/guava/src/com/google/common/eventbus/
DAsyncEventBus.java35 private final Executor executor; field in AsyncEventBus
50 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus()
66 public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) { in AsyncEventBus()
79 public AsyncEventBus(Executor executor) { in AsyncEventBus()
/external/tensorflow/tensorflow/compiler/xla/service/
Dgeneric_transfer_manager.cc55 perftools::gputools::StreamExecutor* executor, in WriteSingleTupleIndexTable()
70 se::StreamExecutor* executor, const ShapedBuffer& device_buffer) { in TransferLiteralFromDevice()
101 se::StreamExecutor* executor, const Literal& literal, in TransferLiteralToDevice()
149 se::StreamExecutor* executor, const Literal& literal) { in TransferLiteralToInfeed()
154 perftools::gputools::StreamExecutor* executor, int64 size, in TransferBufferToInfeed()
160 perftools::gputools::StreamExecutor* executor, const Shape& literal_shape, in TransferLiteralFromOutfeed()
Dtransfer_manager.cc44 perftools::gputools::StreamExecutor* executor, const Literal& literal, in TransferArrayToDevice()
64 perftools::gputools::StreamExecutor* executor, const Shape& shape, in TransferArrayFromDevice()
115 perftools::gputools::StreamExecutor* executor, in WriteTupleIndexTables()
146 se::StreamExecutor* executor, const se::DeviceMemoryBase& source, in TransferBufferFromDevice()
165 se::StreamExecutor* executor, int64 size, const void* source, in TransferBufferToDevice()
/external/guava/guava/src/com/google/common/util/concurrent/
DExecutionList.java81 public void add(Runnable runnable, Executor executor) { in add()
154 private static void executeListener(Runnable runnable, Executor executor) { in executeListener()
168 final Executor executor; field in ExecutionList.RunnableExecutorPair
171 RunnableExecutorPair(Runnable runnable, Executor executor, RunnableExecutorPair next) { in RunnableExecutorPair()
DMoreExecutors.java85 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
108 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
147 public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
168 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
176 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
184 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
213 final ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
218 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
227 private static void useDaemonThreadFactory(ThreadPoolExecutor executor) { in useDaemonThreadFactory()
840 static Executor renamingDecorator(final Executor executor, final Supplier<String> nameSupplier) { in renamingDecorator()
DSerializingExecutor.java51 private final Executor executor; field in SerializingExecutor
76 public SerializingExecutor(Executor executor) { in SerializingExecutor()
DListenerCallQueue.java60 private final Executor executor; field in ListenerCallQueue
65 ListenerCallQueue(L listener, Executor executor) { in ListenerCallQueue()
DListenableFuture.java134 void addListener(Runnable listener, Executor executor); in addListener()
DSimpleTimeLimiter.java50 private final ExecutorService executor; field in SimpleTimeLimiter
66 public SimpleTimeLimiter(ExecutorService executor) { in SimpleTimeLimiter()
DFutures.java102 public void addListener(Runnable listener, Executor executor) { in addListener()
442 FutureFallback<? extends V> fallback, Executor executor) { in withFallback()
457 final Executor executor) { in FallbackFuture()
612 Executor executor) { in transform()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractExecutionThreadServiceTest.java158 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.WaitOnRunService
193 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnStartUpService
247 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnRunService
279 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnShutDown
296 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.TimeoutOnStartUp
344 private final ExecutorService executor = Executors.newSingleThreadExecutor(); field in AbstractExecutionThreadServiceTest.FakeService
375 @Override protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.FakeService
DMoreExecutorsTest.java91 final ListeningExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceInThreadExecution() local
137 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceInvokeAll() local
168 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceTermination() local
247 ExecutorService executor = newDirectExecutorService(); in testDirectExecutorService_shutdownNow() local
253 ExecutorService executor = newDirectExecutorService(); in testExecuteAfterShutdown() local
263 ListeningExecutorService executor = newDirectExecutorService(); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
534 ThreadPoolExecutor executor = new ThreadPoolExecutor( in testGetExitingExcutorService_executorSetToUseDaemonThreads() local
542 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExcutorService_executorDelegatesToOriginal() local
551 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExcutorService_shutdownHookRegistered() local
561 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); in testGetExitingScheduledExcutorService_executorSetToUseDaemonThreads() local
[all …]
DAbstractScheduledServiceTest.java51 final ScheduledExecutorService executor = new ScheduledThreadPoolExecutor(10) { field in AbstractScheduledServiceTest
70 @Override protected ScheduledExecutorService executor() { return executor; } in executor() method in AbstractScheduledServiceTest.NullService
152 final AtomicReference<ScheduledExecutorService> executor = Atomics.newReference(); in testDefaultExecutorIsShutdownWhenServiceIsStopped() local
175 final AtomicReference<ScheduledExecutorService> executor = Atomics.newReference(); in testDefaultExecutorIsShutdownWhenServiceFails() local
267 protected ScheduledExecutorService executor() { in executor() method in AbstractScheduledServiceTest.TestService
415 @Override protected ScheduledExecutorService executor() { in executor() method in AbstractScheduledServiceTest.SchedulerTest.TestAbstractScheduledCustomService
461 @Override protected ScheduledExecutorService executor() { in executor() method in TestFailingCustomScheduledService
/external/tensorflow/tensorflow/compiler/xla/service/gpu/
Dgpu_transfer_manager.cc49 Status GpuTransferManager::TransferLiteralToInfeed(se::StreamExecutor* executor, in TransferLiteralToInfeed()
92 Status GpuTransferManager::TransferBufferToInfeed(se::StreamExecutor* executor, in TransferBufferToInfeed()
101 se::StreamExecutor* executor, std::vector<gpu::InfeedBuffer*> buffers) { in EnqueueBuffersToInfeed()
126 se::StreamExecutor* executor, int64 size, const void* source) { in TransferBufferToInfeedInternal()
/external/guice/extensions/service/src/com/google/inject/service/
DAsyncService.java37 private final ExecutorService executor; field in AsyncService
41 public AsyncService(ExecutorService executor) { in AsyncService()
/external/tensorflow/tensorflow/compiler/xla/service/cpu/
Dcpu_transfer_manager.cc93 Status CpuTransferManager::TransferLiteralToInfeed(se::StreamExecutor* executor, in TransferLiteralToInfeed()
138 Status CpuTransferManager::TransferBufferToInfeed(se::StreamExecutor* executor, in TransferBufferToInfeed()
151 CpuTransferManager::TransferBufferToInfeedInternal(se::StreamExecutor* executor, in TransferBufferToInfeedInternal()
177 se::StreamExecutor* executor, const Shape& literal_shape, in TransferLiteralFromOutfeed()
244 perftools::gputools::StreamExecutor* executor, in TransferTupleBuffersFromOutfeed()
251 perftools::gputools::StreamExecutor* executor, void* destination, in TransferArrayBufferFromOutfeed()
258 perftools::gputools::StreamExecutor* executor, in TransferBuffersFromOutfeedInternal()
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/builder/
DTestComponentWithBuilder.java34 Builder executor(Executor executor); in executor() argument
/external/guice/extensions/service/test/com/google/inject/service/
DSingleServiceIntegrationTest.java22 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncServiceLifecycle() local
61 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncServiceBlockingLifecycle() local
/external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/
DTestingExecutorsTest.java56 ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); in testNoOpScheduledExecutorShutdown() local
65 ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); in testNoOpScheduledExecutorInvokeAll() local
/external/deqp/executor/
DxeBatchExecutor.cpp352 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueStateChanged() local
364 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueTestLogData() local
376 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueInfoLogData() local
388 BatchExecutor* executor = DE_NULL; in dispatchStateChanged() local
401 BatchExecutor* executor = DE_NULL; in dispatchTestLogData() local
412 BatchExecutor* executor = DE_NULL; in dispatchInfoLogData() local
/external/tensorflow/tensorflow/core/kernels/hexagon/
Dhexagon_remote_fused_graph_executor_build.cc23 std::unique_ptr<IRemoteFusedGraphExecutor>* executor) { in BuildRemoteFusedGraphExecutor()
/external/tensorflow/tensorflow/contrib/nccl/kernels/
Dnccl_manager.cc40 perftools::gputools::StreamExecutor* executor = nullptr; member
126 perftools::gputools::StreamExecutor* const executor = nullptr; member
232 auto* executor = collective->participants[i]->executor; in GetCommunicator() local
301 perftools::gputools::StreamExecutor* executor, in AddToAllReduce()
315 perftools::gputools::StreamExecutor* executor, int gpu_device_id, in AddBroadcastSend()
328 perftools::gputools::StreamExecutor* executor, int gpu_device_id, in AddBroadcastRecv()
340 perftools::gputools::StreamExecutor* executor, in AddReduceSend()
354 perftools::gputools::StreamExecutor* executor, in AddReduceRecv()

1234567