Home
last modified time | relevance | path

Searched refs:ExecutorService (Results 1 – 25 of 102) 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/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/r8/src/main/java/com/android/tools/r8/
DIncrementalDexingBenchmark.java9 import java.util.concurrent.ExecutorService;
14 public static void compile(ExecutorService executor) throws IOException, CompilationException { in compile()
29 ExecutorService executor = ThreadUtils.getExecutorService(threads); in main()
DD8.java25 import java.util.concurrent.ExecutorService;
83 public static D8Output run(D8Command command, ExecutorService executor) throws IOException { in run()
143 ExecutorService executor = ThreadUtils.getExecutorService(options); in runForTesting()
152 AndroidApp inputApp, InternalOptions options, ExecutorService executor) throws IOException { in runForTesting()
194 Timing timing, ExecutorService executor) in optimize()
DR8.java60 import java.util.concurrent.ExecutorService;
75 ExecutorService executorService, in writeApplication()
98 GraphLense graphLense, ExecutorService executorService) in optimize()
152 ExecutorService executor = ThreadUtils.getExecutorService(options); in disassemble()
176 ExecutorService executor = ThreadUtils.getExecutorService(options); in runForTesting()
187 ExecutorService executor) in runForTesting()
192 private CompilationResult run(AndroidApp inputApp, ExecutorService executorService) in run()
377 ExecutorService executorService = ThreadUtils.getExecutorService(command.getInternalOptions()); in run()
442 public static AndroidApp run(R8Command command, ExecutorService executor) in run()
/external/r8/src/main/java/com/android/tools/r8/utils/
DThreadUtils.java9 import java.util.concurrent.ExecutorService;
28 public static ExecutorService getExecutorService(int threads) { in getExecutorService()
36 public static ExecutorService getExecutorService(InternalOptions options) { in getExecutorService()
/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/r8/src/main/java/com/android/tools/r8/dex/
DApplicationReader.java45 import java.util.concurrent.ExecutorService;
64 ExecutorService executor = Executors.newSingleThreadExecutor(); in read()
72 public final DexApplication read(ExecutorService executorService) in read()
130 private void readProguardMap(DexApplication.Builder builder, ExecutorService executorService, in readProguardMap()
146 private void readMainDexList(DexApplication.Builder builder, ExecutorService executorService, in readMainDexList()
162 private final ExecutorService executorService;
174 ClassReader(ExecutorService executorService, List<Future<?>> futures, Closer closer) { in ClassReader()
/external/mockito/src/test/java/org/mockitousage/bugs/
DShouldNotDeadlockAnswerExecutionTest.java13 import java.util.concurrent.ExecutorService;
24 ExecutorService threads = Executors.newCachedThreadPool(); in failIfMockIsSharedBetweenThreads()
50 ExecutorService threads = Executors.newCachedThreadPool(); in successIfEveryThreadHasItsOwnMock()
/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/r8/src/main/java/com/android/tools/r8/bisect/
DBisect.java28 import java.util.concurrent.ExecutorService;
71 ExecutorService executor) in run()
103 ExecutorService executor = Executors.newWorkStealingPool(); in run()
172 private DexApplication readApp(File apk, ExecutorService executor) in readApp()
178 private static void writeApp(DexApplication app, Path output, ExecutorService executor) in writeApp()
/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/r8/src/test/examples/sync/
DSync.java7 import java.util.concurrent.ExecutorService;
94 public static void run(ExecutorService service, final Consumer<Integer> fn) in run()
116 ExecutorService service = Executors.newFixedThreadPool(THREADS); in main()
/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