Home
last modified time | relevance | path

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

123

/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 …]
DListenerCallQueueTest.java26 import java.util.concurrent.ExecutorService;
76 ExecutorService service = Executors.newFixedThreadPool(4); in testAddAndExecute_multithreaded()
98 ExecutorService service = Executors.newFixedThreadPool(4); in testAddAndExecute_multithreaded_withThrowingRunnable()
DListenableFutureTester.java28 import java.util.concurrent.ExecutorService;
41 private final ExecutorService exec;
/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/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.java22 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/
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/service/test/com/google/inject/service/
DSingleServiceIntegrationTest.java8 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/
DContinuingRequestIntegrationTest.java40 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;
DTransferRequestIntegrationTest.java30 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/
DExecutorThreadPool.java23 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/
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()
/external/testng/src/main/java/org/testng/internal/
DPoolService.java10 import java.util.concurrent.ExecutorService;
22 private ExecutorService m_executor;
/external/vogar/src/vogar/target/
DTestActivity.java28 import java.util.concurrent.ExecutorService;
66 ExecutorService executor = Threads.fixedThreadsExecutor(log, "testactivity", 1); in onCreate()
/external/jmdns/src/javax/jmdns/impl/
DJmmDNSImpl.java20 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/
DParallelComputer.java6 import java.util.concurrent.ExecutorService;
40 private final ExecutorService fService= Executors in parallelize()
/external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/util/
DRobolectricBackgroundExecutorService.java9 import java.util.concurrent.ExecutorService;
15 public class RobolectricBackgroundExecutorService implements ExecutorService {

123