Searched refs:ExecutorService (Results 1 - 25 of 34) sorted by relevance

12

/libcore/jsr166-tests/src/test/java/jsr166/
H A DAbstractExecutorServiceTest.java43 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 DExecutorsTest.java23 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 DExecutorCompletionServiceTest.java16 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 DForkJoinPoolTest.java14 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 DScheduledExecutorTest.java748 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 DScheduledExecutorSubclassTest.java797 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 DThreadPoolExecutorSubclassTest.java1266 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 DThreadPoolExecutorTest.java1393 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 DSynchronousQueueTest.java21 import java.util.concurrent.ExecutorService;
457 ExecutorService executor = Executors.newFixedThreadPool(2);
485 ExecutorService executor = Executors.newFixedThreadPool(2);
H A DPriorityBlockingQueueTest.java23 import java.util.concurrent.ExecutorService;
602 ExecutorService executor = Executors.newFixedThreadPool(2);
/libcore/luni/src/main/java/java/util/concurrent/
H A DScheduledExecutorService.java10 * 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 DExecutors.java21 * 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 DExecutorService.java20 * <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 DAbstractExecutorService.java11 * Provides default implementations of {@link ExecutorService}
42 public abstract class AbstractExecutorService implements ExecutorService {
/libcore/luni/src/test/java/tests/security/
H A DSecureRandomTest.java23 import java.util.concurrent.ExecutorService;
79 ExecutorService executor = Executors.newFixedThreadPool(threads);
/libcore/support/src/test/java/tests/support/
H A DSupport_Exec.java31 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 DTestSSLSocketPair.java21 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 DOutputStreamTesterTest.java41 import java.util.concurrent.ExecutorService;
116 private ExecutorService executor;
H A DWriterTesterTest.java40 import java.util.concurrent.ExecutorService;
109 private ExecutorService executor;
/libcore/luni/src/test/java/libcore/java/util/zip/
H A DDeflaterOutputStreamTest.java30 import java.util.concurrent.ExecutorService;
72 ExecutorService executor = Executors.newSingleThreadExecutor();
/libcore/luni/src/test/java/libcore/javax/net/ssl/
H A DSSLSocketTest.java39 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 DMessageDigestTest.java29 import java.util.concurrent.ExecutorService;
250 ExecutorService es = Executors.newFixedThreadPool(THREAD_COUNT);
/libcore/luni/src/test/java/libcore/java/util/concurrent/
H A DCopyOnWriteArrayListTest.java27 import java.util.concurrent.ExecutorService;
179 ExecutorService executor = Executors.newSingleThreadExecutor();
/libcore/luni/src/test/java/libcore/java/net/
H A DSocketTest.java34 import java.util.concurrent.ExecutorService;
357 private ExecutorService executor;
/libcore/support/src/test/java/tests/http/
H A DMockWebServer.java43 import java.util.concurrent.ExecutorService;
77 private ExecutorService executor;

Completed in 1165 milliseconds

12