Home
last modified time | relevance | path

Searched refs:CompletableFuture (Results 1 – 18 of 18) sorted by relevance

/libcore/jsr166-tests/src/test/java/jsr166/
DCompletableFutureTest.java12 import static java.util.concurrent.CompletableFuture.completedFuture;
13 import static java.util.concurrent.CompletableFuture.failedFuture;
28 import java.util.concurrent.CompletableFuture;
64 void checkIncomplete(CompletableFuture<?> f) { in checkIncomplete()
79 <T> void checkCompletedNormally(CompletableFuture<T> f, T value) { in checkCompletedNormally()
101 <U> Throwable exceptionalCompletion(CompletableFuture<U> f) { in exceptionalCompletion()
107 void checkCompletedExceptionally(CompletableFuture<?> f, in checkCompletedExceptionally()
155 void checkCompletedWithWrappedCFException(CompletableFuture<?> f) {
160 void checkCompletedWithWrappedCancellationException(CompletableFuture<?> f) { in checkCompletedWithWrappedCancellationException()
165 void checkCompletedWithTimeoutException(CompletableFuture<?> f) { in checkCompletedWithTimeoutException()
[all …]
/libcore/ojluni/src/test/java/util/concurrent/tck/
DCompletableFutureTest.java39 import static java.util.concurrent.CompletableFuture.completedFuture;
40 import static java.util.concurrent.CompletableFuture.failedFuture;
55 import java.util.concurrent.CompletableFuture;
88 void checkIncomplete(CompletableFuture<?> f) { in checkIncomplete()
107 <T> void checkCompletedNormally(CompletableFuture<T> f, T expectedValue) { in checkCompletedNormally()
129 Throwable exceptionalCompletion(CompletableFuture<?> f) { in exceptionalCompletion()
135 void checkCompletedExceptionally(CompletableFuture<?> f, in checkCompletedExceptionally()
181 void checkCompletedWithWrappedCFException(CompletableFuture<?> f) {
186 void checkCompletedWithWrappedCancellationException(CompletableFuture<?> f) { in checkCompletedWithWrappedCancellationException()
191 void checkCompletedWithTimeoutException(CompletableFuture<?> f) { in checkCompletedWithTimeoutException()
[all …]
DSubmissionPublisherTest.java36 import java.util.concurrent.CompletableFuture;
973 CompletableFuture<Void> f = in testConsume()
989 CompletableFuture<Void> f = p.consume(null); in testConsumeNPE()
1000 CompletableFuture<Void> f = p.consume(x -> count.getAndIncrement()); in testCancelledConsume()
1027 CompletableFuture.runAsync(() -> pub.submit(Boolean.TRUE));
1033 CompletableFuture.runAsync(() -> pub.submit(Boolean.TRUE));
DThreadLocalRandom8Test.java275 java.util.concurrent.CompletableFuture.supplyAsync( in testSerialization()
/libcore/ojluni/src/main/java/java/util/concurrent/
DCompletableFuture.java120 public class CompletableFuture<T> implements Future<T>, CompletionStage<T> { class
453 abstract CompletableFuture<?> tryFire(int mode); in tryFire()
474 CompletableFuture<?> f = this; Completion h; in postComplete()
477 CompletableFuture<?> d; Completion t; in postComplete()
528 CompletableFuture<V> dep; // the dependent to complete
529 CompletableFuture<T> src; // source for action
531 UniCompletion(Executor executor, CompletableFuture<V> dep, in UniCompletion()
532 CompletableFuture<T> src) { in UniCompletion()
578 final CompletableFuture<T> postFire(CompletableFuture<?> a, int mode) { in postFire()
598 UniApply(Executor executor, CompletableFuture<V> dep, in UniApply()
[all …]
DSubmissionPublisher.java921 public CompletableFuture<Void> consume(Consumer<? super T> consumer) { in consume()
924 CompletableFuture<Void> status = new CompletableFuture<>(); in consume()
931 final CompletableFuture<Void> status;
934 ConsumerSubscriber(CompletableFuture<Void> status, in ConsumerSubscriber()
970 implements Runnable, CompletableFuture.AsynchronousCompletionTask {
DCompletionStage.java987 public CompletableFuture<T> toCompletableFuture(); in toCompletableFuture()
DForkJoinPool.java1252 CompletableFuture.AsynchronousCompletionTask) &&
/libcore/ojluni/annotations/mmodule/java/util/concurrent/
DCompletableFuture.annotated.java42 public class CompletableFuture<T> implements java.util.concurrent.Future<T>, java.util.concurrent.C… class
44 public CompletableFuture() { throw new RuntimeException("Stub!"); } in CompletableFuture() method in CompletableFuture
46 public static <U> java.util.concurrent.CompletableFuture<U> supplyAsync(java.util.function.Supplier… in supplyAsync()
48 public static <U> java.util.concurrent.CompletableFuture<U> supplyAsync(java.util.function.Supplier… in supplyAsync()
50 public static java.util.concurrent.CompletableFuture<java.lang.Void> runAsync(java.lang.Runnable ru… in runAsync()
52 public static java.util.concurrent.CompletableFuture<java.lang.Void> runAsync(java.lang.Runnable ru… in runAsync()
54 public static <U> java.util.concurrent.CompletableFuture<U> completedFuture(U value) { throw new Ru… in completedFuture()
70 public <U> java.util.concurrent.CompletableFuture<U> thenApply(java.util.function.Function<? super … in thenApply()
72 public <U> java.util.concurrent.CompletableFuture<U> thenApplyAsync(java.util.function.Function<? s… in thenApplyAsync()
74 public <U> java.util.concurrent.CompletableFuture<U> thenApplyAsync(java.util.function.Function<? s… in thenApplyAsync()
[all …]
/libcore/ojluni/src/test/java/util/Properties/
DCheckUnsynchronized.java28 import java.util.concurrent.CompletableFuture;
42 CompletableFuture.supplyAsync(() -> props.contains("value")).join()); in main()
44 CompletableFuture.supplyAsync(() -> props.containsKey("key")).join()); in main()
46 CompletableFuture.supplyAsync(() -> props.containsValue("value")).join()); in main()
48 CompletableFuture.supplyAsync(() -> props.elements()).join(); in main()
51 CompletableFuture.supplyAsync(() -> props.getProperty("key")).join()); in main()
53 … CompletableFuture.supplyAsync(() -> props.getOrDefault("missing", "default")).join()); in main()
55 CompletableFuture.supplyAsync(() -> props.isEmpty()).join()); in main()
57 CompletableFuture.supplyAsync(() -> props.keys()).join(); in main()
60 CompletableFuture.supplyAsync(() -> props.size()).join()); in main()
/libcore/ojluni/src/test/java/util/Random/
DRandomStreamTest.java35 import java.util.concurrent.CompletableFuture;
151 List<CompletableFuture<T>> cfs = Stream.generate(() -> CompletableFuture.supplyAsync(s)). in testRandomResultSupplierConcurrently()
157 …CompletableFuture<Void> all = CompletableFuture.allOf(cfs.stream().toArray(CompletableFuture[]::ne… in testRandomResultSupplierConcurrently()
161 long rc = cfs.stream().map(CompletableFuture::join).distinct().count(); in testRandomResultSupplierConcurrently()
DRandomTestMoments.java31 import java.util.concurrent.CompletableFuture;
DRandomTestChiSquared.java32 import java.util.concurrent.CompletableFuture;
DRandomTestBsi1999.java32 import java.util.concurrent.CompletableFuture;
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DCompletionStageTest.java24 import java.util.concurrent.CompletableFuture;
290 public CompletableFuture<T> toCompletableFuture() { in toCompletableFuture()
/libcore/api/
Dcurrent.txt15387 …public class CompletableFuture<T> implements java.util.concurrent.CompletionStage<T> java.util.con…
15388 ctor public CompletableFuture();
15389 …method public java.util.concurrent.CompletableFuture<java.lang.Void> acceptEither(java.util.concur…
15390 …method public java.util.concurrent.CompletableFuture<java.lang.Void> acceptEitherAsync(java.util.c…
15391 …method public java.util.concurrent.CompletableFuture<java.lang.Void> acceptEitherAsync(java.util.c…
15392 …d public static java.util.concurrent.CompletableFuture<java.lang.Void> allOf(java.util.concurrent.…
15393 … public static java.util.concurrent.CompletableFuture<java.lang.Object> anyOf(java.util.concurrent…
15394 …method public <U> java.util.concurrent.CompletableFuture<U> applyToEither(java.util.concurrent.Com…
15395 …method public <U> java.util.concurrent.CompletableFuture<U> applyToEitherAsync(java.util.concurren…
15396 …method public <U> java.util.concurrent.CompletableFuture<U> applyToEitherAsync(java.util.concurren…
[all …]
/libcore/
Dopenjdk_java_files.bp977 "ojluni/src/main/java/java/util/concurrent/CompletableFuture.java",
DEXPECTED_UPSTREAM1028 …java/util/concurrent/CompletableFuture.java,jdk17u/jdk-17.0.6-ga,src/java.base/share/classes/java/…