| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | Invoker.java | 280 static <V,A> void invokeUnchecked(PendingFuture<V,A> future) { in invokeUnchecked() argument
281 assert future.isDone(); in invokeUnchecked()
282 CompletionHandler<V,? super A> handler = future.handler(); in invokeUnchecked()
285 future.attachment(), in invokeUnchecked()
286 future.value(), in invokeUnchecked()
287 future.exception()); in invokeUnchecked()
296 static <V,A> void invoke(PendingFuture<V,A> future) { in invoke() argument
297 assert future.isDone(); in invoke()
298 CompletionHandler<V,? super A> handler = future.handler(); in invoke()
300 invoke(future.channel(), in invoke()
[all …]
|
| D | UnixAsynchronousSocketChannelImpl.java | 297 PendingFuture<Void,Object> future = connectFuture; in finishConnect() local
299 future.setResult(null, e); in finishConnect()
402 PendingFuture<Number,Object> future = readFuture; in finishRead() local
451 future.setResult(result, exc); in finishRead()
465 PendingFuture<Number,Object> future = null;
473 future = readFuture;
482 future.setFailure(exc);
597 PendingFuture<Number,Object> future = this.writeFuture; in finishWrite() local
646 future.setResult(result, exc); in finishWrite()
660 PendingFuture<Number,Object> future = null;
[all …]
|
| D | UnixAsynchronousServerSocketChannelImpl.java | 111 PendingFuture<AsynchronousSocketChannel,Object> future; in implClose() local
118 future = acceptFuture; in implClose()
126 future.setFailure(x); in implClose()
201 PendingFuture<AsynchronousSocketChannel,Object> future = acceptFuture; in onEvent() local
207 future.setResult(child, exc); in onEvent()
210 if (child != null && future.isCancelled()) { in onEvent()
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | AbstractExecutorServiceTest.java | 70 Future<?> future = e.submit(new CheckedRunnable() { in testExecuteRunnable() local
74 assertNull(future.get()); in testExecuteRunnable()
75 assertNull(future.get(0, MILLISECONDS)); in testExecuteRunnable()
77 assertTrue(future.isDone()); in testExecuteRunnable()
78 assertFalse(future.isCancelled()); in testExecuteRunnable()
86 Future<String> future = e.submit(new StringTask()); in testSubmitCallable() local
87 String result = future.get(); in testSubmitCallable()
96 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable() local
97 future.get(); in testSubmitRunnable()
98 assertTrue(future.isDone()); in testSubmitRunnable()
[all …]
|
| D | ForkJoinPoolTest.java | 232 Future<?> future = p.submit(task); in testGetPoolSize() local
430 Future<?> future = e.submit(new CheckedRunnable() { in testExecuteRunnable() local
434 assertNull(future.get()); in testExecuteRunnable()
435 assertNull(future.get(0, MILLISECONDS)); in testExecuteRunnable()
437 assertTrue(future.isDone()); in testExecuteRunnable()
438 assertFalse(future.isCancelled()); in testExecuteRunnable()
448 Future<String> future = e.submit(new StringTask()); in testSubmitCallable() local
449 assertSame(TEST_STRING, future.get()); in testSubmitCallable()
450 assertTrue(future.isDone()); in testSubmitCallable()
451 assertFalse(future.isCancelled()); in testSubmitCallable()
[all …]
|
| D | ThreadPoolExecutorTest.java | 1443 Future<String> future = e.submit(new StringTask()); in testSubmitCallable() local
1444 String result = future.get(); in testSubmitCallable()
1458 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable() local
1459 future.get(); in testSubmitRunnable()
1460 assertTrue(future.isDone()); in testSubmitRunnable()
1473 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2() local
1474 String result = future.get(); in testSubmitRunnable2()
1654 for (Future<String> future : futures) in testInvokeAll5()
1655 assertSame(TEST_STRING, future.get()); in testInvokeAll5()
1878 for (Future<String> future : futures)
[all …]
|
| D | ThreadPoolExecutorSubclassTest.java | 1436 Future<String> future = e.submit(new StringTask()); in testSubmitCallable() local
1437 String result = future.get(); in testSubmitCallable()
1451 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable() local
1452 future.get(); in testSubmitRunnable()
1453 assertTrue(future.isDone()); in testSubmitRunnable()
1466 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2() local
1467 String result = future.get(); in testSubmitRunnable2()
1647 for (Future<String> future : futures) in testInvokeAll5()
1648 assertSame(TEST_STRING, future.get()); in testInvokeAll5()
1871 for (Future<String> future : futures)
[all …]
|
| D | ScheduledExecutorTest.java | 835 Future<String> future = e.submit(new StringTask()); in testSubmitCallable() local
836 String result = future.get(); in testSubmitCallable()
847 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable() local
848 future.get(); in testSubmitRunnable()
849 assertTrue(future.isDone()); in testSubmitRunnable()
859 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2() local
860 String result = future.get(); in testSubmitRunnable2()
1010 for (Future<String> future : futures) in testInvokeAll5()
1011 assertSame(TEST_STRING, future.get()); in testInvokeAll5()
1197 for (Future<String> future : futures)
[all …]
|
| D | ScheduledExecutorSubclassTest.java | 886 Future<String> future = e.submit(new StringTask()); in testSubmitCallable() local
887 String result = future.get(); in testSubmitCallable()
898 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable() local
899 future.get(); in testSubmitRunnable()
900 assertTrue(future.isDone()); in testSubmitRunnable()
910 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2() local
911 String result = future.get(); in testSubmitRunnable2()
1061 for (Future<String> future : futures) in testInvokeAll5()
1062 assertSame(TEST_STRING, future.get()); in testInvokeAll5()
1247 for (Future<String> future : futures)
[all …]
|
| D | JSR166TestCase.java | 943 for (Future<?> future : futures)
945 assertNull(future.get(LONG_DELAY_MS, MILLISECONDS));
1026 void assertFutureTimesOut(Future future) {
1027 assertFutureTimesOut(future, timeoutMillis());
1033 void assertFutureTimesOut(Future future, long timeoutMillis) {
1036 future.get(timeoutMillis, MILLISECONDS);
1041 } finally { future.cancel(true); }
|
| D | ExecutorsTest.java | 293 Future future = executor.submit(sleeper); in testTimedCallable()
294 assertFutureTimesOut(future); in testTimedCallable()
|
| D | FutureTaskTest.java | 837 for (Future<?> future : futures) in testGet_NegativeInfinityTimeout()
838 checkCompletedNormally(future, null); in testGet_NegativeInfinityTimeout()
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
| D | OutputStreamTesterTest.java | 117 private Future<byte[]> future; field in OutputStreamTesterTest.PipedOutputStreamSinkTester
124 future = executor.submit(new Callable<byte[]>() { in create()
142 return future.get(); in getBytes()
|
| D | WriterTesterTest.java | 110 private Future<char[]> future; field in WriterTesterTest.PipedWriterCharSinkTester
117 future = executor.submit(new Callable<char[]>() { in create()
136 return future.get(); in getChars()
|
| /libcore/ojluni/src/main/java/java/io/ |
| D | ObjectStreamClass.java | 340 EntryFuture future = null; in lookup() local
354 future = newEntry; in lookup()
362 future = (EntryFuture) entry; in lookup()
363 if (future.getOwner() == Thread.currentThread()) { in lookup()
372 entry = future.get(); in lookup()
381 if (future.set(entry)) { in lookup()
385 entry = future.get(); in lookup()
2251 EntryFuture future = null; in getReflector() local
2265 future = newEntry; in getReflector()
2279 future.set(entry); in getReflector()
|
| /libcore/luni/src/test/java/libcore/java/util/concurrent/ |
| D | CopyOnWriteArrayListTest.java | 181 Future<?> future = executor.submit(new Runnable() { in testAddAllIsAtomic() local
200 future.get(); // this will throw the above exception in testAddAllIsAtomic()
|
| /libcore/ |
| D | JavaLibrary.bp | 666 // in future, this could be addressed eg. by splitting
|