| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ExecutorCompletionServiceTest.java | 58 ecs.submit(c); in testSubmitNPE()
74 ecs.submit(r, Boolean.TRUE); in testSubmitNPE2()
90 ecs.submit(c); in testTake()
106 Future f1 = ecs.submit(c); in testTake2()
123 ecs.submit(c); in testPoll1()
148 ecs.submit(c); in testPoll2()
178 Future f1 = ecs.submit(c); in testNewTaskForCallable()
210 Future f1 = ecs.submit(r, null); in testNewTaskForRunnable()
|
| D | ForkJoinPoolTest.java | 217 Future<String> future = p.submit(new StringTask()); in testGetPoolSize()
326 ForkJoinTask<Integer> f = p.submit(new FibTask(8)); in testSubmitForkJoinTask()
342 ForkJoinTask<Integer> f = p.submit(new FibTask(8)); in testSubmitAfterShutdown()
373 ForkJoinTask a = p.submit(awaiter(done)); in testPollSubmission()
374 ForkJoinTask b = p.submit(awaiter(done)); in testPollSubmission()
375 ForkJoinTask c = p.submit(awaiter(done)); in testPollSubmission()
392 ForkJoinTask a = p.submit(awaiter(done)); in testDrainTasksTo()
393 ForkJoinTask b = p.submit(awaiter(done)); in testDrainTasksTo()
394 ForkJoinTask c = p.submit(awaiter(done)); in testDrainTasksTo()
421 Future<?> future = e.submit(task); in testExecuteRunnable()
[all …]
|
| D | AbstractExecutorServiceTest.java | 49 Future<?> future = e.submit(task); in testExecuteRunnable()
62 Future<String> future = e.submit(new StringTask()); in testSubmitCallable()
72 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable()
82 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2()
94 Future future = e.submit(Executors.callable(new PrivilegedAction() { in testSubmitPrivilegedAction()
115 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitPrivilegedExceptionAction()
133 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitFailedPrivilegedExceptionAction()
154 e.submit((Runnable) null); in testExecuteNullRunnable()
165 e.submit((Callable) null); in testSubmitNullCallable()
187 Future<Void> future = p.submit(awaiter); in testInterruptedSubmit()
[all …]
|
| D | ThreadPoolExecutorTest.java | 1011 p.submit(task).get(); in testInterruptedSubmit()
1067 p.submit(task); in testSaturatedSubmitRunnable()
1096 p.submit(Executors.callable(task)); in testSaturatedSubmitCallable()
1398 Future<String> future = e.submit(new StringTask()); in testSubmitCallable()
1415 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable()
1432 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2()
|
| D | ScheduledExecutorTest.java | 750 Future<String> future = e.submit(new StringTask()); in testSubmitCallable()
764 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable()
778 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2()
|
| D | ScheduledExecutorSubclassTest.java | 799 Future<String> future = e.submit(new StringTask()); in testSubmitCallable()
813 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable()
827 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2()
|
| D | ExecutorsTest.java | 271 Future future = executor.submit(sleeper); in testTimedCallable()
|
| D | ThreadPoolExecutorSubclassTest.java | 1268 Future<String> future = e.submit(new StringTask()); in testSubmitCallable()
1282 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable()
1296 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2()
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | ExecutorService.java | 195 <T> Future<T> submit(Callable<T> task); in submit() method
209 <T> Future<T> submit(Runnable task, T result); in submit() method
222 Future<?> submit(Runnable task); in submit() method
|
| D | CompletionService.java | 44 Future<V> submit(Callable<V> task); in submit() method
60 Future<V> submit(Runnable task, V result); in submit() method
|
| D | AbstractExecutorService.java | 78 public Future<?> submit(Runnable task) { in submit() method in AbstractExecutorService
89 public <T> Future<T> submit(Runnable task, T result) { in submit() method in AbstractExecutorService
100 public <T> Future<T> submit(Callable<T> task) { in submit() method in AbstractExecutorService
136 futures.add(ecs.submit(it.next())); in doInvokeAny()
145 futures.add(ecs.submit(it.next())); in doInvokeAny()
|
| D | Executors.java | 592 public Future<?> submit(Runnable task) {
593 return e.submit(task);
595 public <T> Future<T> submit(Callable<T> task) {
596 return e.submit(task);
598 public <T> Future<T> submit(Runnable task, T result) {
599 return e.submit(task, result);
|
| D | ExecutorCompletionService.java | 149 public Future<V> submit(Callable<V> task) { in submit() method in ExecutorCompletionService
156 public Future<V> submit(Runnable task, V result) { in submit() method in ExecutorCompletionService
|
| D | ScheduledThreadPoolExecutor.java | 601 public Future<?> submit(Runnable task) { in submit() method in ScheduledThreadPoolExecutor
609 public <T> Future<T> submit(Runnable task, T result) { in submit() method in ScheduledThreadPoolExecutor
617 public <T> Future<T> submit(Callable<T> task) { in submit() method in ScheduledThreadPoolExecutor
|
| D | ForkJoinPool.java | 2533 public <T> ForkJoinTask<T> submit(ForkJoinTask<T> task) { in submit() method in ForkJoinPool
2545 public <T> ForkJoinTask<T> submit(Callable<T> task) { in submit() method in ForkJoinPool
2556 public <T> ForkJoinTask<T> submit(Runnable task, T result) { in submit() method in ForkJoinPool
2567 public ForkJoinTask<?> submit(Runnable task) { in submit() method in ForkJoinPool
|
| /libcore/support/src/test/java/tests/support/ |
| D | Support_Exec.java | 87 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/ |
| D | SSLSocketTest.java | 320 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_startHandshake()
377 final Future<byte[]> future1 = executor.submit(new SSLServerSessionIdCallable(server1)); in test_SSLSocket_confirmSessionReuse()
390 final Future<byte[]> future2 = executor.submit(new SSLServerSessionIdCallable(server2)); in test_SSLSocket_confirmSessionReuse()
413 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_startHandshake_noKeyStore()
443 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_startHandshake_noClientCertificate()
463 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_HandshakeCompletedListener()
585 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_HandshakeCompletedListener_RuntimeException()
651 Future<IOException> future = executor.submit(new Callable<IOException>() { in test_SSLSocket_setUseClientMode()
705 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_untrustedServer()
735 Future<Void> future = executor.submit(new Callable<Void>() { in test_SSLSocket_clientAuth()
[all …]
|
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| D | TestSSLSocketPair.java | 80 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/ |
| D | SecureRandomTest.java | 82 ecs.submit(new Callable<Void>() { in testSecureRandomThreadSafety()
|
| /libcore/luni/src/test/java/libcore/java/util/zip/ |
| D | DeflaterOutputStreamTest.java | 76 executor.submit(new Callable<Void>() { in createInflaterStream()
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
| D | OutputStreamTesterTest.java | 124 future = executor.submit(new Callable<byte[]>() { in create()
|
| D | WriterTesterTest.java | 117 future = executor.submit(new Callable<char[]>() { in create()
|
| /libcore/luni/src/test/java/libcore/java/security/ |
| D | MessageDigestTest.java | 257 es.submit(new Callable<Void>() { in testMessageDigest_MultipleThreads_Misuse()
|
| /libcore/luni/src/test/java/libcore/java/util/concurrent/ |
| D | CopyOnWriteArrayListTest.java | 180 Future<?> future = executor.submit(new Runnable() { in testAddAllIsAtomic()
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| D | SocketTest.java | 370 return executor.submit(new Callable<byte[]>() { in enqueue()
|