/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | CompletionService.java | 12 * {@code submit} tasks for execution. Consumers {@code take} 38 * @param task the task to submit 44 Future<V> submit(Callable<V> task); method in interface:CompletionService 51 * @param task the task to submit 60 Future<V> submit(Runnable task, V result); method in interface:CompletionService
|
H A D | ExecutorService.java | 32 * <p>Method {@code submit} extends base method {@link 183 * {@code result = exec.submit(aCallable).get();} 190 * @param task the task to submit 197 <T> Future<T> submit(Callable<T> task); method in interface:ExecutorService 204 * @param task the task to submit 212 <T> Future<T> submit(Runnable task, T result); method in interface:ExecutorService 219 * @param task the task to submit 225 Future<?> submit(Runnable task); method in interface:ExecutorService
|
H A D | AbstractExecutorService.java | 18 * execution methods. This class implements the {@code submit}, 22 * the implementation of {@code submit(Runnable)} creates an 86 public Future<?> submit(Runnable task) { method in class:AbstractExecutorService 97 public <T> Future<T> submit(Runnable task, T result) { method in class:AbstractExecutorService 108 public <T> Future<T> submit(Callable<T> task) { method in class:AbstractExecutorService 144 futures.add(ecs.submit(it.next())); 153 futures.add(ecs.submit(it.next()));
|
H A D | Executors.java | 600 public Future<?> submit(Runnable task) { method in class:Executors.DelegatedExecutorService 601 return e.submit(task); 603 public <T> Future<T> submit(Callable<T> task) { method in class:Executors.DelegatedExecutorService 604 return e.submit(task); 606 public <T> Future<T> submit(Runnable task, T result) { method in class:Executors.DelegatedExecutorService 607 return e.submit(task, result);
|
H A D | ExecutorCompletionService.java | 33 * ecs.submit(s); 57 * futures.add(ecs.submit(s)); 151 public Future<V> submit(Callable<V> task) { method in class:ExecutorCompletionService 158 public Future<V> submit(Runnable task, V result) { method in class:ExecutorCompletionService
|
H A D | ScheduledThreadPoolExecutor.java | 65 * {@link AbstractExecutorService#submit(Runnable) submit} 75 * {@code submit}, {@code schedule}, {@code scheduleAtFixedRate}, 127 * otherwise override submit methods to get this effect. These 634 public Future<?> submit(Runnable task) { method in class:ScheduledThreadPoolExecutor 642 public <T> Future<T> submit(Runnable task, T result) { method in class:ScheduledThreadPoolExecutor 650 public <T> Future<T> submit(Callable<T> task) { method in class:ScheduledThreadPoolExecutor
|
H A D | ForkJoinPool.java | 95 * <td> {@link #submit(ForkJoinTask)}</td> 584 * When external threads submit to the common pool, they can 2754 * @param task the task to submit 2761 public <T> ForkJoinTask<T> submit(ForkJoinTask<T> task) { method in class:ForkJoinPool 2770 public <T> ForkJoinTask<T> submit(Callable<T> task) { method in class:ForkJoinPool 2779 public <T> ForkJoinTask<T> submit(Runnable task, T result) { method in class:ForkJoinPool 2788 public ForkJoinTask<?> submit(Runnable task) { method in class:ForkJoinPool
|
/libcore/jsr166-tests/src/test/java/jsr166/ |
H A D | ExecutorCompletionServiceTest.java | 69 ecs.submit(c); 84 ecs.submit(r, Boolean.TRUE); 98 ecs.submit(c); 105 * Take returns the same future object returned by submit 112 Future f1 = ecs.submit(c); 127 ecs.submit(c); 150 ecs.submit(c); 179 Future f1 = ecs.submit(c); 180 assertTrue("submit must return MyCallableFuture", 183 assertSame("submit an [all...] |
H A D | ForkJoinPoolTest.java | 51 * 2. newTaskFor and adapters are tested in submit/invoke tests 232 Future<?> future = p.submit(task); 342 * Completed submit(ForkJoinTask) returns result 347 ForkJoinTask<Integer> f = p.submit(new FibTask(8)); 361 ForkJoinTask<Integer> f = p.submit(new FibTask(8)); 390 ForkJoinTask a = p.submit(awaiter(done)); 391 ForkJoinTask b = p.submit(awaiter(done)); 392 ForkJoinTask c = p.submit(awaiter(done)); 407 ForkJoinTask a = p.submit(awaiter(done)); 408 ForkJoinTask b = p.submit(awaite [all...] |
H A D | AbstractExecutorServiceTest.java | 47 * to test the submit methods only. 70 Future<?> future = e.submit(new CheckedRunnable() { 82 * Completed submit(callable) returns result 86 Future<String> future = e.submit(new StringTask()); 92 * Completed submit(runnable) returns successfully 96 Future<?> future = e.submit(new NoOpRunnable()); 102 * Completed submit(runnable, result) returns result 106 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); 118 Future future = e.submit(Executors.callable(new PrivilegedAction() { 139 Future future = e.submit(Executor [all...] |
H A D | Collection8Test.java | 95 f1 = pool.submit(checkElt); 96 f2 = pool.submit(addRemove);
|
H A D | ThreadPoolExecutorTest.java | 1045 p.submit(task).get(); 1081 * submit(runnable) throws RejectedExecutionException if saturated. 1095 p.submit(task); 1107 * submit(callable) throws RejectedExecutionException if saturated. 1121 p.submit(Executors.callable(task)); 1435 * completed submit of callable returns result 1443 Future<String> future = e.submit(new StringTask()); 1450 * completed submit of runnable returns successfully 1458 Future<?> future = e.submit(new NoOpRunnable()); 1465 * completed submit o [all...] |
H A D | ScheduledExecutorTest.java | 779 blockers.add(p.submit(task)); 830 * completed submit of callable returns result 835 Future<String> future = e.submit(new StringTask()); 842 * completed submit of runnable returns successfully 847 Future<?> future = e.submit(new NoOpRunnable()); 854 * completed submit of (runnable, result) returns result 859 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); 1255 p.submit(immediate);
|
H A D | ScheduledExecutorSubclassTest.java | 830 blockers.add(p.submit(task)); 881 * completed submit of callable returns result 886 Future<String> future = e.submit(new StringTask()); 893 * completed submit of runnable returns successfully 898 Future<?> future = e.submit(new NoOpRunnable()); 905 * completed submit of (runnable, result) returns result 910 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING);
|
H A D | ExecutorsTest.java | 293 Future future = executor.submit(sleeper);
|
H A D | ThreadPoolExecutorSubclassTest.java | 1428 * completed submit of callable returns result 1436 Future<String> future = e.submit(new StringTask()); 1443 * completed submit of runnable returns successfully 1451 Future<?> future = e.submit(new NoOpRunnable()); 1458 * completed submit of (runnable, result) returns result 1466 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); 2021 futures.add(e.submit(r));
|
/libcore/support/src/test/java/tests/support/ |
H A D | Support_Exec.java | 87 Future<String> errFuture = executorService.submit( 89 Future<String> outFuture = executorService.submit( 128 executorService.submit(streamToStringCallable(process.getErrorStream())); 130 executorService.submit(streamToStringCallable(process.getInputStream()));
|
/libcore/support/src/test/java/libcore/javax/net/ssl/ |
H A D | TestSSLSocketPair.java | 80 Future s = executor.submit(new Callable<Void>() { 89 Future c = executor.submit(new Callable<Void>() {
|
/libcore/luni/src/test/java/libcore/javax/net/ssl/ |
H A D | SSLSocketTest.java | 350 Future<Void> future = executor.submit(new Callable<Void>() { 408 final Future<byte[]> future1 = executor.submit(new SSLServerSessionIdCallable(server1)); 421 final Future<byte[]> future2 = executor.submit(new SSLServerSessionIdCallable(server2)); 445 Future<Void> future = executor.submit(new Callable<Void>() { 475 Future<Void> future = executor.submit(new Callable<Void>() { 505 Future<Void> future = executor.submit(new Callable<Void>() { 525 Future<Void> future = executor.submit(new Callable<Void>() { 648 Future<Void> future = executor.submit(new Callable<Void>() { 714 Future<IOException> future = executor.submit(new Callable<IOException>() { 768 Future<Void> future = executor.submit(ne [all...] |
H A D | SSLEngineTest.java | 821 Future<Void> client = executor.submit(new Callable<Void>() { 833 Future<Void> server = executor.submit(new Callable<Void>() {
|
/libcore/luni/src/test/java/tests/security/ |
H A D | SecureRandomTest.java | 82 ecs.submit(new Callable<Void>() {
|
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
H A D | OutputStreamTesterTest.java | 124 future = executor.submit(new Callable<byte[]>() {
|
H A D | WriterTesterTest.java | 117 future = executor.submit(new Callable<char[]>() {
|
/libcore/luni/src/test/java/libcore/java/util/zip/ |
H A D | DeflaterOutputStreamTest.java | 76 executor.submit(new Callable<Void>() {
|
/libcore/luni/src/test/java/libcore/java/security/ |
H A D | MessageDigestTest.java | 262 es.submit(new Callable<Void>() {
|