Searched refs:adapt (Results 1 – 8 of 8) sorted by relevance
42 final ForkJoinTask task = ForkJoinTask.adapt(() -> result.addAndGet(42), result); in testAdaptToRunnableWithResult()61 final ForkJoinTask task = ForkJoinTask.adapt(callable); in testAdaptToCallable()80 final ForkJoinTask task = ForkJoinTask.adapt(callable); in testAdaptToCallableThrowsException()
100 private static IntConsumer adapt(Sink<Integer> sink) { in adapt() method in IntPipeline119 private static Spliterator.OfInt adapt(Spliterator<Integer> s) { in adapt() method in IntPipeline167 Spliterator.OfInt spl = adapt(spliterator); in forEachWithCancel()168 IntConsumer adaptedSink = adapt(sink); in forEachWithCancel()189 return adapt(super.spliterator()); in spliterator()580 adapt(sourceStageSpliterator()).forEachRemaining(action);590 adapt(sourceStageSpliterator()).forEachRemaining(action);
100 private static LongConsumer adapt(Sink<Long> sink) { in adapt() method in LongPipeline118 private static Spliterator.OfLong adapt(Spliterator<Long> s) { in adapt() method in LongPipeline165 Spliterator.OfLong spl = adapt(spliterator); in forEachWithCancel()166 LongConsumer adaptedSink = adapt(sink); in forEachWithCancel()186 return adapt(super.spliterator()); in spliterator()563 adapt(sourceStageSpliterator()).forEachRemaining(action);572 adapt(sourceStageSpliterator()).forEachRemaining(action);
99 private static DoubleConsumer adapt(Sink<Double> sink) { in adapt() method in DoublePipeline117 private static Spliterator.OfDouble adapt(Spliterator<Double> s) { in adapt() method in DoublePipeline164 Spliterator.OfDouble spl = adapt(spliterator); in forEachWithCancel()165 DoubleConsumer adaptedSink = adapt(sink); in forEachWithCancel()185 return adapt(super.spliterator()); in spliterator()582 adapt(sourceStageSpliterator()).forEachRemaining(consumer);592 adapt(sourceStageSpliterator()).forEachRemaining(consumer);
1453 public static ForkJoinTask<?> adapt(Runnable runnable) { in adapt() method in ForkJoinTask1467 public static <T> ForkJoinTask<T> adapt(Runnable runnable, T result) { in adapt() method in ForkJoinTask1481 public static <T> ForkJoinTask<T> adapt(Callable<? extends T> callable) { in adapt() method in ForkJoinTask
1199 final ForkJoinTask a = ForkJoinTask.adapt(awaiter(done));1200 final ForkJoinTask b = ForkJoinTask.adapt(awaiter(done));1201 final ForkJoinTask c = ForkJoinTask.adapt(awaiter(done));
1176 final ForkJoinTask a = ForkJoinTask.adapt(awaiter(done));1177 final ForkJoinTask b = ForkJoinTask.adapt(awaiter(done));1178 final ForkJoinTask c = ForkJoinTask.adapt(awaiter(done));
14724 method public static java.util.concurrent.ForkJoinTask<?> adapt(Runnable);14725 method public static <T> java.util.concurrent.ForkJoinTask<T> adapt(Runnable, T);14726 …method public static <T> java.util.concurrent.ForkJoinTask<T> adapt(java.util.concurrent.Callable<…