| /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/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/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/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | FluentFuture.java | 107 public final void addListener(Runnable listener, Executor executor) { in addListener()
183 Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { in catching()
247 Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) { in catchingAsync()
308 AsyncFunction<? super V, T> function, Executor executor) { in transformAsync()
344 public final <T> FluentFuture<T> transform(Function<? super V, T> function, Executor executor) { in transform()
385 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 | Futures.java | 178 public static <O> ListenableFuture<O> submit(Callable<O> callable, Executor executor) { in submit()
192 public static ListenableFuture<Void> submit(Runnable runnable, Executor executor) { in submit()
205 public static <O> ListenableFuture<O> submitAsync(AsyncCallable<O> callable, Executor executor) { in submitAsync()
281 Executor executor) { in catching()
346 Executor executor) { in catchingAsync()
412 Executor executor) { in transformAsync()
447 ListenableFuture<I> input, Function<? super I, ? extends O> function, Executor executor) { in transform()
|
| /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 | 109 public final void addListener(Runnable listener, Executor executor) { in addListener()
185 Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { in catching()
249 Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) { in catchingAsync()
326 AsyncFunction<? super V, T> function, Executor executor) { in transformAsync()
362 public final <T> FluentFuture<T> transform(Function<? super V, T> function, Executor executor) { in transform()
403 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()
|
| D | Futures.java | 180 public static <O> ListenableFuture<O> submit(Callable<O> callable, Executor executor) { in submit()
194 public static ListenableFuture<Void> submit(Runnable runnable, Executor executor) { in submit()
207 public static <O> ListenableFuture<O> submitAsync(AsyncCallable<O> callable, Executor executor) { in submitAsync()
296 Executor executor) { in catching()
361 Executor executor) { in catchingAsync()
445 Executor executor) { in transformAsync()
480 ListenableFuture<I> input, Function<? super I, ? extends O> function, Executor executor) { in transform()
|
| /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/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 | 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/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/jimfs/jimfs/src/test/java/com/google/common/jimfs/ |
| D | JimfsAsynchronousFileChannelTest.java | 61 RegularFile file, ExecutorService executor, OpenOption... options) throws IOException { in channel()
77 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncChannel() local
101 ExecutorService executor = Executors.newSingleThreadExecutor(); in testClosedChannel() local
119 ExecutorService executor = Executors.newFixedThreadPool(4); in testAsyncClose_write() local
153 ExecutorService executor = Executors.newFixedThreadPool(2); in testAsyncClose_read() local
|
| /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/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/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/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()
179 se::StreamExecutor* executor, MutableBorrowingLiteral literal) { 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()
|