Package io.foldright.cffu2

Class CffuFactory.ParOps

java.lang.Object

io.foldright.cffu2.CffuFactory.ParOps

Enclosing class:

CffuFactory

public final class CffuFactory.ParOps
extends Object

The methods for parallel data processing.

See Also:

• MCffu.parOps()
• CfParallelUtils

Method Summary

Modifier and Type	Method	Description
<T> Cffu<Void>	parAcceptAnyAsync(Iterable<? extends T> elements, Consumer<? super T> action)	Shortcut to method anyOf, processes multiple input elements in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor CffuFactory.defaultExecutor().
<T> Cffu<Void>	parAcceptAnyAsync(Iterable<? extends T> elements, Consumer<? super T> action, Executor executor)	Shortcut to method anyOf, processes multiple input elements in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable, Executor).
<T> Cffu<Void>	parAcceptAnySuccessAsync(Iterable<? extends T> elements, Consumer<? super T> action)	Shortcut to method anySuccessOf, processes multiple input elements in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor CffuFactory.defaultExecutor().
<T> Cffu<Void>	parAcceptAnySuccessAsync(Iterable<? extends T> elements, Consumer<? super T> action, Executor executor)	Shortcut to method anySuccessOf, processes multiple input elements in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable, Executor).
<T> Cffu<Void>	parAcceptAsync(Iterable<? extends T> elements, Consumer<? super T> action)	Shortcut to method allResultsOf, processes multiple input elements in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor CffuFactory.defaultExecutor().
<T> Cffu<Void>	parAcceptAsync(Iterable<? extends T> elements, Consumer<? super T> action, Executor executor)	Shortcut to method allResultsOf, processes multiple input elements in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable, Executor).
<T> Cffu<Void>	parAcceptFailFastAsync(Iterable<? extends T> elements, Consumer<? super T> action)	Shortcut to method allResultsFailFastOf, processes multiple input elements in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor CffuFactory.defaultExecutor().
<T> Cffu<Void>	parAcceptFailFastAsync(Iterable<? extends T> elements, Consumer<? super T> action, Executor executor)	Shortcut to method allResultsFailFastOf, processes multiple input elements in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable, Executor).
<T, U> MCffu<U,List<U>>	parApplyAllSuccessAsync(Iterable<? extends T> elements, U valueIfFailed, Function<? super T,? extends U> fn)	Shortcut to method allSuccessResultsOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor CffuFactory.defaultExecutor().
<T, U> MCffu<U,List<U>>	parApplyAllSuccessAsync(Iterable<? extends T> elements, U valueIfFailed, Function<? super T,? extends U> fn, Executor executor)	Shortcut to method allSuccessResultsOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).
<T, U> Cffu<U>	parApplyAnyAsync(Iterable<? extends T> elements, Function<? super T,? extends U> fn)	Shortcut to method anyOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor CffuFactory.defaultExecutor().
<T, U> Cffu<U>	parApplyAnyAsync(Iterable<? extends T> elements, Function<? super T,? extends U> fn, Executor executor)	Shortcut to method anyOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).
<T, U> Cffu<U>	parApplyAnySuccessAsync(Iterable<? extends T> elements, Function<? super T,? extends U> fn)	Shortcut to method anySuccessOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor CffuFactory.defaultExecutor().
<T, U> Cffu<U>	parApplyAnySuccessAsync(Iterable<? extends T> elements, Function<? super T,? extends U> fn, Executor executor)	Shortcut to method anySuccessOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).
<T, U> MCffu<U,List<U>>	parApplyAsync(Iterable<? extends T> elements, Function<? super T,? extends U> fn)	Shortcut to method allResultsOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor CffuFactory.defaultExecutor().
<T, U> MCffu<U,List<U>>	parApplyAsync(Iterable<? extends T> elements, Function<? super T,? extends U> fn, Executor executor)	Shortcut to method allResultsOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).
<T, U> MCffu<U,List<U>>	parApplyFailFastAsync(Iterable<? extends T> elements, Function<? super T,? extends U> fn)	Shortcut to method allResultsFailFastOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor CffuFactory.defaultExecutor().
<T, U> MCffu<U,List<U>>	parApplyFailFastAsync(Iterable<? extends T> elements, Function<? super T,? extends U> fn, Executor executor)	Shortcut to method allResultsFailFastOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier, Executor).
<T, U> MCffu<U,List<U>>	parApplyMostSuccessAsync(Iterable<? extends T> elements, U valueIfNotSuccess, long timeout, TimeUnit unit, Function<? super T,? extends U> fn)	Shortcut to method mostSuccessResultsOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor CffuFactory.defaultExecutor().
<T, U> MCffu<U,List<U>>	parApplyMostSuccessAsync(Iterable<? extends T> elements, U valueIfNotSuccess, long timeout, TimeUnit unit, Function<? super T,? extends U> fn, Executor executor)	Shortcut to method mostSuccessResultsOf, processes multiple input elements 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

parApplyFailFastAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `parAcceptAsync`")
public <T,
U> MCffu<U,List<U>> parApplyFailFastAsync(Iterable<? extends T> elements,
 Function<? super T,? extends U> fn)

Shortcut to method allResultsFailFastOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor CffuFactory.defaultExecutor().

See the allResultsFailFastOf documentation for the rules of result computation.

parApplyFailFastAsync

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

Shortcut to method allResultsFailFastOf, processes multiple input elements 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.

parApplyAllSuccessAsync

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

Shortcut to method allSuccessResultsOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor CffuFactory.defaultExecutor().

See the allSuccessResultsOf documentation for the rules of result computation.

parApplyAllSuccessAsync

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

Shortcut to method allSuccessResultsOf, processes multiple input elements 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.

parApplyMostSuccessAsync

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

Shortcut to method mostSuccessResultsOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor CffuFactory.defaultExecutor().

See the mostSuccessResultsOf documentation for the rules of result computation.

parApplyMostSuccessAsync

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

Shortcut to method mostSuccessResultsOf, processes multiple input elements 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.

parApplyAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `parAcceptAsync`")
public <T,
U> MCffu<U,List<U>> parApplyAsync(Iterable<? extends T> elements,
 Function<? super T,? extends U> fn)

Shortcut to method allResultsOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor CffuFactory.defaultExecutor().

See the allResultsOf documentation for the rules of result computation.

parApplyAsync

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

Shortcut to method allResultsOf, processes multiple input elements 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.

parApplyAnySuccessAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `parAcceptAsync`")
public <T,
U> Cffu<U> parApplyAnySuccessAsync(Iterable<? extends T> elements,
 Function<? super T,? extends U> fn)

Shortcut to method anySuccessOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor CffuFactory.defaultExecutor().

See the anySuccessOf documentation for the rules of result computation.

parApplyAnySuccessAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `parAcceptAsync`")
public <T,
U> Cffu<U> parApplyAnySuccessAsync(Iterable<? extends T> elements,
 Function<? super T,? extends U> fn,
 Executor executor)

Shortcut to method anySuccessOf, processes multiple input elements 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.

parApplyAnyAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `parAcceptAsync`")
public <T,
U> Cffu<U> parApplyAnyAsync(Iterable<? extends T> elements,
 Function<? super T,? extends U> fn)

Shortcut to method anyOf, processes multiple input elements in parallel by wrapping each element's function computation into a Cffu using CffuFactory.supplyAsync(Supplier) with the executor CffuFactory.defaultExecutor().

See the anyOf documentation for the rules of result computation.

parApplyAnyAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `parAcceptAsync`")
public <T,
U> Cffu<U> parApplyAnyAsync(Iterable<? extends T> elements,
 Function<? super T,? extends U> fn,
 Executor executor)

Shortcut to method anyOf, processes multiple input elements 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.

parAcceptFailFastAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `parAcceptAsync`")
public <T> Cffu<Void> parAcceptFailFastAsync(Iterable<? extends T> elements,
 Consumer<? super T> action)

Shortcut to method allResultsFailFastOf, processes multiple input elements in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor CffuFactory.defaultExecutor().

See the allResultsFailFastOf documentation for the rules of result computation.

parAcceptFailFastAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `parAcceptAsync`")
public <T> Cffu<Void> parAcceptFailFastAsync(Iterable<? extends T> elements,
 Consumer<? super T> action,
 Executor executor)

Shortcut to method allResultsFailFastOf, processes multiple input elements 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.

parAcceptAsync

public <T> Cffu<Void> parAcceptAsync(Iterable<? extends T> elements,
 Consumer<? super T> action)

Shortcut to method allResultsOf, processes multiple input elements in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor CffuFactory.defaultExecutor().

See the allResultsOf documentation for the rules of result computation.

parAcceptAsync

public <T> Cffu<Void> parAcceptAsync(Iterable<? extends T> elements,
 Consumer<? super T> action,
 Executor executor)

Shortcut to method allResultsOf, processes multiple input elements 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.

parAcceptAnySuccessAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `parAcceptAsync`")
public <T> Cffu<Void> parAcceptAnySuccessAsync(Iterable<? extends T> elements,
 Consumer<? super T> action)

Shortcut to method anySuccessOf, processes multiple input elements in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor CffuFactory.defaultExecutor().

See the anySuccessOf documentation for the rules of result computation.

parAcceptAnySuccessAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `parAcceptAsync`")
public <T> Cffu<Void> parAcceptAnySuccessAsync(Iterable<? extends T> elements,
 Consumer<? super T> action,
 Executor executor)

Shortcut to method anySuccessOf, processes multiple input elements 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.

parAcceptAnyAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `parAcceptAsync`")
public <T> Cffu<Void> parAcceptAnyAsync(Iterable<? extends T> elements,
 Consumer<? super T> action)

Shortcut to method anyOf, processes multiple input elements in parallel by wrapping each element's consumer computation into a Cffu using CffuFactory.runAsync(Runnable) with the executor CffuFactory.defaultExecutor().

See the anyOf documentation for the rules of result computation.

parAcceptAnyAsync

@CheckReturnValue(explanation="should use the returned Cffu; otherwise, prefer simple method `parAcceptAsync`")
public <T> Cffu<Void> parAcceptAnyAsync(Iterable<? extends T> elements,
 Consumer<? super T> action,
 Executor executor)

Shortcut to method anyOf, processes multiple input elements 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.