HomeSort by relevance Sort by last modified time
    Searched defs:executorService (Results 1 - 25 of 217) sorted by null

1 2 3 4 5 6 7 8 9

  /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/badexecutor/
BadExecutorTest.java 31 ListeningExecutorService executorService = MoreExecutors.newDirectExecutorService();
34 .executor(executorService)
37 executorService.shutdown();
  /libcore/support/src/test/java/tests/support/
Support_Exec.java 31 import java.util.concurrent.ExecutorService;
85 ExecutorService executorService = Executors.newFixedThreadPool(2);
87 Future<String> errFuture = executorService.submit(
89 Future<String> outFuture = executorService.submit(
113 executorService.shutdown();
  /tools/tradefederation/core/tests/src/com/android/tradefed/device/metric/
DeviceMetricDataFuncTest.java 38 import java.util.concurrent.ExecutorService;
93 ExecutorService executorService = Executors.newFixedThreadPool(threadCount);
95 // Invoke the tasks. The call to ExecutorService#invokeAll blocks until all the threads are
97 List<Future<HashMap<String, Metric>>> futures = executorService.invokeAll(tasks);
109 executorService.shutdownNow();
  /external/guava/guava-testlib/test/com/google/common/testing/
FakeTickerTest.java 27 import java.util.concurrent.ExecutorService;
150 ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads);
154 executorService.submit(new Callable<Void>() {
  /external/mockito/src/test/java/org/mockitousage/serialization/
ParallelSerializationTest.java 28 final ExecutorService executorService = Executors.newFixedThreadPool(threadingFactor);
41 futures.add(executorService.submit(new Callable<Object>() {
52 executorService.submit(new Callable<Object>() {
  /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/android/util/concurrent/
RoboExecutorServiceTest.java 21 private final RoboExecutorService executorService = new RoboExecutorService();
38 executorService.execute(runnable);
48 Future<String> future = executorService.submit(runnable, "foo");
62 Future<String> future = executorService.submit(new Callable<String>() {
82 assertThat(executorService.isShutdown()).isFalse();
87 assertThat(executorService.isTerminated()).isFalse();
92 executorService.execute(runnable);
94 executorService.shutdown();
102 executorService.execute(runnable);
104 List<Runnable> notExecutedRunnables = executorService.shutdownNow()
    [all...]
  /packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/utils/
ExecutorUtils.java 98 final ScheduledExecutorService executorService = getBackgroundExecutor(name);
99 executorService.shutdownNow();
101 executorService.awaitTermination(5, TimeUnit.SECONDS);
105 if (executorService == sExecutorServiceForTests) {
  /external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/util/
RobolectricBackgroundExecutorServiceTest.java 19 private RobolectricBackgroundExecutorService executorService;
24 executorService = new RobolectricBackgroundExecutorService();
37 executorService.execute(runnable);
47 Future<String> future = executorService.submit(runnable, "foo");
61 Future<String> future = executorService.submit(new Callable<String>() {
  /packages/apps/Dialer/java/com/android/dialer/commandline/impl/
Blocking.java 46 private final ListeningExecutorService executorService;
51 @BackgroundExecutor ListeningExecutorService executorService) {
53 this.executorService = executorService;
62 return executorService.submit(() -> doInBackground(args, asyncQueryHandler));
  /external/desugar/test/java/com/google/devtools/build/android/desugar/runtime/
ConcurrentWeakIdentityHashMapTest.java 28 import java.util.concurrent.ExecutorService;
145 ExecutorService executorService = Executors.newFixedThreadPool(workers.size());
146 workers.forEach(executorService::execute);
147 executorService.shutdown();
148 executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS); // wait for completion.
  /frameworks/layoutlib/bridge/tests/src/com/android/layoutlib/bridge/intensive/util/perf/
TimedStatement.java 145 ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);
147 executorService.scheduleAtFixedRate(() -> {
166 executorService.shutdownNow();
  /packages/apps/Dialer/java/com/android/dialer/phonelookup/blockednumber/
DialerBlockedNumberPhoneLookup.java 54 private final ListeningExecutorService executorService;
60 @BackgroundExecutor ListeningExecutorService executorService,
63 this.executorService = executorService;
72 return executorService.submit(
90 return executorService.submit(() -> queryNumbers(existingInfoMap.keySet()));
SystemBlockedNumberPhoneLookup.java 57 private final ListeningExecutorService executorService;
63 @BackgroundExecutor ListeningExecutorService executorService,
66 this.executorService = executorService;
75 return executorService.submit(
95 return executorService.submit(() -> queryNumbers(existingInfoMap.keySet()));
  /cts/hostsidetests/security/src/android/cts/security/
FileSystemPermissionTest.java 24 import java.util.concurrent.ExecutorService;
209 ExecutorService executorService = null;
211 executorService = Executors.newFixedThreadPool(2);
213 executorService.submit(new DrainCallable(p.getInputStream()));
215 executorService.submit(new DrainCallable(p.getErrorStream()));
227 if (executorService != null) {
228 executorService.shutdownNow();
  /external/guava/guava-tests/test/com/google/common/util/concurrent/
JdkFutureAdaptersTest.java 34 import java.util.concurrent.ExecutorService;
83 ExecutorService executorService = newCachedThreadPool(
87 ExecutorSpy spy = new ExecutorSpy(executorService);
98 listenableFuture.addListener(singleCallListener, executorService);
111 ExecutorService executorService = new ThreadPoolExecutor(
123 listenInPoolThread(abstractFuture, executorService);
138 executorService.shutdownNow();
  /libcore/luni/src/test/java/libcore/java/nio/channels/
AsynchronousChannelGroupTest.java 25 import java.util.concurrent.ExecutorService;
105 // ExecutorService hasn't yet terminated as the channel is still open.
138 ExecutorService executorService = Executors.newFixedThreadPool(5);
140 executorService, 1);
152 assertTrue(executorService.isTerminated());
AsynchronousFileChannelTest.java 41 import java.util.concurrent.ExecutorService;
647 ExecutorService executorService = Executors.newSingleThreadExecutor(new ThreadFactory() {
661 openOptions, executorService);
  /packages/apps/Dialer/java/com/android/voicemail/impl/transcribe/
TranscriptionService.java 41 import java.util.concurrent.ExecutorService;
53 private ExecutorService executorService;
131 ExecutorService executorService,
134 this.executorService = executorService;
187 if (executorService != null) {
188 executorService.shutdownNow();
189 executorService = null
    [all...]
  /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
Dispatcher.java 24 import java.util.concurrent.ExecutorService;
32 * <p>Each dispatcher uses an {@link ExecutorService} to run calls internally. If you
41 private ExecutorService executorService;
52 public Dispatcher(ExecutorService executorService) {
53 this.executorService = executorService;
59 public synchronized ExecutorService getExecutorService() {
60 if (executorService == null)
    [all...]
  /packages/apps/SettingsIntelligence/src/com/android/settings/intelligence/search/
SearchResultAggregator.java 18 import java.util.concurrent.ExecutorService;
52 final ExecutorService executorService = mFeatureProvider.getExecutorService();
58 executorService.execute(task);
  /art/test/708-jit-cache-churn/src/
JitCacheChurnTest.java 25 import java.util.concurrent.ExecutorService;
59 private final ExecutorService executorService;
63 this.executorService = new ThreadPoolExecutor(CONCURRENCY, CONCURRENCY, 5000,
68 this.executorService.shutdown();
82 List<Future<Integer>> results = executorService.invokeAll(tasks);
  /external/mockito/src/test/java/org/mockitoutil/
ClassLoaders.java 31 import java.util.concurrent.ExecutorService;
107 ExecutorService executorService = Executors.newSingleThreadExecutor(new ThreadFactory() {
116 Future<?> taskFuture = executorService.submit(new Runnable() {
130 executorService.shutdownNow();
  /external/guice/extensions/servlet/test/com/google/inject/servlet/
ContinuingRequestIntegrationTest.java 40 import java.util.concurrent.ExecutorService;
101 private ExecutorService executor;
116 bind(ExecutorService.class).toInstance(executor);
157 bind(ExecutorService.class).toInstance(executor);
201 @Inject ExecutorService executorService;
214 executorService.submit(task);
  /packages/apps/SettingsIntelligence/src/com/android/settings/intelligence/search/query/
DatabaseResultTask.java 45 import java.util.concurrent.ExecutorService;
133 ExecutorService executorService = mFeatureProvider.getExecutorService();
134 executorService.execute(rankerTask);
  /packages/apps/Dialer/java/com/android/dialer/app/voicemail/
VoicemailPlaybackLayout.java 241 public void onPlaybackStarted(int duration, ScheduledExecutorService executorService) {
250 positionUpdater = new PositionUpdater(duration, executorService);
383 private final ScheduledExecutorService executorService;
406 public PositionUpdater(int durationMs, ScheduledExecutorService executorService) {
408 this.executorService = executorService;
420 executorService.scheduleAtFixedRate(

Completed in 704 milliseconds

1 2 3 4 5 6 7 8 9