Searched refs:submit (Results 1 - 25 of 31) sorted by relevance

12

/libcore/luni/src/main/java/java/util/concurrent/
H A DCompletionService.java12 * {@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 DExecutorService.java32 * <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 DAbstractExecutorService.java18 * 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 DExecutors.java600 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 DExecutorCompletionService.java33 * 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 DScheduledThreadPoolExecutor.java65 * {@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 DForkJoinPool.java95 * <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 DExecutorCompletionServiceTest.java69 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 DForkJoinPoolTest.java51 * 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 DAbstractExecutorServiceTest.java47 * 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 DCollection8Test.java95 f1 = pool.submit(checkElt);
96 f2 = pool.submit(addRemove);
H A DThreadPoolExecutorTest.java1045 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 DScheduledExecutorTest.java779 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 DScheduledExecutorSubclassTest.java830 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 DExecutorsTest.java293 Future future = executor.submit(sleeper);
H A DThreadPoolExecutorSubclassTest.java1428 * 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 DSupport_Exec.java87 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 DTestSSLSocketPair.java80 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 DSSLSocketTest.java350 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 DSSLEngineTest.java821 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 DSecureRandomTest.java82 ecs.submit(new Callable<Void>() {
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/
H A DOutputStreamTesterTest.java124 future = executor.submit(new Callable<byte[]>() {
H A DWriterTesterTest.java117 future = executor.submit(new Callable<char[]>() {
/libcore/luni/src/test/java/libcore/java/util/zip/
H A DDeflaterOutputStreamTest.java76 executor.submit(new Callable<Void>() {
/libcore/luni/src/test/java/libcore/java/security/
H A DMessageDigestTest.java262 es.submit(new Callable<Void>() {

Completed in 1134 milliseconds

12