| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | MoreExecutorsDirectExecutorBenchmark.java | 42 Executor executor() { in executor() method
48 Executor executor() { in executor() method
53 abstract Executor executor(); in executor() method in MoreExecutorsDirectExecutorBenchmark.Impl
57 Executor executor; field in MoreExecutorsDirectExecutorBenchmark
106 final Executor executor = this.executor; in timeUncontendedExecute() local
116 final Executor executor = this.executor; in timeContendedExecute() local
|
| D | ExecutionListBenchmark.java | 50 void add(Runnable runnable, Executor executor); in add()
65 public void add(Runnable runnable, Executor executor) { in newExecutionList()
88 public void add(Runnable runnable, Executor executor) { in newExecutionList()
111 public void add(Runnable runnable, Executor executor) { in newExecutionList()
|
| /external/guava/android/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | MoreExecutorsDirectExecutorBenchmark.java | 42 Executor executor() { in executor() method
48 Executor executor() { in executor() method
53 abstract Executor executor(); in executor() method in MoreExecutorsDirectExecutorBenchmark.Impl
57 Executor executor; field in MoreExecutorsDirectExecutorBenchmark
106 final Executor executor = this.executor; in timeUncontendedExecute() local
116 final Executor executor = this.executor; in timeContendedExecute() local
|
| D | ExecutionListBenchmark.java | 50 void add(Runnable runnable, Executor executor); in add()
65 public void add(Runnable runnable, Executor executor) { in newExecutionList()
88 public void add(Runnable runnable, Executor executor) { in newExecutionList()
111 public void add(Runnable runnable, Executor executor) { in newExecutionList()
|
| /external/exoplayer/tree/extensions/cronet/src/main/java/com/google/android/exoplayer2/ext/cronet/ |
| D | CronetDataSourceFactory.java | 45 private final Executor executor; field in CronetDataSourceFactory
69 Executor executor, in CronetDataSourceFactory()
97 Executor executor, in CronetDataSourceFactory()
129 Executor executor, in CronetDataSourceFactory()
165 Executor executor, in CronetDataSourceFactory()
198 Executor executor, in CronetDataSourceFactory()
228 Executor executor, in CronetDataSourceFactory()
262 Executor executor, in CronetDataSourceFactory()
296 Executor executor, in CronetDataSourceFactory()
|
| /external/jacoco/org.jacoco.core.test/src/org/jacoco/core/test/validation/ |
| D | StatementExecutorTest.java | 44 StatementExecutor executor = new StatementExecutor(this, in should_prefix_arguments() local
55 StatementExecutor executor = new StatementExecutor(this); in should_call_method_with_int_argument() local
67 StatementExecutor executor = new StatementExecutor(this); in should_preserve_AssertionError() local
76 StatementExecutor executor = new StatementExecutor(this); in should_wrap_other_exceptions() local
85 StatementExecutor executor = new StatementExecutor(this); in should_throw_RuntimeException_when_method_cannot_be_invoked() local
|
| /external/dagger2/javatests/dagger/functional/producers/ |
| D | ExecutorModule.java | 31 private final Executor executor; field in ExecutorModule
37 public ExecutorModule(Executor executor) { in ExecutorModule()
43 Executor executor() { in executor() method in ExecutorModule
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | FluentFuture.java | 103 public final void addListener(Runnable listener, Executor executor) { in addListener()
168 Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { in catching()
232 Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) { in catchingAsync()
293 AsyncFunction<? super V, T> function, Executor executor) { in transformAsync()
329 public final <T> FluentFuture<T> transform(Function<? super V, T> function, Executor executor) { in transform()
370 public final void addCallback(FutureCallback<? super V> callback, Executor executor) { in addCallback()
|
| D | ExecutionList.java | 68 public void add(Runnable runnable, Executor executor) { in add()
139 private static void executeListener(Runnable runnable, Executor executor) { in executeListener()
155 final Executor executor; field in ExecutionList.RunnableExecutorPair
158 RunnableExecutorPair(Runnable runnable, Executor executor, RunnableExecutorPair next) { in RunnableExecutorPair()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | FluentFuture.java | 103 public final void addListener(Runnable listener, Executor executor) { in addListener()
168 Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { in catching()
232 Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) { in catchingAsync()
293 AsyncFunction<? super V, T> function, Executor executor) { in transformAsync()
329 public final <T> FluentFuture<T> transform(Function<? super V, T> function, Executor executor) { in transform()
370 public final void addCallback(FutureCallback<? super V> callback, Executor executor) { in addCallback()
|
| D | ExecutionList.java | 69 public void add(Runnable runnable, Executor executor) { in add()
140 private static void executeListener(Runnable runnable, Executor executor) { in executeListener()
156 final Executor executor; field in ExecutionList.RunnableExecutorPair
159 RunnableExecutorPair(Runnable runnable, Executor executor, RunnableExecutorPair next) { in RunnableExecutorPair()
|
| D | MoreExecutors.java | 84 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
103 public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
124 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
145 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
174 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
181 final ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
186 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
194 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
230 private static void useDaemonThreadFactory(ThreadPoolExecutor executor) { in useDaemonThreadFactory()
824 static Executor renamingDecorator(final Executor executor, final Supplier<String> nameSupplier) { in renamingDecorator()
|
| /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/android/guava/src/com/google/common/eventbus/ |
| D | AsyncEventBus.java | 38 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus()
51 public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) { in AsyncEventBus()
61 public AsyncEventBus(Executor executor) { in AsyncEventBus()
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | AsyncEventBus.java | 38 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus()
51 public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) { in AsyncEventBus()
61 public AsyncEventBus(Executor executor) { in AsyncEventBus()
|
| /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/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/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractExecutionThreadServiceTest.java | 168 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.WaitOnRunService
206 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnStartUpService
263 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnRunService
298 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnShutDown
316 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.TimeoutOnStartUp
392 private final ExecutorService executor = Executors.newSingleThreadExecutor(); field in AbstractExecutionThreadServiceTest.FakeService
427 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.FakeService
|
| D | MoreExecutorsTest.java | 92 final ListeningExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceInThreadExecution() local
140 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceInvokeAll() local
171 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceTermination() local
304 ExecutorService executor = newDirectExecutorService(); in testDirectExecutorService_shutdownNow() local
310 ExecutorService executor = newDirectExecutorService(); in testExecuteAfterShutdown() local
320 ListeningExecutorService executor = newDirectExecutorService(); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
585 ThreadPoolExecutor executor = in testGetExitingExecutorService_executorSetToUseDaemonThreads() local
593 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local
602 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_shutdownHookRegistered() local
612 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); in testGetExitingScheduledExecutorService_executorSetToUseDaemonThreads() local
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractExecutionThreadServiceTest.java | 168 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.WaitOnRunService
206 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnStartUpService
263 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnRunService
298 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnShutDown
316 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.TimeoutOnStartUp
392 private final ExecutorService executor = Executors.newSingleThreadExecutor(); field in AbstractExecutionThreadServiceTest.FakeService
427 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.FakeService
|
| D | MoreExecutorsTest.java | 92 final ListeningExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceInThreadExecution() local
140 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceInvokeAll() local
171 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceTermination() local
304 ExecutorService executor = newDirectExecutorService(); in testDirectExecutorService_shutdownNow() local
310 ExecutorService executor = newDirectExecutorService(); in testExecuteAfterShutdown() local
320 ListeningExecutorService executor = newDirectExecutorService(); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
585 ThreadPoolExecutor executor = in testGetExitingExecutorService_executorSetToUseDaemonThreads() local
593 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local
602 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_shutdownHookRegistered() local
612 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); in testGetExitingScheduledExecutorService_executorSetToUseDaemonThreads() local
[all …]
|
| /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()
|
| /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()
|