OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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