Home
last modified time | relevance | path

Searched defs:executorService (Results 1 – 25 of 104) sorted by relevance

12345

/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/
DFileTransformerConfiguration.java43 private final ExecutorService executorService; field in FileTransformerConfiguration
71 public Optional<ExecutorService> executorService() { in executorService() method in FileTransformerConfiguration
211 Builder executorService(ExecutorService executorService); in executorService() method
217 private ExecutorService executorService; field in FileTransformerConfiguration.DefaultBuilder
241 public Builder executorService(ExecutorService executorService) { in executorService() argument
/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/
DBlockingAsyncRequestResponseBodyTest.java84 ExecutorService executorService = Executors.newSingleThreadExecutor(); in blockingWithExecutor_inputStreamWithMark_shouldRetry() local
122 ExecutorService executorService = Executors.newSingleThreadExecutor(); in blockingWithExecutor_sendsRightValues() local
142 ExecutorService executorService = Executors.newSingleThreadExecutor(); in blockingWithExecutor_canUnderUpload() local
162 ExecutorService executorService = Executors.newSingleThreadExecutor(); in blockingWithExecutor_canUnderUploadOneByteAtATime() local
182 ExecutorService executorService = Executors.newSingleThreadExecutor(); in blockingWithExecutor_propagatesReadFailures() local
199 ExecutorService executorService = Executors.newSingleThreadExecutor(); in blockingWithExecutor_propagates400Failures() local
215 …ExecutorService executorService = Executors.newSingleThreadExecutor(new ThreadFactoryBuilder().dae… in blockingWithExecutor_propagates500Failures() local
/external/apache-commons-io/src/main/java/org/apache/commons/io/input/
DReadAheadInputStream.java67 private ExecutorService executorService; field in ReadAheadInputStream.Builder
96 public Builder setExecutorService(final ExecutorService executorService) { in setExecutorService()
174 private final ExecutorService executorService; field in ReadAheadInputStream
201 …inal InputStream inputStream, final int bufferSizeInBytes, final ExecutorService executorService) { in ReadAheadInputStream()
213 …(final InputStream inputStream, final int bufferSizeInBytes, final ExecutorService executorService, in ReadAheadInputStream()
/external/robolectric/robolectric/src/test/java/org/robolectric/shadows/
DShadowRcsUceAdapterSTest.java42 private ExecutorService executorService; field in ShadowRcsUceAdapterSTest
65 rcsUceAdapter.requestCapabilities(ImmutableList.of(URI), executorService, verifierCallback); in setCapabilitiesForUri_requestCapabilities_overridesCapabilitiesForUri() local
84 ImmutableList.of(OTHER_URI), executorService, verifierCallback); in setCapabilitiesForUri_requestCapabilities_doesNotOverrideCapabilitiesForOtherUri() local
97 rcsUceAdapter.requestCapabilities(ImmutableList.of(URI), executorService, verifierCallback); in setCapabilitiesFailureForUri_requestCapabilities_failsForUri() local
115 ImmutableList.of(OTHER_URI), executorService, verifierCallback); in setCapabilitiesFailureForUri_requestCapabilities_doesNotFailForOtherUri() local
DShadowUwbAdapterStateListenerTest.java54 PausedExecutorService executorService = new PausedExecutorService(); in testSetEnabledTrueTwice_callbackInvokedOnlyOnce() local
95 PausedExecutorService executorService = new PausedExecutorService(); in testRegisterCallback() local
/external/grpc-grpc-java/api/src/test/java/io/grpc/
DSynchronizationContextTest.java236 MockScheduledExecutorService executorService = new MockScheduledExecutorService(); in schedule() local
251 MockScheduledExecutorService executorService = new MockScheduledExecutorService(); in scheduleDueImmediately() local
265 MockScheduledExecutorService executorService = new MockScheduledExecutorService(); in scheduleHandle_cancel() local
283 MockScheduledExecutorService executorService = new MockScheduledExecutorService(); in scheduledHandle_cancelRacesWithTimerExpiration() local
/external/downloader/src/test/java/com/google/android/downloader/
DTestExecutorRule.java68 ExecutorService executorService = Executors.newSingleThreadExecutor(threadFactory); in newSingleThreadExecutor() local
81 ScheduledExecutorService executorService = in newSingleThreadScheduledExecutor() local
/external/libtextclassifier/java/src/com/android/textclassifier/downloader/
DModelDownloadManager.java72 private final ListeningExecutorService executorService; field in ModelDownloadManager
86 ListeningExecutorService executorService) { in ModelDownloadManager()
103 ListeningExecutorService executorService) { in ModelDownloadManager()
DModelDownloadWorker.java57 private final ListeningExecutorService executorService; field in ModelDownloadWorker
95 ListeningExecutorService executorService, in ModelDownloadWorker()
159 executorService); in startWork() argument
/external/aws-sdk-java-v2/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/waiters/
Dquery-async-waiter-class.java50 private final ScheduledExecutorService executorService; field in DefaultQueryAsyncWaiter
140 private ScheduledExecutorService executorService; field in DefaultQueryAsyncWaiter.DefaultBuilder
146 …ublic QueryAsyncWaiter.Builder scheduledExecutorService(ScheduledExecutorService executorService) { in scheduledExecutorService()
/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/waiters/
DAsyncWaiterExecutor.java42 private final ScheduledExecutorService executorService; field in AsyncWaiterExecutor
47 ScheduledExecutorService executorService) { in AsyncWaiterExecutor()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
DDispatcher.java41 private ExecutorService executorService; field in Dispatcher
52 public Dispatcher(ExecutorService executorService) { in Dispatcher()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/
DDispatcher.java43 private ExecutorService executorService; field in Dispatcher
54 public Dispatcher(ExecutorService executorService) { in Dispatcher()
/external/apache-commons-compress/src/main/java/org/apache/commons/compress/archivers/zip/
DParallelScatterZipCreator.java109 public ParallelScatterZipCreator(final ExecutorService executorService) { in ParallelScatterZipCreator()
120 public ParallelScatterZipCreator(final ExecutorService executorService, in ParallelScatterZipCreator()
/external/robolectric/integration_tests/nativegraphics/src/test/java/org/robolectric/shadows/
DBitmapLoadingTest.java24 ExecutorService executorService = Executors.newFixedThreadPool(4); in bitmapLoading_backgroundThreads_doesNotRace() local
/external/robolectric/utils/src/test/java/org/robolectric/util/
DTempDirectoryTest.kt51 val executorService = Executors.newSingleThreadScheduledExecutor() in cleanupObsoleteDirectories() constant
/external/robolectric/robolectric/src/test/java/org/robolectric/android/internal/
DApplicationContentionTest.java27 private final ExecutorService executorService = Executors.newSingleThreadExecutor(); field in ApplicationContentionTest
/external/aws-sdk-java-v2/test/codegen-generated-classes-test/src/test/java/software/amazon/awssdk/services/waiters/
DWaiterResourceTest.java38 private ScheduledExecutorService executorService; field in WaiterResourceTest
/external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/extensions/cronet/src/androidTest/java/com/google/android/exoplayer2/ext/cronet/
DCronetDataSourceContractTest.java40 private final ExecutorService executorService = Executors.newSingleThreadExecutor(); field in CronetDataSourceContractTest
/external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/extensions/cronet/src/androidTest/java/com/google/android/exoplayer2/ext/cronet/
DCronetDataSourceContractTest.java40 private final ExecutorService executorService = Executors.newSingleThreadExecutor(); field in CronetDataSourceContractTest
/external/dagger2/javatests/dagger/functional/producers/badexecutor/
DBadExecutorTest.java47 ListeningExecutorService executorService = MoreExecutors.newDirectExecutorService(); in setUpComponent() local
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DJdkFutureAdaptersTest.java104 ExecutorService executorService = in testListenInPoolThreadUsesGivenExecutor() local
129 ExecutorService executorService = in testListenInPoolThreadCustomExecutorInterrupted() local
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DJdkFutureAdaptersTest.java104 ExecutorService executorService = in testListenInPoolThreadUsesGivenExecutor() local
129 ExecutorService executorService = in testListenInPoolThreadCustomExecutorInterrupted() local
/external/robolectric/plugins/maven-dependency-resolver/src/main/java/org/robolectric/internal/dependency/
DMavenDependencyResolver.java42 private final ExecutorService executorService; field in MavenDependencyResolver
182 ExecutorService executorService) { in createMavenFetcher()
/external/zxing/zxingorg/src/main/java/com/google/zxing/web/
DTimeoutFilter.java47 private ExecutorService executorService; field in TimeoutFilter

12345