| /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/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | SendPingCommand.java | 27 private final Executor executor; field in SendPingCommand
29 SendPingCommand(PingCallback callback, Executor executor) { in SendPingCommand()
38 Executor executor() { in executor() method in SendPingCommand
|
| /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/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()
|
| /external/tensorflow/tensorflow/stream_executor/ |
| D | stream_test.cc | 34 std::unique_ptr<StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
40 std::unique_ptr<StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
47 std::unique_ptr<StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
68 std::unique_ptr<StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
99 std::unique_ptr<StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
138 std::unique_ptr<StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
|
| /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/setupcompat/main/java/com/google/android/setupcompat/internal/ |
| D | ExecutorProvider.java | 51 private final T executor; field in ExecutorProvider
55 private ExecutorProvider(T executor) { in ExecutorProvider()
71 public void injectExecutor(T executor) { in injectExecutor()
|
| /external/libchrome/base/android/javatests/src/org/chromium/base/ |
| D | AsyncTaskTest.java | 62 Executor executor = new AsyncTask.ChromeThreadPoolExecutor(1, 1, 1, TimeUnit.SECONDS, in testChromeThreadPoolExecutorRunnables() local
87 Executor executor = new AsyncTask.ChromeThreadPoolExecutor(1, 1, 1, TimeUnit.SECONDS, in testChromeThreadPoolExecutorChromeAsyncTask() local
111 Executor executor = new AsyncTask.ChromeThreadPoolExecutor(1, 1, 1, TimeUnit.SECONDS, in testChromeThreadPoolExecutorOsAsyncTask() local
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ConnectivityStateManager.java | 45 void notifyWhenStateChanged(Runnable callback, Executor executor, ConnectivityState source) { in notifyWhenStateChanged()
92 final Executor executor; field in ConnectivityStateManager.Listener
94 Listener(Runnable callback, Executor executor) { in Listener()
|
| D | Http2Ping.java | 93 public void addCallback(final ClientTransport.PingCallback callback, Executor executor) { in addCallback()
170 public static void notifyFailed(PingCallback callback, Executor executor, Throwable cause) { in notifyFailed()
178 private static void doExecute(Executor executor, Runnable runnable) { in doExecute()
|
| /external/tensorflow/tensorflow/compiler/xla/service/cpu/ |
| D | cpu_transfer_manager.cc | 94 se::StreamExecutor* executor, const LiteralSlice& literal) { in TransferLiteralToInfeed()
139 Status CpuTransferManager::TransferBufferToInfeed(se::StreamExecutor* executor, in TransferBufferToInfeed()
153 CpuTransferManager::TransferBufferToInfeedInternal(se::StreamExecutor* executor, in TransferBufferToInfeedInternal()
178 se::StreamExecutor* executor, const Shape& literal_shape, in TransferLiteralFromOutfeed()
229 se::StreamExecutor* executor, in TransferTupleBuffersFromOutfeed()
236 se::StreamExecutor* executor, void* destination, int64 size_bytes) { in TransferArrayBufferFromOutfeed()
242 se::StreamExecutor* executor, in TransferBuffersFromOutfeedInternal()
|
| /external/guice/extensions/service/src/com/google/inject/service/ |
| D | AsyncService.java | 38 private final ExecutorService executor; field in AsyncService
42 public AsyncService(ExecutorService executor) { in AsyncService()
|
| /external/guice/extensions/service/test/com/google/inject/service/ |
| D | SingleServiceIntegrationTest.java | 18 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncServiceLifecycle() local
60 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncServiceBlockingLifecycle() local
|
| /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/conscrypt/repackaged/testing/src/main/java/com/android/org/conscrypt/tlswire/ |
| D | TlsTester.java | 33 public static ClientHello captureTlsHandshakeClientHello(ExecutorService executor, in captureTlsHandshakeClientHello()
54 public static TlsRecord captureTlsHandshakeFirstTlsRecord(ExecutorService executor, in captureTlsHandshakeFirstTlsRecord()
70 ExecutorService executor, final SSLSocketFactory sslSocketFactory) throws Exception { in captureTlsHandshakeFirstTransmittedChunkBytes()
|
| /external/conscrypt/testing/src/main/java/org/conscrypt/tlswire/ |
| D | TlsTester.java | 29 public static ClientHello captureTlsHandshakeClientHello(ExecutorService executor, in captureTlsHandshakeClientHello()
50 public static TlsRecord captureTlsHandshakeFirstTlsRecord(ExecutorService executor, in captureTlsHandshakeFirstTlsRecord()
66 ExecutorService executor, final SSLSocketFactory sslSocketFactory) throws Exception { in captureTlsHandshakeFirstTransmittedChunkBytes()
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| D | stream_pool_test.cc | 39 std::unique_ptr<se::StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
60 std::unique_ptr<se::StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
97 std::unique_ptr<se::StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
136 std::unique_ptr<se::StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ConnectivityStateManagerTest.java | 44 private final FakeClock executor = new FakeClock(); field in ConnectivityStateManagerTest
194 private Runnable newRecursiveCallback(final Executor executor) { in newRecursiveCallback()
|
| /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
|