| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/tracing/ |
| D | PropagatedFutures.java | 40 Executor executor) { in transformAsync()
46 ListenableFuture<I> input, Function<? super I, ? extends O> function, Executor executor) { in transform()
51 ListenableFuture<V> future, FutureCallback<? super V> callback, Executor executor) { in addCallback()
59 Executor executor) { in catching()
67 Executor executor) { in catchingAsync()
72 Callable<V> callable, Executor executor) { in submit()
76 public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) { in submit()
81 AsyncCallable<V> callable, Executor executor) { in submitAsync()
86 AsyncCallable<V> callable, long delay, TimeUnit timeUnit, ScheduledExecutorService executor) { in scheduleAsync()
121 AsyncCallable<C> combiner, Executor executor) { in callAsync()
[all …]
|
| D | PropagatedFluentFuture.java | 53 Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { in catching()
63 Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) { in catchingAsync()
83 AsyncFunction<? super V, T> function, Executor executor) { in transformAsync()
90 Function<? super V, T> function, Executor executor) { in transform()
99 public final void addCallback(FutureCallback<? super V> callback, Executor executor) { in addCallback()
100 PropagatedFutures.addCallback(delegate(), callback, executor); in addCallback() local
|
| /external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/extensions/cronet/src/main/java/com/google/android/exoplayer2/ext/cronet/ |
| D | CronetDataSourceFactory.java | 43 private final Executor executor; field in CronetDataSourceFactory
66 Executor executor, in CronetDataSourceFactory()
90 public CronetDataSourceFactory(CronetEngineWrapper cronetEngineWrapper, Executor executor) { in CronetDataSourceFactory()
110 CronetEngineWrapper cronetEngineWrapper, Executor executor, @Nullable String userAgent) { in CronetDataSourceFactory()
138 Executor executor, in CronetDataSourceFactory()
172 Executor executor, in CronetDataSourceFactory()
204 Executor executor, in CronetDataSourceFactory()
232 Executor executor, in CronetDataSourceFactory()
255 Executor executor, in CronetDataSourceFactory()
288 Executor executor, in CronetDataSourceFactory()
[all …]
|
| /external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/extensions/cronet/src/main/java/com/google/android/exoplayer2/ext/cronet/ |
| D | CronetDataSourceFactory.java | 39 private final Executor executor; field in CronetDataSourceFactory
62 Executor executor, in CronetDataSourceFactory()
86 public CronetDataSourceFactory(CronetEngineWrapper cronetEngineWrapper, Executor executor) { in CronetDataSourceFactory()
106 CronetEngineWrapper cronetEngineWrapper, Executor executor, @Nullable String userAgent) { in CronetDataSourceFactory()
134 Executor executor, in CronetDataSourceFactory()
168 Executor executor, in CronetDataSourceFactory()
200 Executor executor, in CronetDataSourceFactory()
228 Executor executor, in CronetDataSourceFactory()
251 Executor executor, in CronetDataSourceFactory()
284 Executor executor, in CronetDataSourceFactory()
[all …]
|
| /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
|
| /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
|
| /external/jacoco/org.jacoco.core.test/src/org/jacoco/core/test/validation/ |
| D | StatementExecutorTest.java | 41 StatementExecutor executor = new StatementExecutor(this, "Hello", in should_prefix_arguments() local
52 StatementExecutor executor = new StatementExecutor(this); in should_call_method_with_int_argument() local
62 StatementExecutor executor = new StatementExecutor(this); in should_preserve_AssertionError() local
73 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/cronet/base/task/ |
| D | single_thread_task_executor_unittest.cc | 518 SingleThreadTaskExecutor executor(GetParam()); in TEST_P() local
546 SingleThreadTaskExecutor executor(GetParam()); in TEST_P() local
566 SingleThreadTaskExecutor executor(GetParam()); in TEST_P() local
588 SingleThreadTaskExecutor executor(GetParam()); in TEST_P() local
615 SingleThreadTaskExecutor executor(GetParam()); in TEST_P() local
641 SingleThreadTaskExecutor executor(GetParam()); in TEST_P() local
668 SingleThreadTaskExecutor executor(GetParam()); in TEST_P() local
739 SingleThreadTaskExecutor executor(GetParam()); in TEST_P() local
763 SingleThreadTaskExecutor executor(GetParam()); in TEST_P() local
793 SingleThreadTaskExecutor executor(GetParam()); in TEST_P() local
[all …]
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | FluentFuture.java | 111 public final void addListener(Runnable listener, Executor executor) { in addListener()
188 Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { in catching()
253 Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) { in catchingAsync()
316 AsyncFunction<? super V, T> function, Executor executor) { in transformAsync()
354 Function<? super V, T> function, Executor executor) { in transform()
395 public final void addCallback(FutureCallback<? super V> callback, Executor executor) { in addCallback()
|
| D | ExecutionList.java | 70 public void add(Runnable runnable, Executor executor) { in add()
141 private static void executeListener(Runnable runnable, Executor executor) { in executeListener()
157 final Executor executor; field in ExecutionList.RunnableExecutorPair
161 Runnable runnable, Executor executor, @CheckForNull RunnableExecutorPair next) { in RunnableExecutorPair()
|
| D | Futures.java | 187 Callable<O> callable, Executor executor) { in submit()
200 public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) { in submit()
214 AsyncCallable<O> callable, Executor executor) { in submitAsync()
290 Executor executor) { in catching()
355 Executor executor) { in catchingAsync()
422 Executor executor) { in transformAsync()
458 ListenableFuture<I> input, Function<? super I, ? extends O> function, Executor executor) { in transform()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | FluentFuture.java | 113 public final void addListener(Runnable listener, Executor executor) { in addListener()
190 Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { in catching()
255 Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) { in catchingAsync()
335 AsyncFunction<? super V, T> function, Executor executor) { in transformAsync()
373 Function<? super V, T> function, Executor executor) { in transform()
414 public final void addCallback(FutureCallback<? super V> callback, Executor executor) { in addCallback()
|
| D | ExecutionList.java | 70 public void add(Runnable runnable, Executor executor) { in add()
141 private static void executeListener(Runnable runnable, Executor executor) { in executeListener()
157 final Executor executor; field in ExecutionList.RunnableExecutorPair
161 Runnable runnable, Executor executor, @CheckForNull RunnableExecutorPair next) { in RunnableExecutorPair()
|
| /external/tensorflow/tensorflow/compiler/xla/stream_executor/ |
| D | stream_test.cc | 32 std::unique_ptr<StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
38 std::unique_ptr<StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
45 std::unique_ptr<StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
66 std::unique_ptr<StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
97 std::unique_ptr<StreamExecutor> executor = NewStreamExecutor(); in TEST_F() local
136 std::unique_ptr<StreamExecutor> executor = NewStreamExecutor(); in TEST_F() 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/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| D | infeed_manager.cc | 32 InfeedManager::InfeedManager(se::StreamExecutor* executor) in InfeedManager()
49 se::StreamExecutor* executor = stream->parent(); in CopyBufferToDevice() local
57 Status InfeedManager::TransferLiteralToInfeed(se::StreamExecutor* executor, in TransferLiteralToInfeed()
90 InfeedManager* GetOrCreateInfeedManager(se::StreamExecutor* executor) { in GetOrCreateInfeedManager()
|
| /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/cronet/base/task/thread_pool/ |
| D | thread_group_impl.cc | 381 ScopedCommandsExecutor executor(this); in Start() local
419 ScopedCommandsExecutor executor(this); in UpdateSortKey() local
425 ScopedCommandsExecutor executor(this); in PushTaskSourceAndWakeUpWorkers() local
570 ScopedCommandsExecutor executor(outer_.get()); in GetWork() local
716 ScopedCommandsExecutor* executor, in CleanupLockRequired()
733 ScopedCommandsExecutor* executor, in OnWorkerBecomesIdleLockRequired()
807 ScopedCommandsExecutor executor(outer_.get()); in BlockingStarted() local
844 ScopedCommandsExecutor executor(outer_.get()); in BlockingTypeUpgraded() local
890 ScopedCommandsExecutor* executor) { in OnShutdownStartedLockRequired()
904 ScopedCommandsExecutor* executor, in CanGetWorkLockRequired()
[all …]
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | AsyncEventBus.java | 37 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus()
50 public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) { in AsyncEventBus()
60 public AsyncEventBus(Executor executor) { in AsyncEventBus()
|
| /external/guava/android/guava/src/com/google/common/eventbus/ |
| D | AsyncEventBus.java | 37 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus()
50 public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) { in AsyncEventBus()
60 public AsyncEventBus(Executor executor) { in AsyncEventBus()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ExecutorAsCoroutineDispatcherDelayTest.kt | 27 val executor = STPE() in <lambda>() constant
37 val executor = SES() in <lambda>() constant
|
| /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
303 ExecutorService executor = newDirectExecutorService(); in testDirectExecutorService_shutdownNow() local
309 ExecutorService executor = newDirectExecutorService(); in testExecuteAfterShutdown() local
319 ListeningExecutorService executor = newDirectExecutorService(); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
587 ThreadPoolExecutor executor = in testGetExitingExecutorService_executorSetToUseDaemonThreads() local
596 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local
606 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_shutdownHookRegistered() local
616 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
|
| /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
|