Home
last modified time | relevance | path

Searched refs:ExecutorService (Results 1 – 25 of 122) sorted by relevance

12345

/external/guava/guava-tests/test/com/google/common/util/concurrent/
DMoreExecutorsTest.java66 import java.util.concurrent.ExecutorService;
137 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceInvokeAll()
168 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceTermination()
247 ExecutorService executor = newDirectExecutorService(); in testDirectExecutorService_shutdownNow()
253 ExecutorService executor = newDirectExecutorService(); in testExecuteAfterShutdown()
290 ExecutorService delegate = mock(ExecutorService.class); in testListeningDecorator_noWrapExecuteTask()
514 ExecutorService service = mock(ExecutorService.class); in testAddDelayedShutdownHook_success()
525 ExecutorService service = mock(ExecutorService.class); in testAddDelayedShutdownHook_interrupted()
633 ExecutorService service = Executors.newSingleThreadExecutor(); in testShutdownAndAwaitTermination_immediateShutdown()
639 ExecutorService service = mock(ExecutorService.class); in testShutdownAndAwaitTermination_immediateShutdownInternal()
[all …]
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/
DEngineJob.java14 import java.util.concurrent.ExecutorService;
32 private final ExecutorService diskCacheService;
33 private final ExecutorService sourceService;
50 …public EngineJob(Key key, ExecutorService diskCacheService, ExecutorService sourceService, boolean… in EngineJob()
55 …public EngineJob(Key key, ExecutorService diskCacheService, ExecutorService sourceService, boolean… in EngineJob()
DEngine.java23 import java.util.concurrent.ExecutorService;
56 public Engine(MemoryCache memoryCache, DiskCache diskCache, ExecutorService diskCacheService, in Engine()
57 ExecutorService sourceService) { in Engine()
62 …Engine(MemoryCache cache, DiskCache diskCache, ExecutorService diskCacheService, ExecutorService s… in Engine()
296 private final ExecutorService diskCacheService;
297 private final ExecutorService sourceService;
300 public EngineJobFactory(ExecutorService diskCacheService, ExecutorService sourceService, in EngineJobFactory()
/external/guava/guava/src/com/google/common/util/concurrent/
DMoreExecutors.java40 import java.util.concurrent.ExecutorService;
84 public static ExecutorService getExitingExecutorService( in getExitingExecutorService()
126 ExecutorService service, long terminationTimeout, TimeUnit timeUnit) { in addDelayedShutdownHook()
147 public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
175 final ExecutorService getExitingExecutorService( in getExitingExecutorService()
178 ExecutorService service = Executors.unconfigurableExecutorService(executor); in getExitingExecutorService()
192 final ExecutorService service, final long terminationTimeout, final TimeUnit timeUnit) { in addDelayedShutdownHook()
213 final ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
480 ExecutorService delegate) { in listeningDecorator()
516 private final ExecutorService delegate;
[all …]
DWrappingExecutorService.java28 import java.util.concurrent.ExecutorService;
46 abstract class WrappingExecutorService implements ExecutorService {
47 private final ExecutorService delegate;
49 protected WrappingExecutorService(ExecutorService delegate) { in WrappingExecutorService()
DForwardingExecutorService.java25 import java.util.concurrent.ExecutorService;
40 implements ExecutorService {
45 protected abstract ExecutorService delegate(); in delegate()
DListeningExecutorService.java22 import java.util.concurrent.ExecutorService;
35 public interface ListeningExecutorService extends ExecutorService {
DSimpleTimeLimiter.java33 import java.util.concurrent.ExecutorService;
50 private final ExecutorService executor;
66 public SimpleTimeLimiter(ExecutorService executor) { in SimpleTimeLimiter()
/external/setupcompat/main/java/com/google/android/setupcompat/internal/
DExecutorProvider.java23 import java.util.concurrent.ExecutorService;
42 public static final ExecutorProvider<ExecutorService> setupCompatServiceInvoker =
46 public static final ExecutorProvider<ExecutorService> setupCompatExecutor =
81 public static ExecutorService createSizeBoundedExecutor(String threadName, int maxSize) { in createSizeBoundedExecutor()
DSetupCompatServiceInvoker.java27 import java.util.concurrent.ExecutorService;
103 private final ExecutorService loggingExecutor;
104 private final ExecutorService setupCompatExecutor;
/external/glide/library/src/main/java/com/bumptech/glide/
DGlideBuilder.java20 import java.util.concurrent.ExecutorService;
32 private ExecutorService sourceService;
33 private ExecutorService diskCacheService;
91 public GlideBuilder setResizeService(ExecutorService service) { in setResizeService()
111 public GlideBuilder setDiskCacheService(ExecutorService service) { in setDiskCacheService()
/external/vogar/src/vogar/util/
DThreads.java19 import java.util.concurrent.ExecutorService;
43 public static ExecutorService threadPerCpuExecutor(Log log, String name) { in threadPerCpuExecutor()
47 public static ExecutorService fixedThreadsExecutor(final Log log, String name, int count) { in fixedThreadsExecutor()
/external/guice/extensions/service/src/com/google/inject/service/
DAsyncService.java21 import java.util.concurrent.ExecutorService;
38 private final ExecutorService executor;
42 public AsyncService(ExecutorService executor) { in AsyncService()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/
DDispatcher.java25 import java.util.concurrent.ExecutorService;
43 private ExecutorService executorService;
54 public Dispatcher(ExecutorService executorService) { in Dispatcher()
61 public synchronized ExecutorService getExecutorService() { in getExecutorService()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
DDispatcher.java24 import java.util.concurrent.ExecutorService;
41 private ExecutorService executorService;
52 public Dispatcher(ExecutorService executorService) { in Dispatcher()
59 public synchronized ExecutorService getExecutorService() { in getExecutorService()
/external/guice/extensions/servlet/test/com/google/inject/servlet/
DTransferRequestIntegrationTest.java27 import java.util.concurrent.ExecutorService;
104 ExecutorService executor = Executors.newSingleThreadExecutor(); in testTransferNonHttpRequest()
144 ExecutorService executor = Executors.newSingleThreadExecutor(); in testTransferNonHttpRequest_closeable()
159 ExecutorService executor = Executors.newSingleThreadExecutor(); in testTransferNonHttpRequest_concurrentUseBlocks()
184 ExecutorService executor = Executors.newSingleThreadExecutor(); in testTransferNonHttpRequest_concurrentUseBlocks_closeable()
DContinuingRequestIntegrationTest.java36 import java.util.concurrent.ExecutorService;
103 private ExecutorService executor;
122 bind(ExecutorService.class).toInstance(executor); in testRequestContinuesInOtherThread()
164 bind(ExecutorService.class).toInstance(executor); in testRequestContinuationDiesInHttpRequestThread()
205 @Inject ExecutorService executorService;
/external/conscrypt/testing/src/main/java/org/conscrypt/tlswire/
DTlsTester.java14 import java.util.concurrent.ExecutorService;
29 public static ClientHello captureTlsHandshakeClientHello(ExecutorService executor, in captureTlsHandshakeClientHello()
50 public static TlsRecord captureTlsHandshakeFirstTlsRecord(ExecutorService executor, in captureTlsHandshakeFirstTlsRecord()
66 ExecutorService executor, final SSLSocketFactory sslSocketFactory) throws Exception { in captureTlsHandshakeFirstTransmittedChunkBytes()
/external/conscrypt/repackaged/testing/src/main/java/com/android/org/conscrypt/tlswire/
DTlsTester.java15 import java.util.concurrent.ExecutorService;
33 public static ClientHello captureTlsHandshakeClientHello(ExecutorService executor, in captureTlsHandshakeClientHello()
54 public static TlsRecord captureTlsHandshakeFirstTlsRecord(ExecutorService executor, in captureTlsHandshakeFirstTlsRecord()
70 ExecutorService executor, final SSLSocketFactory sslSocketFactory) throws Exception { in captureTlsHandshakeFirstTransmittedChunkBytes()
/external/apache-commons-compress/src/main/java/org/apache/commons/compress/archivers/zip/
DParallelScatterZipCreator.java31 import java.util.concurrent.ExecutorService;
56 private final ExecutorService es;
109 public ParallelScatterZipCreator(final ExecutorService executorService) { in ParallelScatterZipCreator()
120 public ParallelScatterZipCreator(final ExecutorService executorService, in ParallelScatterZipCreator()
/external/guice/extensions/service/test/com/google/inject/service/
DSingleServiceIntegrationTest.java5 import java.util.concurrent.ExecutorService;
18 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncServiceLifecycle()
60 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncServiceBlockingLifecycle()
/external/mockito/src/test/java/org/mockitousage/bugs/
DShouldNotDeadlockAnswerExecutionTest.java14 import java.util.concurrent.ExecutorService;
25 ExecutorService threads = Executors.newCachedThreadPool(); in failIfMockIsSharedBetweenThreads()
51 ExecutorService threads = Executors.newCachedThreadPool(); in successIfEveryThreadHasItsOwnMock()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpChannelBuilder.java49 import java.util.concurrent.ExecutorService;
125 private static final Resource<ExecutorService> SHARED_EXECUTOR =
126 new Resource<ExecutorService>() {
128 public ExecutorService create() {
133 public void close(ExecutorService executor) {
567 SharedResourceHolder.release(SHARED_EXECUTOR, (ExecutorService) executor); in close()
/external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/
DExecutorTestBase.java17 import java.util.concurrent.ExecutorService;
32 protected ExecutorService executor;
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
DAbstractListenableFutureTest.java27 import java.util.concurrent.ExecutorService;
167 ExecutorService exec = Executors.newCachedThreadPool(); in testListenersNotifiedOnError()
212 ExecutorService exec = Executors.newCachedThreadPool(); in testAllListenersCompleteSuccessfully()

12345