| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/ |
| DiskLruCache.java | 30 import java.util.concurrent.Executor;
167 private final Executor executor; field in class:DiskLruCache
188 Executor executor) {
197 this.executor = executor;
255 Executor executor = new ThreadPoolExecutor(0, 1, 60L, TimeUnit.SECONDS, local
258 return new DiskLruCache(fileSystem, directory, appVersion, valueCount, maxSize, executor);
[all...] |
| /packages/apps/DocumentsUI/src/com/android/documentsui/services/ |
| FileOperationService.java | 97 // The executor and job factory are visible for testing and non-final
100 @VisibleForTesting ExecutorService executor; field in class:FileOperationService
131 if (executor == null) {
132 executor = Executors.newFixedThreadPool(POOL_SIZE);
171 if (DEBUG) Log.d(TAG, "Shutting down executor.");
173 List<Runnable> unfinishedCopies = executor.shutdownNow();
180 Log.w(TAG, "Shutting down, but executor reports running jobs: " + unfinished);
183 executor = null;
282 return executor;
317 // so we can't guard executor shutdown. For this reason we mov
[all...] |
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| CompletableFuture.java | 66 * <li>All <em>async</em> methods without an explicit Executor
399 * Default executor -- ForkJoinPool.commonPool() unless it cannot
402 private static final Executor ASYNC_POOL = USE_COMMON_POOL ?
406 static final class ThreadPerTaskExecutor implements Executor {
411 * Null-checks user executor argument, and translates uses of
414 static Executor screenExecutor(Executor e) {
513 /** A Completion with a source, dependent, and executor. */
516 Executor executor; // executor to use (null if none field in class:CompletableFuture.UniCompletion
2679 final Executor executor; field in class:CompletableFuture.DelayedExecutor
2690 final Executor executor; field in class:CompletableFuture.TaskSubmitter
[all...] |
| /prebuilts/tools/common/m2/repository/io/netty/netty-transport/4.1.0.CR3/ |
| netty-transport-4.1.0.CR3.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-core/0.13.2/ |
| grpc-core-0.13.2.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-core/1.0.1/ |
| grpc-core-1.0.1.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-core/1.0.3/ |
| grpc-core-1.0.3.jar | |
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| NativeCryptoTest.java | 931 ExecutorService executor = Executors.newSingleThreadExecutor(); local
[all...] |
| /external/conscrypt/platform/src/test/java/org/conscrypt/ |
| NativeCryptoTest.java | 929 ExecutorService executor = Executors.newSingleThreadExecutor(); local
[all...] |
| /libcore/luni/src/test/java/libcore/javax/net/ssl/ |
| SSLSocketTest.java | 377 ExecutorService executor = Executors.newSingleThreadExecutor(); local
378 Future<Void> future = executor.submit(new Callable<Void>() {
399 executor.shutdown();
431 final ExecutorService executor = Executors.newSingleThreadExecutor(); local
436 final Future<byte[]> future1 = executor.submit(new SSLServerSessionIdCallable(server1));
449 final Future<byte[]> future2 = executor.submit(new SSLServerSessionIdCallable(server2));
461 executor.shutdown();
472 ExecutorService executor = Executors.newSingleThreadExecutor(); local
473 Future<Void> future = executor.submit(new Callable<Void>() {
484 executor.shutdown()
502 ExecutorService executor = Executors.newSingleThreadExecutor(); local
532 ExecutorService executor = Executors.newSingleThreadExecutor(); local
552 ExecutorService executor = Executors.newSingleThreadExecutor(); local
676 ExecutorService executor = Executors.newSingleThreadExecutor(); local
743 ExecutorService executor = Executors.newSingleThreadExecutor(); local
797 ExecutorService executor = Executors.newSingleThreadExecutor(); local
827 ExecutorService executor = Executors.newSingleThreadExecutor(); local
899 ExecutorService executor = Executors.newSingleThreadExecutor(); local
993 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1287 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1329 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1358 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1567 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1598 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1640 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1746 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1799 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1876 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1917 ExecutorService executor = Executors.newSingleThreadExecutor(new ThreadFactory() { local
2289 ExecutorService executor = Executors.newSingleThreadExecutor(); local
2324 ExecutorService executor = Executors.newFixedThreadPool(2); local
2364 ExecutorService executor = Executors.newFixedThreadPool(2); local
2409 ExecutorService executor = Executors.newFixedThreadPool(2); local
2460 ExecutorService executor = Executors.newFixedThreadPool(2); local
2513 ExecutorService executor = Executors.newFixedThreadPool(2); local
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/ |
| DiskLruCacheTest.java | 28 import java.util.concurrent.Executor;
60 private final TestExecutor executor = new TestExecutor(); field in class:DiskLruCacheTest
70 cache = new DiskLruCache(fileSystem, cacheDir, appVersion, 2, maxSize, executor);
509 assertEquals(1, executor.jobs.size());
660 while (executor.jobs.isEmpty()) {
667 while (executor.jobs.isEmpty()) {
671 executor.jobs.removeFirst().run();
682 while (executor.jobs.isEmpty()) {
692 while (executor.jobs.isEmpty()) {
[all...] |
| /prebuilts/tools/common/m2/repository/com/google/dagger/dagger-producers/2.0-beta/ |
| dagger-producers-2.0-beta.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-auth/1.0.1/ |
| grpc-auth-1.0.1.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-auth/1.0.3/ |
| grpc-auth-1.0.3.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-all/0.13.2/ |
| grpc-all-0.13.2.jar | |
| /prebuilts/eclipse/maven/apache-maven-3.2.1/lib/ |
| aether-connector-wagon-0.9.0.M2.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-stub/0.13.2/ |
| grpc-stub-0.13.2.jar | |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| CompletableFutureTest.java | 32 import java.util.concurrent.Executor;
550 // Used for explicit executor tests
551 static final class ThreadExecutor implements Executor {
720 EXECUTOR {
3502 ThreadExecutor executor = new ThreadExecutor(); local
3516 ThreadExecutor executor = new ThreadExecutor(); local
[all...] |
| /prebuilts/tools/common/m2/repository/io/netty/netty-handler/4.1.0.CR3/ |
| netty-handler-4.1.0.CR3.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-handler/4.1.3.Final/ |
| netty-handler-4.1.3.Final.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-netty/0.13.2/ |
| grpc-netty-0.13.2.jar | |
| /prebuilts/eclipse/mavenplugins/tycho/tycho-dependencies-m2repo/org/eclipse/tycho/tycho-bundles-external/0.20.0/eclipse/plugins/ |
| org.eclipse.equinox.concurrent_1.1.0.v20130327-1442.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-okhttp/0.13.2/ |
| grpc-okhttp-0.13.2.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-okhttp/1.0.1/ |
| grpc-okhttp-1.0.1.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-okhttp/1.0.3/ |
| grpc-okhttp-1.0.3.jar | |
