Home
last modified time | relevance | path

Searched refs:submit (Results 1 – 25 of 48) sorted by relevance

12

/libcore/ojluni/src/test/java/util/concurrent/tck/
DExecutorCompletionServiceTest.java90 cs.submit((Callable) null); in testSubmitNullCallable()
101 cs.submit((Runnable) null, Boolean.TRUE); in testSubmitNullRunnable()
112 cs.submit(new StringTask()); in testTake()
123 Future f1 = cs.submit(new StringTask()); in testTake2()
135 cs.submit(new StringTask()); in testPoll1()
155 cs.submit(new StringTask()); in testPoll2()
175 cs.submit(new Callable() { public String call() throws Exception { in testPollReturnsNull()
197 cs.submit(new StringTask()); in testTaskAssortment()
198 cs.submit(callableThrowing(ex)); in testTaskAssortment()
199 cs.submit(runnableThrowing(ex), null); in testTaskAssortment()
[all …]
DForkJoinPoolTest.java250 Future<?> future = p.submit(task); in testGetPoolSize()
365 ForkJoinTask<Integer> f = p.submit(new FibTask(8));
379 ForkJoinTask<Integer> f = p.submit(new FibTask(8));
408 ForkJoinTask a = p.submit(awaiter(done));
409 ForkJoinTask b = p.submit(awaiter(done));
410 ForkJoinTask c = p.submit(awaiter(done));
425 ForkJoinTask a = p.submit(awaiter(done));
426 ForkJoinTask b = p.submit(awaiter(done));
427 ForkJoinTask c = p.submit(awaiter(done));
448 Future<?> future = e.submit(new CheckedRunnable() { in testExecuteRunnable()
[all …]
DAbstractExecutorServiceTest.java93 Future<?> future = e.submit(new CheckedRunnable() { in testExecuteRunnable()
109 Future<String> future = e.submit(new StringTask()); in testSubmitCallable()
119 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable()
129 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2()
141 Future future = e.submit(Executors.callable(new PrivilegedAction() { in testSubmitPrivilegedAction()
162 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitPrivilegedExceptionAction()
180 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitFailedPrivilegedExceptionAction()
201 e.submit((Runnable) null); in testExecuteNullRunnable()
212 e.submit((Callable) null); in testSubmitNullCallable()
234 Future<Void> future = p.submit(awaiter); in testInterruptedSubmit()
[all …]
DExecutorCompletionService9Test.java65 solvers.forEach(cs::submit); in solveAll()
82 solvers.forEach(solver -> futures.add(cs.submit(solver))); in solveAny()
/libcore/jsr166-tests/src/test/java/jsr166/
DExecutorCompletionServiceTest.java69 ecs.submit(c); in testSubmitNPE()
84 ecs.submit(r, Boolean.TRUE); in testSubmitNPE2()
98 ecs.submit(c); in testTake()
112 Future f1 = ecs.submit(c); in testTake2()
127 ecs.submit(c); in testPoll1()
150 ecs.submit(c); in testPoll2()
179 Future f1 = ecs.submit(c); in testNewTaskForCallable()
210 Future f1 = ecs.submit(r, null); in testNewTaskForRunnable()
DForkJoinPoolTest.java232 Future<?> future = p.submit(task); in testGetPoolSize()
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(awaiter(done));
409 ForkJoinTask c = p.submit(awaiter(done));
430 Future<?> future = e.submit(new CheckedRunnable() { in testExecuteRunnable()
[all …]
DAbstractExecutorServiceTest.java70 Future<?> future = e.submit(new CheckedRunnable() { in testExecuteRunnable()
86 Future<String> future = e.submit(new StringTask()); in testSubmitCallable()
96 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable()
106 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2()
118 Future future = e.submit(Executors.callable(new PrivilegedAction() { in testSubmitPrivilegedAction()
139 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitPrivilegedExceptionAction()
157 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitFailedPrivilegedExceptionAction()
178 e.submit((Runnable) null); in testExecuteNullRunnable()
189 e.submit((Callable) null); in testSubmitNullCallable()
211 Future<Void> future = p.submit(awaiter); in testInterruptedSubmit()
[all …]
DCollection8Test.java95 f1 = pool.submit(checkElt); in testForEachConcurrentStressTest()
96 f2 = pool.submit(addRemove); in testForEachConcurrentStressTest()
/libcore/ojluni/src/main/java/java/util/concurrent/
DExecutorService.java226 <T> Future<T> submit(Callable<T> task); in submit() method
241 <T> Future<T> submit(Runnable task, T result); in submit() method
254 Future<?> submit(Runnable task); in submit() method
DCompletionService.java73 Future<V> submit(Callable<V> task); in submit() method
89 Future<V> submit(Runnable task, V result); in submit() method
DAbstractExecutorService.java115 public Future<?> submit(Runnable task) { in submit() method in AbstractExecutorService
126 public <T> Future<T> submit(Runnable task, T result) { in submit() method in AbstractExecutorService
137 public <T> Future<T> submit(Callable<T> task) { in submit() method in AbstractExecutorService
173 futures.add(ecs.submit(it.next())); in doInvokeAny()
182 futures.add(ecs.submit(it.next())); in doInvokeAny()
DExecutors.java639 public Future<?> submit(Runnable task) {
640 return e.submit(task);
642 public <T> Future<T> submit(Callable<T> task) {
643 return e.submit(task);
645 public <T> Future<T> submit(Runnable task, T result) {
646 return e.submit(task, result);
DExecutorCompletionService.java180 public Future<V> submit(Callable<V> task) { in submit() method in ExecutorCompletionService
187 public Future<V> submit(Runnable task, V result) { in submit() method in ExecutorCompletionService
DScheduledThreadPoolExecutor.java663 public Future<?> submit(Runnable task) { in submit() method in ScheduledThreadPoolExecutor
671 public <T> Future<T> submit(Runnable task, T result) { in submit() method in ScheduledThreadPoolExecutor
679 public <T> Future<T> submit(Callable<T> task) { in submit() method in ScheduledThreadPoolExecutor
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DForkJoinPoolTest.java40 ForkJoinTask task = pool.submit(() -> result.addAndGet(42), result); in testSubmit()
56 ForkJoinTask task = pool.submit(new Runnable() { in testGetRunningThreadCount()
DCountedCompleterTest.java157 pool.submit(new Task(this, idx)); in completeAllChildren()
176 pool.submit(task); in completeAllChildren()
DAbstractExecutorServiceTest.java76 Future<Integer> future = service.submit(() -> didRun.set(true), value); in testSubmitRunnableWithValue()
/libcore/support/src/test/java/libcore/javax/net/ssl/
DTestSSLSocketPair.java79 Future s = executor.submit(new Callable<Void>() { in connect()
88 Future c = executor.submit(new Callable<Void>() { in connect()
/libcore/support/src/test/java/tests/support/
DSupport_Exec.java87 Future<String> errFuture = executorService.submit( in execAndGetOutput()
89 Future<String> outFuture = executorService.submit( in execAndGetOutput()
/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
DExecutors.java218 public java.util.concurrent.Future<?> submit(java.lang.Runnable task) { in submit() method in Executors.DelegatedExecutorService
222 public <T> java.util.concurrent.Future<T> submit(java.util.concurrent.Callable<T> task) { in submit() method in Executors.DelegatedExecutorService
226 public <T> java.util.concurrent.Future<T> submit(java.lang.Runnable task, T result) { in submit() method in Executors.DelegatedExecutorService
/libcore/luni/src/test/java/tests/security/
DSecureRandomTest.java82 ecs.submit(new Callable<Void>() { in testSecureRandomThreadSafety()
/libcore/luni/src/test/java/libcore/java/security/
DMessageDigestTest.java44 es.submit(new Callable<Void>() { in testMessageDigest_MultipleThreads_Misuse()
/libcore/luni/src/test/java/libcore/java/util/zip/
DDeflaterOutputStreamTest.java80 executor.submit(new Callable<Void>() { in createInflaterStream()
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/
DOutputStreamTesterTest.java124 future = executor.submit(new Callable<byte[]>() { in create()
DWriterTesterTest.java117 future = executor.submit(new Callable<char[]>() { in create()

12