Home
last modified time | relevance | path

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

123

/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 …]
DSubmissionPublisherTest.java236 p.submit(1); in testClose()
259 p.submit(1); in testCloseExceptionally()
393 p.submit(1); in testCloseCompletes()
415 p.submit(1); in testCloseExceptionallyError()
439 p.submit(1); in testCancel()
442 p.submit(i); in testCancel()
461 p.submit(1);
463 p.submit(2);
484 p.submit(1);
486 p.submit(2);
[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.java75 Future<V> submit(Callable<V> task); in submit() method
91 Future<V> submit(Runnable task, V result); in submit() method
DAbstractExecutorService.java120 public Future<?> submit(Runnable task) { in submit() method in AbstractExecutorService
131 public <T> Future<T> submit(Runnable task, T result) { in submit() method in AbstractExecutorService
142 public <T> Future<T> submit(Callable<T> task) { in submit() method in AbstractExecutorService
178 futures.add(ecs.submit(it.next())); in doInvokeAny()
187 futures.add(ecs.submit(it.next())); in doInvokeAny()
DExecutors.java703 public Future<?> submit(Runnable task) {
705 return e.submit(task);
708 public <T> Future<T> submit(Callable<T> task) {
710 return e.submit(task);
713 public <T> Future<T> submit(Runnable task, T result) {
715 return e.submit(task, result);
DExecutorCompletionService.java181 public Future<V> submit(Callable<V> task) { in submit() method in ExecutorCompletionService
192 public Future<V> submit(Runnable task, V result) { in submit() method in ExecutorCompletionService
/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/luni/src/test/java/libcore/java/util/concurrent/
DForkJoinPoolTest.java41 ForkJoinTask task = pool.submit(() -> result.addAndGet(42), result); in testSubmit()
58 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/tools/expected_upstream/
DREADME.md156 Here are the order of events / votes required to submit your CL on gerrit as of
163 4. Click the submit button / `Autosubmit +1` on commit `B`, `C` and `E`
164 * Never submit commit `A` individually without submitting `B` together.
167 * Due a Gerrit bug, you can't submit the commit `C` before submitting `B`
169 submit `B` yourself manually.
170 * If you can't submit the CL due a permission issue, ask an Android Core
171 Library member to submit.
/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/ojluni/src/test/java/util/Properties/
DConcurrentLoadAndStoreXML.java98 task[i] = pool.submit(basher[i]); in main()
/libcore/luni/src/test/java/libcore/java/security/
DMessageDigestTest.java44 es.submit(new Callable<Void>() { in testMessageDigest_MultipleThreads_Misuse()
/libcore/ojluni/src/test/java/lang/constant/
DDynamicConstantDescTest.java77 results[i++] = executor.submit(task); in main()

123