/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
D | MoreExecutorsTest.java | 66 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 …]
|
D | ListenerCallQueueTest.java | 26 import java.util.concurrent.ExecutorService; 76 ExecutorService service = Executors.newFixedThreadPool(4); in testAddAndExecute_multithreaded() 98 ExecutorService service = Executors.newFixedThreadPool(4); in testAddAndExecute_multithreaded_withThrowingRunnable()
|
D | ListenableFutureTester.java | 28 import java.util.concurrent.ExecutorService; 41 private final ExecutorService exec;
|
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/ |
D | EngineJob.java | 14 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()
|
D | Engine.java | 23 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/ |
D | MoreExecutors.java | 40 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 …]
|
D | WrappingExecutorService.java | 28 import java.util.concurrent.ExecutorService; 46 abstract class WrappingExecutorService implements ExecutorService { 47 private final ExecutorService delegate; 49 protected WrappingExecutorService(ExecutorService delegate) { in WrappingExecutorService()
|
D | ForwardingExecutorService.java | 25 import java.util.concurrent.ExecutorService; 40 implements ExecutorService { 45 protected abstract ExecutorService delegate(); in delegate()
|
D | ListeningExecutorService.java | 22 import java.util.concurrent.ExecutorService; 35 public interface ListeningExecutorService extends ExecutorService {
|
D | SimpleTimeLimiter.java | 33 import java.util.concurrent.ExecutorService; 50 private final ExecutorService executor; 66 public SimpleTimeLimiter(ExecutorService executor) { in SimpleTimeLimiter()
|
/external/glide/library/src/main/java/com/bumptech/glide/ |
D | GlideBuilder.java | 20 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/ |
D | Threads.java | 19 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/ |
D | AsyncService.java | 22 import java.util.concurrent.ExecutorService; 37 private final ExecutorService executor; 41 public AsyncService(ExecutorService executor) { in AsyncService()
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
D | Dispatcher.java | 24 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/service/test/com/google/inject/service/ |
D | SingleServiceIntegrationTest.java | 8 import java.util.concurrent.ExecutorService; 22 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncServiceLifecycle() 61 ExecutorService executor = Executors.newSingleThreadExecutor(); in testAsyncServiceBlockingLifecycle()
|
/external/guice/extensions/servlet/test/com/google/inject/servlet/ |
D | ContinuingRequestIntegrationTest.java | 40 import java.util.concurrent.ExecutorService; 101 private ExecutorService executor; 116 bind(ExecutorService.class).toInstance(executor); in testRequestContinuesInOtherThread() 157 bind(ExecutorService.class).toInstance(executor); in testRequestContinuationDiesInHttpRequestThread() 201 @Inject ExecutorService executorService;
|
D | TransferRequestIntegrationTest.java | 30 import java.util.concurrent.ExecutorService; 87 ExecutorService executor = Executors.newSingleThreadExecutor(); in testTransferNonHttpRequest() 95 ExecutorService executor = Executors.newSingleThreadExecutor(); in testTransferNonHttpRequest_concurrentUseBlocks()
|
/external/jetty/src/java/org/eclipse/jetty/util/thread/ |
D | ExecutorThreadPool.java | 23 import java.util.concurrent.ExecutorService; 44 private final ExecutorService _executor; 47 public ExecutorThreadPool(ExecutorService executor) in ExecutorThreadPool()
|
/external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/ |
D | ExecutorTestBase.java | 17 import java.util.concurrent.ExecutorService; 32 protected ExecutorService executor;
|
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
D | AbstractListenableFutureTest.java | 27 import java.util.concurrent.ExecutorService; 167 ExecutorService exec = Executors.newCachedThreadPool(); in testListenersNotifiedOnError() 212 ExecutorService exec = Executors.newCachedThreadPool(); in testAllListenersCompleteSuccessfully()
|
/external/testng/src/main/java/org/testng/internal/ |
D | PoolService.java | 10 import java.util.concurrent.ExecutorService; 22 private ExecutorService m_executor;
|
/external/vogar/src/vogar/target/ |
D | TestActivity.java | 28 import java.util.concurrent.ExecutorService; 66 ExecutorService executor = Threads.fixedThreadsExecutor(log, "testactivity", 1); in onCreate()
|
/external/jmdns/src/javax/jmdns/impl/ |
D | JmmDNSImpl.java | 20 import java.util.concurrent.ExecutorService; 56 private final ExecutorService _ListenerExecutor; 58 private final ExecutorService _jmDNSExecutor; 88 ExecutorService executor = Executors.newCachedThreadPool(); in close() 201 ExecutorService executor = Executors.newCachedThreadPool(); in getServiceInfos() 404 ExecutorService executor = Executors.newCachedThreadPool(); in list()
|
/external/junit/src/org/junit/experimental/ |
D | ParallelComputer.java | 6 import java.util.concurrent.ExecutorService; 40 private final ExecutorService fService= Executors in parallelize()
|
/external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/util/ |
D | RobolectricBackgroundExecutorService.java | 9 import java.util.concurrent.ExecutorService; 15 public class RobolectricBackgroundExecutorService implements ExecutorService {
|