Home
last modified time | relevance | path

Searched defs:executor (Results 1 – 25 of 515) sorted by relevance

12345678910>>...21

/external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/extensions/cronet/src/main/java/com/google/android/exoplayer2/ext/cronet/
DCronetDataSourceFactory.java43 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/
DCronetDataSourceFactory.java39 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/
DMoreExecutorsDirectExecutorBenchmark.java42 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
DExecutionListBenchmark.java50 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/
DMoreExecutorsDirectExecutorBenchmark.java42 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/exoplayer/tree/extensions/cronet/src/main/java/com/google/android/exoplayer2/ext/cronet/
DCronetDataSourceFactory.java45 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/
DStatementExecutorTest.java41 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/guava/android/guava/src/com/google/common/util/concurrent/
DFluentFuture.java112 public final void addListener(Runnable listener, Executor executor) { in addListener()
188 Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { in catching()
252 Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) { in catchingAsync()
313 AsyncFunction<? super V, T> function, Executor executor) { in transformAsync()
350 Function<? super V, T> function, Executor executor) { in transform()
391 public final void addCallback(FutureCallback<? super V> callback, Executor executor) { in addCallback()
DFutures.java184 Callable<O> callable, Executor executor) { in submit()
198 public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) { in submit()
213 AsyncCallable<O> callable, Executor executor) { in submitAsync()
289 Executor executor) { in catching()
354 Executor executor) { in catchingAsync()
421 Executor executor) { in transformAsync()
457 ListenableFuture<I> input, Function<? super I, ? extends O> function, Executor executor) { in transform()
DExecutionList.java70 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/guava/guava/src/com/google/common/util/concurrent/
DFluentFuture.java114 public final void addListener(Runnable listener, Executor executor) { in addListener()
190 Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { in catching()
254 Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) { in catchingAsync()
331 AsyncFunction<? super V, T> function, Executor executor) { in transformAsync()
368 Function<? super V, T> function, Executor executor) { in transform()
409 public final void addCallback(FutureCallback<? super V> callback, Executor executor) { in addCallback()
DExecutionList.java70 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()
DFutures.java186 Callable<O> callable, Executor executor) { in submit()
200 public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) { in submit()
215 AsyncCallable<O> callable, Executor executor) { in submitAsync()
304 Executor executor) { in catching()
369 Executor executor) { in catchingAsync()
454 Executor executor) { in transformAsync()
490 ListenableFuture<I> input, Function<? super I, ? extends O> function, Executor executor) { in transform()
/external/tensorflow/tensorflow/stream_executor/
Dstream_test.cc34 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/dagger2/javatests/dagger/functional/producers/
DExecutorModule.java31 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/
Dinfeed_manager.cc31 InfeedManager::InfeedManager(se::StreamExecutor* executor) in InfeedManager()
48 se::StreamExecutor* executor = stream->parent(); in CopyBufferToDevice() local
56 Status InfeedManager::TransferLiteralToInfeed(se::StreamExecutor* executor, in TransferLiteralToInfeed()
89 InfeedManager *GetOrCreateInfeedManager(se::StreamExecutor *executor) { in GetOrCreateInfeedManager()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DSendPingCommand.java27 private final Executor executor; field in SendPingCommand
29 SendPingCommand(PingCallback callback, Executor executor) { in SendPingCommand()
38 Executor executor() { in executor() method in SendPingCommand
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DExecutorAsCoroutineDispatcherDelayTest.kt27 val executor = STPE() in <lambda>() constant
37 val executor = SES() in <lambda>() constant
/external/guava/guava/src/com/google/common/eventbus/
DAsyncEventBus.java37 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/
DAsyncEventBus.java37 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-tests/test/com/google/common/util/concurrent/
DAbstractExecutionThreadServiceTest.java171 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.WaitOnRunService
210 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnStartUpService
269 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnRunService
305 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnShutDown
323 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.TimeoutOnStartUp
401 private final ExecutorService executor = Executors.newSingleThreadExecutor(); field in AbstractExecutionThreadServiceTest.FakeService
436 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.FakeService
DMoreExecutorsTest.java93 final ListeningExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceInThreadExecution() local
141 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceInvokeAll() local
173 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceTermination() local
306 ExecutorService executor = newDirectExecutorService(); in testDirectExecutorService_shutdownNow() local
312 ExecutorService executor = newDirectExecutorService(); in testExecuteAfterShutdown() local
322 ListeningExecutorService executor = newDirectExecutorService(); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
594 ThreadPoolExecutor executor = in testGetExitingExecutorService_executorSetToUseDaemonThreads() local
603 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local
613 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_shutdownHookRegistered() local
624 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); in testGetExitingScheduledExecutorService_executorSetToUseDaemonThreads() local
[all …]
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractExecutionThreadServiceTest.java171 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.WaitOnRunService
210 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnStartUpService
269 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnRunService
305 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.ThrowOnShutDown
323 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.TimeoutOnStartUp
401 private final ExecutorService executor = Executors.newSingleThreadExecutor(); field in AbstractExecutionThreadServiceTest.FakeService
436 protected Executor executor() { in executor() method in AbstractExecutionThreadServiceTest.FakeService
DMoreExecutorsTest.java93 final ListeningExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceInThreadExecution() local
141 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceInvokeAll() local
173 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceTermination() local
306 ExecutorService executor = newDirectExecutorService(); in testDirectExecutorService_shutdownNow() local
312 ExecutorService executor = newDirectExecutorService(); in testExecuteAfterShutdown() local
322 ListeningExecutorService executor = newDirectExecutorService(); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
594 ThreadPoolExecutor executor = in testGetExitingExecutorService_executorSetToUseDaemonThreads() local
603 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local
613 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_shutdownHookRegistered() local
624 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); in testGetExitingScheduledExecutorService_executorSetToUseDaemonThreads() local
[all …]
/external/jimfs/jimfs/src/test/java/com/google/common/jimfs/
DJimfsAsynchronousFileChannelTest.java61 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

12345678910>>...21