Home | History | Annotate | Download | only in concurrent

Lines Matching defs:future

47     AbstractFuture<String> future = new AbstractFuture<String>() {
53 ExecutionException ee1 = getExpectingExecutionException(future);
54 ExecutionException ee2 = getExpectingExecutionException(future);
67 InterruptibleFuture future = new InterruptibleFuture();
68 assertTrue(future.cancel(false));
69 assertTrue(future.isCancelled());
70 assertTrue(future.isDone());
71 assertFalse(future.wasInterrupted);
75 InterruptibleFuture future = new InterruptibleFuture();
76 assertTrue(future.cancel(true));
77 assertTrue(future.isCancelled());
78 assertTrue(future.isDone());
79 assertTrue(future.wasInterrupted);
83 AbstractFuture<String> future = new AbstractFuture<String>() {
88 assertFalse(future.cancel(true));
89 assertFalse(future.isCancelled());
90 assertTrue(future.isDone());
96 final AbstractFuture<String> future = new AbstractFuture<String>() {};
101 future.set("success");
102 if (!future.isDone()) {
103 errorMessage.set("Set call exited before future was complete.");
110 future.setException(new IllegalArgumentException("failure"));
111 if (!future.isDone()) {
112 errorMessage.set("SetException call exited before future was complete.");
119 future.cancel(true);
120 if (!future.isDone()) {
121 errorMessage.set("Cancel call exited before future was complete.");
126 future.get();
166 AbstractFuture<String> future) throws InterruptedException {
168 String got = future.get();