Home
last modified time | relevance | path

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

12

/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()
DThreadPoolExecutorTest.java1045 p.submit(task).get(); in testInterruptedSubmit()
1095 p.submit(task); in testSaturatedSubmitRunnable()
1121 p.submit(Executors.callable(task)); in testSaturatedSubmitCallable()
1443 Future<String> future = e.submit(new StringTask()); in testSubmitCallable()
1458 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable()
1473 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2()
2057 futures.add(e.submit(r));
DScheduledExecutorTest.java779 blockers.add(p.submit(task)); in testShutdown_cancellation()
835 Future<String> future = e.submit(new StringTask()); in testSubmitCallable()
847 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable()
859 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2()
1255 p.submit(immediate);
DScheduledExecutorSubclassTest.java830 blockers.add(p.submit(task)); in testShutdown_cancellation()
886 Future<String> future = e.submit(new StringTask()); in testSubmitCallable()
898 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable()
910 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2()
DThreadPoolExecutorSubclassTest.java1436 Future<String> future = e.submit(new StringTask()); in testSubmitCallable()
1451 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable()
1466 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2()
2021 futures.add(e.submit(r));
/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.java629 public Future<?> submit(Runnable task) {
630 return e.submit(task);
632 public <T> Future<T> submit(Callable<T> task) {
633 return e.submit(task);
635 public <T> Future<T> submit(Runnable task, T result) {
636 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/javax/net/ssl/
DSSLSocketTest.java372 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_noncontiguousProtocols_useLower()
403 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_noncontiguousProtocols_canNegotiate()
441 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_startHandshake()
499 final Future<byte[]> future1 = executor.submit(new SSLServerSessionIdCallable(server1)); in test_SSLSocket_confirmSessionReuse()
512 final Future<byte[]> future2 = executor.submit(new SSLServerSessionIdCallable(server2)); in test_SSLSocket_confirmSessionReuse()
536 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_NoEnabledCipherSuites_Failure()
566 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_startHandshake_noKeyStore()
596 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_startHandshake_noClientCertificate()
616 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_HandshakeCompletedListener()
740 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_HandshakeCompletedListener_RuntimeException()
[all …]
DSSLEngineTest.java862 Future<Void> client = executor.submit(new Callable<Void>() {
875 Future<Void> server = executor.submit(new Callable<Void>() {
/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/support/src/test/java/libcore/javax/net/ssl/
DTestSSLSocketPair.java80 Future s = executor.submit(new Callable<Void>() { in connect()
89 Future c = executor.submit(new Callable<Void>() { in connect()
/libcore/luni/src/test/java/tests/security/
DSecureRandomTest.java82 ecs.submit(new Callable<Void>() { in testSecureRandomThreadSafety()
/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()
/libcore/luni/src/test/java/libcore/java/security/
DMessageDigestTest.java262 es.submit(new Callable<Void>() { in testMessageDigest_MultipleThreads_Misuse()
/libcore/luni/src/test/java/libcore/java/net/
DSocketTest.java411 Executors.newSingleThreadScheduledExecutor().submit(connectWorker); in testCloseDuringConnect()
496 return executor.submit(new Callable<byte[]>() { in enqueue()
/libcore/luni/src/test/java/libcore/net/
DNetworkSecurityPolicyTest.java279 mFirstChunkReceivedFuture = executor.submit(callable); in CapturingServerSocket()

12