| /external/downloader/src/test/java/com/google/android/downloader/ |
| D | TestExecutorRule.java | 68 ExecutorService executorService = Executors.newSingleThreadExecutor(threadFactory); in newSingleThreadExecutor() local
81 ScheduledExecutorService executorService = in newSingleThreadScheduledExecutor() local
|
| D | CronetUrlEngineTest.java | 48 ExecutorService executorService = Executors.newSingleThreadExecutor(); in setUp() local
|
| D | PlatformUrlEngineTest.java | 44 private ListeningExecutorService executorService; field in PlatformUrlEngineTest
|
| D | MockWebServerUrlEngineTestHelper.java | 49 private final TestingExecutorService executorService; field in MockWebServerUrlEngineTestHelper
53 TemporaryFolder temporaryFolder, TestingExecutorService executorService) { in MockWebServerUrlEngineTestHelper()
|
| /external/apache-commons-compress/src/main/java/org/apache/commons/compress/archivers/zip/ |
| D | ParallelScatterZipCreator.java | 109 public ParallelScatterZipCreator(final ExecutorService executorService) { in ParallelScatterZipCreator()
120 public ParallelScatterZipCreator(final ExecutorService executorService, in ParallelScatterZipCreator()
|
| /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()
|
| /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()
|
| /external/dagger2/javatests/dagger/functional/producers/badexecutor/ |
| D | BadExecutorTest.java | 48 ListeningExecutorService executorService = MoreExecutors.newDirectExecutorService(); in setUpComponent() local
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | JdkFutureAdaptersTest.java | 104 ExecutorService executorService = in testListenInPoolThreadUsesGivenExecutor() local
129 ExecutorService executorService = in testListenInPoolThreadCustomExecutorInterrupted() local
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | JdkFutureAdaptersTest.java | 104 ExecutorService executorService = in testListenInPoolThreadUsesGivenExecutor() local
129 ExecutorService executorService = in testListenInPoolThreadCustomExecutorInterrupted() local
|
| /external/mockito/src/test/java/org/mockitousage/serialization/ |
| D | ParallelSerializationTest.java | 28 final ExecutorService executorService = Executors.newFixedThreadPool(threadingFactor); in single_mock_being_serialized_in_different_classloaders_by_multiple_threads() local
|
| /external/grpc-grpc-java/core/src/jmh/java/io/grpc/internal/ |
| D | SerializingExecutorBenchmark.java | 43 private ExecutorService executorService = Executors.newSingleThreadExecutor(); field in SerializingExecutorBenchmark
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ExecutorsTest.kt | 101 val executorService = Executors.newSingleThreadExecutor { r -> Thread(r, "TestExecutor") } in <lambda>() constant
|
| /external/exoplayer/tree/library/core/src/test/java/com/google/android/exoplayer2/ |
| D | PlayerMessageTest.java | 98 ExecutorService executorService = Executors.newSingleThreadExecutor(); in experimental_blockUntilDelivered_markAsProcessedWhileBlocked_succeeds() local
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/android/util/concurrent/ |
| D | RoboExecutorServiceTest.java | 21 private final RoboExecutorService executorService = new RoboExecutorService(); field in RoboExecutorServiceTest
|
| /external/okio/okio/src/jvmTest/kotlin/okio/ |
| D | ThrottlerTest.kt | 34 private val executorService = Executors.newFixedThreadPool(threads) constant in okio.ThrottlerTest
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Futures.java | 222 AsyncCallable<O> callable, Duration delay, ScheduledExecutorService executorService) { in scheduleAsync()
239 ScheduledExecutorService executorService) { in scheduleAsync()
|
| D | MoreExecutors.java | 730 ListeningExecutorService executorService, in invokeAnyImpl()
745 ListeningExecutorService executorService, in invokeAnyImpl()
825 ListeningExecutorService executorService, in submitAndAddQueueListener()
|
| /external/okio/okio/src/jvmTest/java/okio/ |
| D | WaitUntilNotifiedTest.java | 30 final ScheduledExecutorService executorService = Executors.newScheduledThreadPool(0); field in WaitUntilNotifiedTest
|
| D | PipeTest.java | 34 final ScheduledExecutorService executorService = Executors.newScheduledThreadPool(2); field in PipeTest
|
| /external/guava/android/guava-testlib/test/com/google/common/testing/ |
| D | FakeTickerTest.java | 150 ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads); in runConcurrentTest() local
|
| /external/guava/guava-testlib/test/com/google/common/testing/ |
| D | FakeTickerTest.java | 161 ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads); in runConcurrentTest() local
|
| /external/guice/extensions/servlet/test/com/google/inject/servlet/ |
| D | ContinuingRequestIntegrationTest.java | 205 @Inject ExecutorService executorService; field in ContinuingRequestIntegrationTest.ContinuingServlet
|
| /external/google-java-format/core/src/main/java/com/google/googlejavaformat/java/ |
| D | Main.java | 113 ExecutorService executorService = Executors.newFixedThreadPool(numThreads); in formatFiles() local
|
| /external/ukey2/src/main/javatest/com/google/security/cryptauth/lib/securegcm/ |
| D | Ukey2ShellCppWrapper.java | 65 private final ExecutorService executorService; field in Ukey2ShellCppWrapper
|