/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
D | MoreExecutorsDirectExecutorBenchmark.java | 42 @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
|
D | ExecutionListBenchmark.java | 53 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()
|
D | FuturesCombineBenchmark.java | 39 @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/ |
D | AsyncEventBus.java | 35 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/ |
D | generic_transfer_manager.cc | 55 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()
|
D | transfer_manager.cc | 44 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/ |
D | ExecutionList.java | 81 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()
|
D | MoreExecutors.java | 85 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()
|
D | SerializingExecutor.java | 51 private final Executor executor; field in SerializingExecutor 76 public SerializingExecutor(Executor executor) { in SerializingExecutor()
|
D | ListenerCallQueue.java | 60 private final Executor executor; field in ListenerCallQueue 65 ListenerCallQueue(L listener, Executor executor) { in ListenerCallQueue()
|
D | ListenableFuture.java | 134 void addListener(Runnable listener, Executor executor); in addListener()
|
D | SimpleTimeLimiter.java | 50 private final ExecutorService executor; field in SimpleTimeLimiter 66 public SimpleTimeLimiter(ExecutorService executor) { in SimpleTimeLimiter()
|
D | Futures.java | 102 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/ |
D | AbstractExecutionThreadServiceTest.java | 158 @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
|
D | MoreExecutorsTest.java | 91 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 …]
|
D | AbstractScheduledServiceTest.java | 51 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/ |
D | gpu_transfer_manager.cc | 49 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/ |
D | AsyncService.java | 37 private final ExecutorService executor; field in AsyncService 41 public AsyncService(ExecutorService executor) { in AsyncService()
|
/external/tensorflow/tensorflow/compiler/xla/service/cpu/ |
D | cpu_transfer_manager.cc | 93 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/ |
D | TestComponentWithBuilder.java | 34 Builder executor(Executor executor); in executor() argument
|
/external/guice/extensions/service/test/com/google/inject/service/ |
D | SingleServiceIntegrationTest.java | 22 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/ |
D | TestingExecutorsTest.java | 56 ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); in testNoOpScheduledExecutorShutdown() local 65 ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); in testNoOpScheduledExecutorInvokeAll() local
|
/external/deqp/executor/ |
D | xeBatchExecutor.cpp | 352 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/ |
D | hexagon_remote_fused_graph_executor_build.cc | 23 std::unique_ptr<IRemoteFusedGraphExecutor>* executor) { in BuildRemoteFusedGraphExecutor()
|
/external/tensorflow/tensorflow/contrib/nccl/kernels/ |
D | nccl_manager.cc | 40 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()
|