Package io.foldright.cffu2

Class MCffu.ParOps

java.lang.Object

io.foldright.cffu2.MCffu.ParOps

Enclosing class:

MCffu<E,T extends Iterable<? extends E>>

public final class MCffu.ParOps
extends Object

The methods for parallel data processing.

See Also:

• CffuFactory.parOps()
• CfParallelUtils

Method Summary

Modifier and Type	Method	Description
Cffu<Void>	thenParAcceptAnyAsync(Consumer<? super E> action)	Shortcut to method anyOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor BaseCffu.defaultExecutor().
Cffu<Void>	thenParAcceptAnyAsync(Consumer<? super E> action, Executor executor)	Shortcut to method anyOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable, Executor).
Cffu<Void>	thenParAcceptAnySuccessAsync(Consumer<? super E> action)	Shortcut to method anySuccessOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor BaseCffu.defaultExecutor().
Cffu<Void>	thenParAcceptAnySuccessAsync(Consumer<? super E> action, Executor executor)	Shortcut to method anySuccessOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable, Executor).
Cffu<Void>	thenParAcceptAsync(Consumer<? super E> action)	Shortcut to method allResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor BaseCffu.defaultExecutor().
Cffu<Void>	thenParAcceptAsync(Consumer<? super E> action, Executor executor)	Shortcut to method allResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable, Executor).
Cffu<Void>	thenParAcceptFailFastAsync(Consumer<? super E> action)	Shortcut to method allResultsFailFastOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor BaseCffu.defaultExecutor().
Cffu<Void>	thenParAcceptFailFastAsync(Consumer<? super E> action, Executor executor)	Shortcut to method allResultsFailFastOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable, Executor).
<U> MCffu<U,List<U>>	thenParApplyAllSuccessAsync(U valueIfFailed, Function<? super E,? extends U> fn)	Shortcut to method allSuccessResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor BaseCffu.defaultExecutor().
<U> MCffu<U,List<U>>	thenParApplyAllSuccessAsync(U valueIfFailed, Function<? super E,? extends U> fn, Executor executor)	Shortcut to method allSuccessResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).
<U> Cffu<U>	thenParApplyAnyAsync(Function<? super E,? extends U> fn)	Shortcut to method anyOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor BaseCffu.defaultExecutor().
<U> Cffu<U>	thenParApplyAnyAsync(Function<? super E,? extends U> fn, Executor executor)	Shortcut to method anyOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).
<U> Cffu<U>	thenParApplyAnySuccessAsync(Function<? super E,? extends U> fn)	Shortcut to method anySuccessOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor BaseCffu.defaultExecutor().
<U> Cffu<U>	thenParApplyAnySuccessAsync(Function<? super E,? extends U> fn, Executor executor)	Shortcut to method anySuccessOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).
<U> MCffu<U,List<U>>	thenParApplyAsync(Function<? super E,? extends U> fn)	Shortcut to method allResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor BaseCffu.defaultExecutor().
<U> MCffu<U,List<U>>	thenParApplyAsync(Function<? super E,? extends U> fn, Executor executor)	Shortcut to method allResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).
<U> MCffu<U,List<U>>	thenParApplyFailFastAsync(Function<? super E,? extends U> fn)	Shortcut to method allResultsFailFastOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor BaseCffu.defaultExecutor().
<U> MCffu<U,List<U>>	thenParApplyFailFastAsync(Function<? super E,? extends U> fn, Executor executor)	Shortcut to method allResultsFailFastOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).
<U> MCffu<U,List<U>>	thenParApplyMostSuccessAsync(U valueIfNotSuccess, long timeout, TimeUnit unit, Function<? super E,? extends U> fn)	Shortcut to method mostSuccessResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor BaseCffu.defaultExecutor().
<U> MCffu<U,List<U>>	thenParApplyMostSuccessAsync(U valueIfNotSuccess, long timeout, TimeUnit unit, Function<? super E,? extends U> fn, Executor executor)	Shortcut to method mostSuccessResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

thenParApplyFailFastAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public <U> MCffu<U,List<U>> thenParApplyFailFastAsync(Function<? super E,? extends U> fn)

Shortcut to method allResultsFailFastOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor BaseCffu.defaultExecutor().

See the allResultsFailFastOf documentation for the rules of result computation.

thenParApplyFailFastAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public <U> MCffu<U,List<U>> thenParApplyFailFastAsync(Function<? super E,? extends U> fn,
 Executor executor)

Shortcut to method allResultsFailFastOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).

See the allResultsFailFastOf documentation for the rules of result computation.

thenParApplyAllSuccessAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public <U> MCffu<U,List<U>> thenParApplyAllSuccessAsync(@Nullable
 U valueIfFailed,
 Function<? super E,? extends U> fn)

Shortcut to method allSuccessResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor BaseCffu.defaultExecutor().

See the allSuccessResultsOf documentation for the rules of result computation.

thenParApplyAllSuccessAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public <U> MCffu<U,List<U>> thenParApplyAllSuccessAsync(@Nullable
 U valueIfFailed,
 Function<? super E,? extends U> fn,
 Executor executor)

Shortcut to method allSuccessResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).

See the allSuccessResultsOf documentation for the rules of result computation.

thenParApplyMostSuccessAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public <U> MCffu<U,List<U>> thenParApplyMostSuccessAsync(@Nullable
 U valueIfNotSuccess,
 long timeout,
 TimeUnit unit,
 Function<? super E,? extends U> fn)

Shortcut to method mostSuccessResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor BaseCffu.defaultExecutor().

See the mostSuccessResultsOf documentation for the rules of result computation.

thenParApplyMostSuccessAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public <U> MCffu<U,List<U>> thenParApplyMostSuccessAsync(@Nullable
 U valueIfNotSuccess,
 long timeout,
 TimeUnit unit,
 Function<? super E,? extends U> fn,
 Executor executor)

Shortcut to method mostSuccessResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).

See the mostSuccessResultsOf documentation for the rules of result computation.

thenParApplyAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public <U> MCffu<U,List<U>> thenParApplyAsync(Function<? super E,? extends U> fn)

Shortcut to method allResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor BaseCffu.defaultExecutor().

See the allResultsOf documentation for the rules of result computation.

thenParApplyAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public <U> MCffu<U,List<U>> thenParApplyAsync(Function<? super E,? extends U> fn,
 Executor executor)

Shortcut to method allResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).

See the allResultsOf documentation for the rules of result computation.

thenParApplyAnySuccessAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public <U> Cffu<U> thenParApplyAnySuccessAsync(Function<? super E,? extends U> fn)

Shortcut to method anySuccessOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor BaseCffu.defaultExecutor().

See the anySuccessOf documentation for the rules of result computation.

thenParApplyAnySuccessAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public <U> Cffu<U> thenParApplyAnySuccessAsync(Function<? super E,? extends U> fn,
 Executor executor)

Shortcut to method anySuccessOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).

See the anySuccessOf documentation for the rules of result computation.

thenParApplyAnyAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public <U> Cffu<U> thenParApplyAnyAsync(Function<? super E,? extends U> fn)

Shortcut to method anyOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor BaseCffu.defaultExecutor().

See the anyOf documentation for the rules of result computation.

thenParApplyAnyAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public <U> Cffu<U> thenParApplyAnyAsync(Function<? super E,? extends U> fn,
 Executor executor)

Shortcut to method anyOf, processes elements from the result of parameter stage in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).

See the anyOf documentation for the rules of result computation.

thenParAcceptFailFastAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public Cffu<Void> thenParAcceptFailFastAsync(Consumer<? super E> action)

Shortcut to method allResultsFailFastOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor BaseCffu.defaultExecutor().

See the allResultsFailFastOf documentation for the rules of result computation.

thenParAcceptFailFastAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public Cffu<Void> thenParAcceptFailFastAsync(Consumer<? super E> action,
 Executor executor)

Shortcut to method allResultsFailFastOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable, Executor).

See the allResultsFailFastOf documentation for the rules of result computation.

thenParAcceptAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public Cffu<Void> thenParAcceptAsync(Consumer<? super E> action)

Shortcut to method allResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor BaseCffu.defaultExecutor().

See the allResultsOf documentation for the rules of result computation.

thenParAcceptAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public Cffu<Void> thenParAcceptAsync(Consumer<? super E> action,
 Executor executor)

Shortcut to method allResultsOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable, Executor).

See the allResultsOf documentation for the rules of result computation.

thenParAcceptAnySuccessAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public Cffu<Void> thenParAcceptAnySuccessAsync(Consumer<? super E> action)

Shortcut to method anySuccessOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor BaseCffu.defaultExecutor().

See the anySuccessOf documentation for the rules of result computation.

thenParAcceptAnySuccessAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public Cffu<Void> thenParAcceptAnySuccessAsync(Consumer<? super E> action,
 Executor executor)

Shortcut to method anySuccessOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable, Executor).

See the anySuccessOf documentation for the rules of result computation.

thenParAcceptAnyAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public Cffu<Void> thenParAcceptAnyAsync(Consumer<? super E> action)

Shortcut to method anyOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor BaseCffu.defaultExecutor().

See the anyOf documentation for the rules of result computation.

thenParAcceptAnyAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `thenParAcceptAsync`")
public Cffu<Void> thenParAcceptAnyAsync(Consumer<? super E> action,
 Executor executor)

Shortcut to method anyOf, processes elements from the result of parameter stage in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable, Executor).

See the anyOf documentation for the rules of result computation.