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));
DExecutorsTest.java293 Future future = executor.submit(sleeper); in testTimedCallable()
/libcore/luni/src/main/java/java/util/concurrent/
DExecutorService.java197 <T> Future<T> submit(Callable<T> task); in submit() method
212 <T> Future<T> submit(Runnable task, T result); in submit() method
225 Future<?> submit(Runnable task); in submit() method
DCompletionService.java44 Future<V> submit(Callable<V> task); in submit() method
60 Future<V> submit(Runnable task, V result); in submit() method
DAbstractExecutorService.java86 public Future<?> submit(Runnable task) { in submit() method in AbstractExecutorService
97 public <T> Future<T> submit(Runnable task, T result) { in submit() method in AbstractExecutorService
108 public <T> Future<T> submit(Callable<T> task) { in submit() method in AbstractExecutorService
144 futures.add(ecs.submit(it.next())); in doInvokeAny()
153 futures.add(ecs.submit(it.next())); in doInvokeAny()
DExecutors.java600 public Future<?> submit(Runnable task) {
601 return e.submit(task);
603 public <T> Future<T> submit(Callable<T> task) {
604 return e.submit(task);
606 public <T> Future<T> submit(Runnable task, T result) {
607 return e.submit(task, result);
DExecutorCompletionService.java151 public Future<V> submit(Callable<V> task) { in submit() method in ExecutorCompletionService
158 public Future<V> submit(Runnable task, V result) { in submit() method in ExecutorCompletionService
DScheduledThreadPoolExecutor.java634 public Future<?> submit(Runnable task) { in submit() method in ScheduledThreadPoolExecutor
642 public <T> Future<T> submit(Runnable task, T result) { in submit() method in ScheduledThreadPoolExecutor
650 public <T> Future<T> submit(Callable<T> task) { in submit() method in ScheduledThreadPoolExecutor
DForkJoinPool.java2761 public <T> ForkJoinTask<T> submit(ForkJoinTask<T> task) { in submit() method in ForkJoinPool
2770 public <T> ForkJoinTask<T> submit(Callable<T> task) { in submit() method in ForkJoinPool
2779 public <T> ForkJoinTask<T> submit(Runnable task, T result) { in submit() method in ForkJoinPool
2788 public ForkJoinTask<?> submit(Runnable task) { in submit() method in ForkJoinPool
/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()
128 executorService.submit(streamToStringCallable(process.getErrorStream())); in execAndCheckOutput()
130 executorService.submit(streamToStringCallable(process.getInputStream())); in execAndCheckOutput()
/libcore/luni/src/test/java/libcore/javax/net/ssl/
DSSLSocketTest.java350 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_startHandshake()
408 final Future<byte[]> future1 = executor.submit(new SSLServerSessionIdCallable(server1)); in test_SSLSocket_confirmSessionReuse()
421 final Future<byte[]> future2 = executor.submit(new SSLServerSessionIdCallable(server2)); in test_SSLSocket_confirmSessionReuse()
445 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_NoEnabledCipherSuites_Failure()
475 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_startHandshake_noKeyStore()
505 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_startHandshake_noClientCertificate()
525 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_HandshakeCompletedListener()
648 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_HandshakeCompletedListener_RuntimeException()
714 Future<IOException> future = executor.submit(new Callable<IOException>() { in test_SSLSocket_setUseClientMode()
768 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_untrustedServer()
[all …]
DSSLEngineTest.java821 Future<Void> client = executor.submit(new Callable<Void>() {
833 Future<Void> server = executor.submit(new Callable<Void>() {
/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.java76 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()

12