Home
last modified time | relevance | path

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

123

/external/guava/guava-tests/test/com/google/common/util/concurrent/
DMoreExecutorsTest.java65 import java.util.concurrent.ExecutorService;
137 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorInvokeAll()
168 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorServiceTermination()
247 ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutor_shutdownNow()
253 ExecutorService executor = MoreExecutors.sameThreadExecutor(); 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.java24 import java.util.concurrent.ExecutorService;
74 ExecutorService service = Executors.newFixedThreadPool(4); in testAddAndExecute_multithreaded()
96 ExecutorService service = Executors.newFixedThreadPool(4); in testAddAndExecute_multithreaded_withThrowingRunnable()
DListenableFutureTester.java28 import java.util.concurrent.ExecutorService;
41 private final ExecutorService exec;
DJdkFutureAdaptersTest.java34 import java.util.concurrent.ExecutorService;
83 ExecutorService executorService = newCachedThreadPool( in testListenInPoolThreadUsesGivenExecutor()
111 ExecutorService executorService = new ThreadPoolExecutor( in testListenInPoolThreadCustomExecutorInterrupted()
DListenableFutureTaskTest.java24 import java.util.concurrent.ExecutorService;
35 private ExecutorService exec;
DSerializingExecutorTest.java28 import java.util.concurrent.ExecutorService;
177 ExecutorService service = Executors.newSingleThreadExecutor(); in testTaskThrowsError()
/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()
414 ExecutorService delegate) { in listeningDecorator()
450 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/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/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/jmonkeyengine/engine/src/core/com/jme3/asset/
DThreadingManager.java36 import java.util.concurrent.ExecutorService;
48 protected final ExecutorService executor =
/external/vogar/src/vogar/target/
DTestActivity.java25 import java.util.concurrent.ExecutorService;
47 ExecutorService executor = Threads.fixedThreadsExecutor(log, "testactivity", 1); in onCreate()
/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/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/src/main/java/com/xtremelabs/robolectric/util/
DRobolectricBackgroundExecutorService.java9 import java.util.concurrent.ExecutorService;
15 public class RobolectricBackgroundExecutorService implements ExecutorService {
/external/junit/src/org/junit/internal/runners/
DMethodRoadie.java7 import java.util.concurrent.ExecutorService;
59 ExecutorService service= Executors.newSingleThreadExecutor(); in runWithTimeout()
/external/guava/guava-testlib/test/com/google/common/testing/
DFakeTickerTest.java27 import java.util.concurrent.ExecutorService;
150 ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads); in runConcurrentTest()

123