| /external/robolectric/robolectric/src/test/java/org/robolectric/android/util/concurrent/ |
| D | PausedExecutorServiceTest.java | 21 private PausedExecutorService executorService; field in PausedExecutorServiceTest
26 executorService = new PausedExecutorService(); in setUp()
32 executorService.execute( in executionRunsInBackgroundThread()
37 executorService.runAll(); in executionRunsInBackgroundThread()
43 executorService.execute(() -> executedTasksRecord.add("background event ran")); in runAll()
47 executorService.runAll(); in runAll()
53 executorService.execute(() -> executedTasksRecord.add("first")); in runAll_inOrder()
54 executorService.execute(() -> executedTasksRecord.add("second")); in runAll_inOrder()
57 executorService.runAll(); in runAll_inOrder()
63 executorService.execute(() -> executedTasksRecord.add("first")); in runNext()
[all …]
|
| D | RoboExecutorServiceTest.java | 23 private RoboExecutorService executorService; field in RoboExecutorServiceTest
30 executorService = new RoboExecutorService(); in setUp()
40 executorService.execute(runnable); in execute_shouldRunStuffOnBackgroundThread()
50 Future<String> future = executorService.submit(runnable, "foo"); in submitRunnable_shouldRunStuffOnBackgroundThread()
65 executorService.submit( in submitCallable_shouldRunStuffOnBackgroundThread()
83 assertThat(executorService.isShutdown()).isFalse(); in byDefault_IsNotShutdown()
88 assertThat(executorService.isTerminated()).isFalse(); in byDefault_IsNotTerminated()
93 executorService.execute(runnable); in whenShutdownBeforeSubmittedTasksAreExecuted_TaskIsNotInTranscript()
95 executorService.shutdown(); in whenShutdownBeforeSubmittedTasksAreExecuted_TaskIsNotInTranscript()
103 executorService.execute(runnable); in whenShutdownNow_ReturnedListContainsOneRunnable()
[all …]
|
| D | InlineExecutorServiceTest.java | 20 private InlineExecutorService executorService; field in InlineExecutorServiceTest
25 executorService = new InlineExecutorService(); in setUp()
31 executorService.execute( in executionRunsInBackgroundThread()
45 Future<String> future = executorService.submit(runnable, "foo"); in submit()
56 executorService.submit( in submitCallable()
69 assertThat(executorService.isShutdown()).isFalse(); in byDefault_IsNotShutdown()
74 assertThat(executorService.isTerminated()).isFalse(); in byDefault_IsNotTerminated()
79 executorService.shutdown(); in whenAwaitingTerminationAfterShutdown_TrueIsReturned()
81 assertThat(executorService.awaitTermination(0, TimeUnit.MILLISECONDS)).isTrue(); in whenAwaitingTerminationAfterShutdown_TrueIsReturned()
95 executorService.submit(throwingCallable); in exceptionsPropagated()
[all …]
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/ |
| D | FileTransformerConfiguration.java | 43 private final ExecutorService executorService; field in FileTransformerConfiguration
48 this.executorService = builder.executorService; in FileTransformerConfiguration()
71 public Optional<ExecutorService> executorService() { in executorService() method in FileTransformerConfiguration
72 return Optional.ofNullable(executorService); in executorService()
140 return Objects.equals(executorService, that.executorService); in equals()
147 result = 31 * result + (executorService != null ? executorService.hashCode() : 0); in hashCode()
211 Builder executorService(ExecutorService executorService); in executorService() method
217 private ExecutorService executorService; field in FileTransformerConfiguration.DefaultBuilder
225 this.executorService = fileTransformerConfiguration.executorService; in DefaultBuilder()
241 public Builder executorService(ExecutorService executorService) { in executorService() argument
[all …]
|
| /external/robolectric/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowRcsUceAdapterSTest.java | 43 private ExecutorService executorService; field in ShadowRcsUceAdapterSTest
53 executorService = Executors.newSingleThreadExecutor(); in setUp()
68 executorService, in setCapabilitiesForUri_requestCapabilities_overridesCapabilitiesForUri() local
70 executorService.shutdown(); in setCapabilitiesForUri_requestCapabilities_overridesCapabilitiesForUri()
71 executorService.awaitTermination(10, SECONDS); in setCapabilitiesForUri_requestCapabilities_overridesCapabilitiesForUri()
89 executorService, in setCapabilitiesForUri_requestCapabilities_doesNotOverrideCapabilitiesForOtherUri() local
91 executorService.shutdown(); in setCapabilitiesForUri_requestCapabilities_doesNotOverrideCapabilitiesForOtherUri()
92 executorService.awaitTermination(10, SECONDS); in setCapabilitiesForUri_requestCapabilities_doesNotOverrideCapabilitiesForOtherUri()
105 executorService, in setCapabilitiesFailureForUri_requestCapabilities_failsForUri() local
107 executorService.shutdown(); in setCapabilitiesFailureForUri_requestCapabilities_failsForUri()
[all …]
|
| D | ShadowUwbAdapterStateListenerTest.java | 54 PausedExecutorService executorService = new PausedExecutorService(); in testSetEnabledTrueTwice_callbackInvokedOnlyOnce() local
55 adapterStateListener.register(executorService, mockAdapterStateCallback); in testSetEnabledTrueTwice_callbackInvokedOnlyOnce()
58 executorService.runAll(); in testSetEnabledTrueTwice_callbackInvokedOnlyOnce()
60 executorService.runAll(); in testSetEnabledTrueTwice_callbackInvokedOnlyOnce()
95 PausedExecutorService executorService = new PausedExecutorService(); in testRegisterCallback() local
97 adapterStateListener.register(executorService, mockAdapterStateCallback); in testRegisterCallback()
98 executorService.runAll(); in testRegisterCallback()
106 executorService.runAll(); in testRegisterCallback()
116 executorService.runAll(); in testRegisterCallback()
124 executorService.runAll(); in testRegisterCallback()
[all …]
|
| /external/downloader/src/test/java/com/google/android/downloader/ |
| D | TestExecutorRule.java | 68 ExecutorService executorService = Executors.newSingleThreadExecutor(threadFactory); in newSingleThreadExecutor() local
69 executorServices.add(executorService); in newSingleThreadExecutor()
70 return executorService; in newSingleThreadExecutor()
81 ScheduledExecutorService executorService = in newSingleThreadScheduledExecutor() local
83 executorServices.add(executorService); in newSingleThreadScheduledExecutor()
84 return executorService; in newSingleThreadScheduledExecutor()
90 for (ExecutorService executorService : executorServices) { in after()
92 executorService.shutdown(); in after()
93 assertThat(executorService.awaitTermination(timeout.toMillis(), MILLISECONDS)).isTrue(); in after()
|
| D | PlatformUrlEngineTest.java | 44 private ListeningExecutorService executorService; field in PlatformUrlEngineTest
48 executorService = listeningDecorator(newSingleThreadExecutor()); in setUp()
51 temporaryFolder, new TestingExecutorService(executorService)); in setUp()
54 executorService, /* connectTimeoutMs= */ 1000, /* readTimeoutMs= */ 1000); in setUp()
60 executorService.shutdown(); in tearDown()
|
| /external/apache-commons-io/src/main/java/org/apache/commons/io/input/ |
| D | ReadAheadInputStream.java | 67 private ExecutorService executorService; field in ReadAheadInputStream.Builder
86 …ReadAheadInputStream(getInputStream(), getBufferSize(), executorService != null ? executorService … in get()
87 executorService == null); in get()
96 public Builder setExecutorService(final ExecutorService executorService) { in setExecutorService() argument
97 this.executorService = executorService; in setExecutorService()
174 private final ExecutorService executorService; field in ReadAheadInputStream
201 …inal InputStream inputStream, final int bufferSizeInBytes, final ExecutorService executorService) { in ReadAheadInputStream() argument
202 this(inputStream, bufferSizeInBytes, executorService, false); in ReadAheadInputStream()
213 …(final InputStream inputStream, final int bufferSizeInBytes, final ExecutorService executorService, in ReadAheadInputStream() argument
219 this.executorService = Objects.requireNonNull(executorService, "executorService"); in ReadAheadInputStream()
[all …]
|
| /external/grpc-grpc-java/api/src/test/java/io/grpc/ |
| D | SynchronizationContextTest.java | 236 MockScheduledExecutorService executorService = new MockScheduledExecutorService(); in schedule() local
238 syncContext.schedule(task1, 110, TimeUnit.NANOSECONDS, executorService); in schedule()
239 assertThat(executorService.delay) in schedule()
240 .isEqualTo(executorService.unit.convert(110, TimeUnit.NANOSECONDS)); in schedule()
244 executorService.command.run(); in schedule()
251 MockScheduledExecutorService executorService = new MockScheduledExecutorService(); in scheduleDueImmediately() local
252 ScheduledHandle handle = syncContext.schedule(task1, -1, TimeUnit.NANOSECONDS, executorService); in scheduleDueImmediately()
253 assertThat(executorService.delay) in scheduleDueImmediately()
254 .isEqualTo(executorService.unit.convert(-1, TimeUnit.NANOSECONDS)); in scheduleDueImmediately()
258 executorService.command.run(); in scheduleDueImmediately()
[all …]
|
| /external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/async/ |
| D | FileAsyncResponseTransformerTest.java | 236 .executorService(spyingExecutorService) in explicitExecutor_shouldUseExecutor()
278 private final ExecutorService executorService; field in FileAsyncResponseTransformerTest.SpyingExecutorService
281 private SpyingExecutorService(ExecutorService executorService) { in SpyingExecutorService() argument
282 this.executorService = executorService; in SpyingExecutorService()
291 executorService.shutdown(); in shutdown()
296 return executorService.shutdownNow(); in shutdownNow()
301 return executorService.isShutdown(); in isShutdown()
306 return executorService.isTerminated(); in isTerminated()
311 return executorService.awaitTermination(timeout, unit); in awaitTermination()
317 return executorService.submit(task); in submit()
[all …]
|
| /external/aws-sdk-java-v2/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/waiters/ |
| D | query-async-waiter-class.java | 50 private final ScheduledExecutorService executorService; field in DefaultQueryAsyncWaiter
60 if (builder.executorService == null) { in DefaultQueryAsyncWaiter()
61 this.executorService = Executors.newScheduledThreadPool(1, in DefaultQueryAsyncWaiter()
63 attributeMapBuilder.put(SCHEDULED_EXECUTOR_SERVICE_ATTRIBUTE, this.executorService); in DefaultQueryAsyncWaiter()
65 this.executorService = builder.executorService; in DefaultQueryAsyncWaiter()
71 … .scheduledExecutorService(executorService).build(); in DefaultQueryAsyncWaiter()
140 private ScheduledExecutorService executorService; field in DefaultQueryAsyncWaiter.DefaultBuilder
146 …ublic QueryAsyncWaiter.Builder scheduledExecutorService(ScheduledExecutorService executorService) { in scheduledExecutorService() argument
147 this.executorService = executorService; in scheduledExecutorService()
|
| /external/libtextclassifier/java/src/com/android/textclassifier/downloader/ |
| D | ModelDownloadWorker.java | 57 private final ListeningExecutorService executorService; field in ModelDownloadWorker
78 this.executorService = TextClassifierServiceExecutors.getDownloaderExecutor(); in ModelDownloadWorker()
79 this.downloader = new ModelDownloaderImpl(context, executorService); in ModelDownloadWorker()
95 ListeningExecutorService executorService, in ModelDownloadWorker() argument
103 this.executorService = executorService; in ModelDownloadWorker()
132 return FluentFuture.from(Futures.submitAsync(this::checkAndDownloadModels, executorService)) in startWork()
150 executorService) in startWork()
159 executorService); in startWork() argument
255 executorService); in checkAndDownloadModels()
305 executorService)
[all …]
|
| D | ModelDownloadManager.java | 72 private final ListeningExecutorService executorService; field in ModelDownloadManager
86 ListeningExecutorService executorService) { in ModelDownloadManager() argument
93 executorService); in ModelDownloadManager()
103 ListeningExecutorService executorService) { in ModelDownloadManager() argument
109 this.executorService = Preconditions.checkNotNull(executorService); in ModelDownloadManager()
142 DeviceConfig.NAMESPACE_TEXTCLASSIFIER, executorService, deviceConfigListener); in onTextClassifierServiceCreated()
276 executorService); in scheduleDownloadWork()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | Dispatcher.java | 41 private ExecutorService executorService; field in Dispatcher
52 public Dispatcher(ExecutorService executorService) { in Dispatcher() argument
53 this.executorService = executorService; in Dispatcher()
60 if (executorService == null) { in getExecutorService()
61 executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS, in getExecutorService()
64 return executorService; in getExecutorService()
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/ |
| D | Dispatcher.java | 43 private ExecutorService executorService; field in Dispatcher
54 public Dispatcher(ExecutorService executorService) { in Dispatcher() argument
55 this.executorService = executorService; in Dispatcher()
62 if (executorService == null) { in getExecutorService()
63 executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS, in getExecutorService()
66 return executorService; in getExecutorService()
|
| /external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/ |
| D | BlockingAsyncRequestResponseBodyTest.java | 84 ExecutorService executorService = Executors.newSingleThreadExecutor(); in blockingWithExecutor_inputStreamWithMark_shouldRetry() local
108 … (long) length).executor(executorService).maxReadLimit(length + 1))).join(); in blockingWithExecutor_inputStreamWithMark_shouldRetry()
115 executorService.shutdownNow(); in blockingWithExecutor_inputStreamWithMark_shouldRetry()
122 ExecutorService executorService = Executors.newSingleThreadExecutor(); in blockingWithExecutor_sendsRightValues() local
128 executorService)) in blockingWithExecutor_sendsRightValues()
136 executorService.shutdownNow(); in blockingWithExecutor_sendsRightValues()
142 ExecutorService executorService = Executors.newSingleThreadExecutor(); in blockingWithExecutor_canUnderUpload() local
148 executorService)) in blockingWithExecutor_canUnderUpload()
156 executorService.shutdownNow(); in blockingWithExecutor_canUnderUpload()
162 ExecutorService executorService = Executors.newSingleThreadExecutor(); in blockingWithExecutor_canUnderUploadOneByteAtATime() local
[all …]
|
| /external/okio/okio/src/jvmTest/kotlin/okio/ |
| D | ThrottlerTest.kt | 33 private val executorService = TestingExecutors.newExecutorService(threads) constant
43 executorService.shutdown() in teardown()
88 executorService.submit { in parallel()
101 executorService.submit { in parallelFastThenSlower()
116 executorService.submit { in parallelSlowThenFaster()
131 executorService.submit { in parallelIndividualThrottle()
147 executorService.submit { in parallelGroupAndIndividualThrottle()
|
| /external/robolectric/integration_tests/nativegraphics/src/test/java/org/robolectric/shadows/ |
| D | BitmapLoadingTest.java | 24 ExecutorService executorService = Executors.newFixedThreadPool(4); in bitmapLoading_backgroundThreads_doesNotRace() local
26 executorService.execute( in bitmapLoading_backgroundThreads_doesNotRace()
34 executorService.shutdown(); in bitmapLoading_backgroundThreads_doesNotRace()
35 executorService.awaitTermination(10, SECONDS); in bitmapLoading_backgroundThreads_doesNotRace()
|
| /external/zxing/zxingorg/src/main/java/com/google/zxing/web/ |
| D | TimeoutFilter.java | 47 private ExecutorService executorService; field in TimeoutFilter
53 executorService = Executors.newCachedThreadPool(); in init()
54 timeLimiter = SimpleTimeLimiter.create(executorService); in init()
87 if (executorService != null) { in destroy()
88 executorService.shutdownNow(); in destroy()
|
| /external/aws-sdk-java-v2/http-clients/apache-client/src/test/java/software/amazon/awssdk/http/apache/internal/conn/ |
| D | IdleConnectionReaperTest.java | 48 public ExecutorService executorService; field in IdleConnectionReaperTest
58 …idleConnectionReaper = new IdleConnectionReaper(connectionManagers, () -> executorService, SLEEP_P… in methodSetup()
64 verify(executorService).execute(any(Runnable.class)); in setsUpExecutorIfManagerNotPreviouslyRegistered()
72 verify(executorService).shutdownNow(); in shutsDownExecutorIfMapEmptied()
80 verify(executorService, times(0)).shutdownNow(); in doesNotShutDownExecutorIfNoManagerRemoved()
|
| /external/robolectric/sandbox/src/main/java/org/robolectric/internal/bytecode/ |
| D | Sandbox.java | 23 private final ExecutorService executorService; field in Sandbox
38 executorService = Executors.newSingleThreadExecutor(mainThreadFactory()); in Sandbox()
111 return executorService.isShutdown(); in isShutdown()
116 executorService.shutdown(); in shutdown()
119 executorService.awaitTermination(5, SECONDS); in shutdown()
131 Future<T> future = executorService.submit(callable); in runOnMainThread()
|
| /external/grpc-grpc-java/core/src/jmh/java/io/grpc/internal/ |
| D | SerializingExecutorBenchmark.java | 43 private ExecutorService executorService = Executors.newSingleThreadExecutor(); field in SerializingExecutorBenchmark
44 private Executor executor = new SerializingExecutor(executorService);
67 executorService.shutdownNow(); in tearDown()
68 if (!executorService.awaitTermination(1, TimeUnit.SECONDS)) { in tearDown()
|
| /external/apache-commons-io/src/test/java/org/apache/commons/io/output/ |
| D | QueueOutputStreamTest.java | 46 private static final ExecutorService executorService = Executors.newFixedThreadPool(5); field in QueueOutputStreamTest
50 executorService.shutdown(); in afterAll()
55 executorService.submit(() -> { in callInThrowAwayThread()
76 executorService.submit(() -> { in writeInterrupted()
82 executorService.submit(() -> { in writeInterrupted()
|
| /external/apache-commons-lang/src/main/java/org/apache/commons/lang3/concurrent/ |
| D | TimedSemaphore.java | 151 private final ScheduledExecutorService executorService; field in TimedSemaphore
219 executorService = service; in TimedSemaphore()
226 executorService = s; in TimedSemaphore()
408 return executorService; in getExecutorService()
|