/libcore/jsr166-tests/src/test/java/jsr166/ |
H A D | AbstractExecutorServiceTest.java | 43 ExecutorService e = new DirectExecutorService(); 61 ExecutorService e = new DirectExecutorService(); 71 ExecutorService e = new DirectExecutorService(); 81 ExecutorService e = new DirectExecutorService(); 93 ExecutorService e = new DirectExecutorService(); 114 ExecutorService e = new DirectExecutorService(); 132 ExecutorService e = new DirectExecutorService(); 153 ExecutorService e = new DirectExecutorService(); 164 ExecutorService e = new DirectExecutorService(); 176 final ExecutorService [all...] |
H A D | ExecutorsTest.java | 23 ExecutorService e = Executors.newCachedThreadPool(); 34 ExecutorService e = Executors.newCachedThreadPool(new SimpleThreadFactory()); 46 ExecutorService e = Executors.newCachedThreadPool(null); 55 ExecutorService e = Executors.newSingleThreadExecutor(); 66 ExecutorService e = Executors.newSingleThreadExecutor(new SimpleThreadFactory()); 78 ExecutorService e = Executors.newSingleThreadExecutor(null); 87 ExecutorService e = Executors.newSingleThreadExecutor(); 101 ExecutorService e = Executors.newFixedThreadPool(2); 112 ExecutorService e = Executors.newFixedThreadPool(2, new SimpleThreadFactory()); 124 ExecutorService [all...] |
H A D | ExecutorCompletionServiceTest.java | 16 import java.util.concurrent.ExecutorService; 44 ExecutorService e = Executors.newCachedThreadPool(); 54 ExecutorService e = Executors.newCachedThreadPool(); 70 ExecutorService e = Executors.newCachedThreadPool(); 86 ExecutorService e = Executors.newCachedThreadPool(); 102 ExecutorService e = Executors.newCachedThreadPool(); 118 ExecutorService e = Executors.newCachedThreadPool(); 143 ExecutorService e = Executors.newCachedThreadPool(); 167 ExecutorService e = new ThreadPoolExecutor( 199 ExecutorService [all...] |
H A D | ForkJoinPoolTest.java | 14 import java.util.concurrent.ExecutorService; 414 ExecutorService e = new ForkJoinPool(1); 436 ExecutorService e = new ForkJoinPool(1); 451 ExecutorService e = new ForkJoinPool(1); 466 ExecutorService e = new ForkJoinPool(1); 485 ExecutorService e = new ForkJoinPool(1); 506 ExecutorService e = new ForkJoinPool(1); 527 ExecutorService e = new ForkJoinPool(1); 548 ExecutorService e = new ForkJoinPool(1); 562 ExecutorService [all...] |
H A D | ScheduledExecutorTest.java | 748 ExecutorService e = new ScheduledThreadPoolExecutor(2); 762 ExecutorService e = new ScheduledThreadPoolExecutor(2); 776 ExecutorService e = new ScheduledThreadPoolExecutor(2); 790 ExecutorService e = new ScheduledThreadPoolExecutor(2); 804 ExecutorService e = new ScheduledThreadPoolExecutor(2); 819 ExecutorService e = new ScheduledThreadPoolExecutor(2); 837 ExecutorService e = new ScheduledThreadPoolExecutor(2); 854 ExecutorService e = new ScheduledThreadPoolExecutor(2); 870 ExecutorService e = new ScheduledThreadPoolExecutor(2); 884 ExecutorService [all...] |
H A D | ScheduledExecutorSubclassTest.java | 797 ExecutorService e = new CustomExecutor(2); 811 ExecutorService e = new CustomExecutor(2); 825 ExecutorService e = new CustomExecutor(2); 839 ExecutorService e = new CustomExecutor(2); 853 ExecutorService e = new CustomExecutor(2); 868 ExecutorService e = new CustomExecutor(2); 886 ExecutorService e = new CustomExecutor(2); 903 ExecutorService e = new CustomExecutor(2); 919 ExecutorService e = new CustomExecutor(2); 933 ExecutorService [all...] |
H A D | ThreadPoolExecutorSubclassTest.java | 1266 ExecutorService e = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10)); 1280 ExecutorService e = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10)); 1294 ExecutorService e = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10)); 1308 ExecutorService e = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10)); 1322 ExecutorService e = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10)); 1337 ExecutorService e = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10)); 1355 ExecutorService e = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10)); 1372 ExecutorService e = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10)); 1388 ExecutorService e = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10)); 1402 ExecutorService [all...] |
H A D | ThreadPoolExecutorTest.java | 1393 ExecutorService e = 1410 ExecutorService e = 1427 ExecutorService e = 1444 ExecutorService e = 1461 ExecutorService e = 1479 final ExecutorService e = 1500 ExecutorService e = 1520 ExecutorService e = 1539 ExecutorService e = 1556 ExecutorService [all...] |
H A D | SynchronousQueueTest.java | 21 import java.util.concurrent.ExecutorService; 457 ExecutorService executor = Executors.newFixedThreadPool(2); 485 ExecutorService executor = Executors.newFixedThreadPool(2);
|
H A D | PriorityBlockingQueueTest.java | 23 import java.util.concurrent.ExecutorService; 602 ExecutorService executor = Executors.newFixedThreadPool(2);
|
/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | ScheduledExecutorService.java | 10 * An {@link ExecutorService} that can schedule commands to run after a given 20 * {@link ExecutorService} {@code submit} methods are scheduled with 65 public interface ScheduledExecutorService extends ExecutorService {
|
H A D | Executors.java | 21 * ExecutorService}, {@link ScheduledExecutorService}, {@link 26 * <li> Methods that create and return an {@link ExecutorService} 30 * <li> Methods that create and return a "wrapped" ExecutorService, that 54 * until it is explicitly {@link ExecutorService#shutdown shutdown}. 60 public static ExecutorService newFixedThreadPool(int nThreads) { 82 public static ExecutorService newWorkStealingPool(int parallelism) { 97 public static ExecutorService newWorkStealingPool() { 114 * exist until it is explicitly {@link ExecutorService#shutdown 123 public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) { 143 public static ExecutorService newSingleThreadExecuto [all...] |
H A D | ExecutorService.java | 20 * <p>An {@code ExecutorService} can be shut down, which will cause 22 * shutting down an {@code ExecutorService}. The {@link #shutdown} 28 * unused {@code ExecutorService} should be shut down to allow 52 * private final ExecutorService pool; 79 * The following method shuts down an {@code ExecutorService} in two phases, 84 * void shutdownAndAwaitTermination(ExecutorService pool) { 104 * {@code ExecutorService} 112 public interface ExecutorService extends Executor { interface in inherits:Executor
|
H A D | AbstractExecutorService.java | 11 * Provides default implementations of {@link ExecutorService} 42 public abstract class AbstractExecutorService implements ExecutorService {
|
/libcore/luni/src/test/java/tests/security/ |
H A D | SecureRandomTest.java | 23 import java.util.concurrent.ExecutorService; 79 ExecutorService executor = Executors.newFixedThreadPool(threads);
|
/libcore/support/src/test/java/tests/support/ |
H A D | Support_Exec.java | 31 import java.util.concurrent.ExecutorService; 85 ExecutorService executorService = Executors.newFixedThreadPool(2); 125 ExecutorService executorService = Executors.newFixedThreadPool(2);
|
/libcore/support/src/test/java/libcore/javax/net/ssl/ |
H A D | TestSSLSocketPair.java | 21 import java.util.concurrent.ExecutorService; 79 ExecutorService executor = Executors.newFixedThreadPool(2);
|
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
H A D | OutputStreamTesterTest.java | 41 import java.util.concurrent.ExecutorService; 116 private ExecutorService executor;
|
H A D | WriterTesterTest.java | 40 import java.util.concurrent.ExecutorService; 109 private ExecutorService executor;
|
/libcore/luni/src/test/java/libcore/java/util/zip/ |
H A D | DeflaterOutputStreamTest.java | 30 import java.util.concurrent.ExecutorService; 72 ExecutorService executor = Executors.newSingleThreadExecutor();
|
/libcore/luni/src/test/java/libcore/javax/net/ssl/ |
H A D | SSLSocketTest.java | 39 import java.util.concurrent.ExecutorService; 319 ExecutorService executor = Executors.newSingleThreadExecutor(); 372 final ExecutorService executor = Executors.newSingleThreadExecutor(); 412 ExecutorService executor = Executors.newSingleThreadExecutor(); 442 ExecutorService executor = Executors.newSingleThreadExecutor(); 462 ExecutorService executor = Executors.newSingleThreadExecutor(); 584 ExecutorService executor = Executors.newSingleThreadExecutor(); 650 ExecutorService executor = Executors.newSingleThreadExecutor(); 704 ExecutorService executor = Executors.newSingleThreadExecutor(); 734 ExecutorService executo [all...] |
/libcore/luni/src/test/java/libcore/java/security/ |
H A D | MessageDigestTest.java | 29 import java.util.concurrent.ExecutorService; 250 ExecutorService es = Executors.newFixedThreadPool(THREAD_COUNT);
|
/libcore/luni/src/test/java/libcore/java/util/concurrent/ |
H A D | CopyOnWriteArrayListTest.java | 27 import java.util.concurrent.ExecutorService; 179 ExecutorService executor = Executors.newSingleThreadExecutor();
|
/libcore/luni/src/test/java/libcore/java/net/ |
H A D | SocketTest.java | 34 import java.util.concurrent.ExecutorService; 357 private ExecutorService executor;
|
/libcore/support/src/test/java/tests/http/ |
H A D | MockWebServer.java | 43 import java.util.concurrent.ExecutorService; 77 private ExecutorService executor;
|