net.thevpc.nuts.runtime.standalone.concurrent

Class NTaskSetImpl

java.lang.Object

net.thevpc.nuts.runtime.standalone.concurrent.NTaskSetImpl

All Implemented Interfaces:

NTaskSet

public class NTaskSetImpl
extends Object
implements NTaskSet

Constructor Summary

Constructors

Constructor and Description
NTaskSetImpl()

Method Summary

Modifier and Type	Method and Description
NTaskSet	add(CompletableFuture<?> future)
NTaskSet	add(Future<?> future)
NTaskSet	add(String taskId, CompletableFuture<?> future)
NTaskSet	add(String taskId, Future<?> future)
NTaskSet	call(Callable<?> task)
NTaskSet	call(Callable<?> task, ExecutorService exec)
NTaskSet	call(NCallable<?> task)
NTaskSet	call(NCallable<?> task, ExecutorService exec)
NTaskSet	call(String taskId, Callable<?> task)
NTaskSet	call(String taskId, Callable<?> task, ExecutorService exec)
NTaskSet	cancelAll(boolean mayInterrupt)
NTaskSet	clear()
List<Throwable>	errors()
NTaskSet	executorService(ExecutorService executor)
<T> T	first()
<T> T	first(boolean cancelOthers)
<T> NOptional<NTaskResult<T>>	firstMatch(Predicate<NTaskResult<T>> predicate, boolean cancelOthers)
<T> CompletableFuture<NOptional<NTaskResult<T>>>	firstMatchAsync(Predicate<NTaskResult<T>> predicate, boolean cancelOthers)
<T> T	firstOnly()
List<CompletableFuture<?>>	futures()
<T> List<CompletableFuture<T>>	futures(Class<T> type)
boolean	hasError()
boolean	isDone()
NTaskSet	join()
NTaskSet	requireAll()
<T> List<NTaskResult<T>>	results()
<T> List<NTaskResult<T>>	results(Class<T> type)
NTaskSet	run(Runnable task)
NTaskSet	run(Runnable task, ExecutorService exec)
NTaskSet	run(String taskId, Runnable task)
NTaskSet	run(String taskId, Runnable task, ExecutorService executor)
NTaskSet	supply(String taskId, Supplier<?> supplier)
NTaskSet	supply(String taskId, Supplier<?> supplier, ExecutorService executor)
NTaskSet	supply(Supplier<?> supplier)
NTaskSet	supply(Supplier<?> supplier, ExecutorService exec)

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.thevpc.nuts.concurrent.NTaskSet

of

Constructor Detail

NTaskSetImpl

public NTaskSetImpl()

Method Detail

executorService

public NTaskSet executorService(ExecutorService executor)

Specified by:

executorService in interface NTaskSet

add

public NTaskSet add(Future<?> future)

Specified by:

add in interface NTaskSet

add

public NTaskSet add(String taskId,
                    Future<?> future)

Specified by:

add in interface NTaskSet

add

public NTaskSet add(CompletableFuture<?> future)

Specified by:

add in interface NTaskSet

add

public NTaskSet add(String taskId,
                    CompletableFuture<?> future)

Specified by:

add in interface NTaskSet

supply

public NTaskSet supply(Supplier<?> supplier)

Specified by:

supply in interface NTaskSet

supply

public NTaskSet supply(String taskId,
                       Supplier<?> supplier)

Specified by:

supply in interface NTaskSet

supply

public NTaskSet supply(Supplier<?> supplier,
                       ExecutorService exec)

Specified by:

supply in interface NTaskSet

supply

public NTaskSet supply(String taskId,
                       Supplier<?> supplier,
                       ExecutorService executor)

Specified by:

supply in interface NTaskSet

run

public NTaskSet run(Runnable task)

Specified by:

run in interface NTaskSet

run

public NTaskSet run(String taskId,
                    Runnable task)

Specified by:

run in interface NTaskSet

run

public NTaskSet run(Runnable task,
                    ExecutorService exec)

Specified by:

run in interface NTaskSet

run

public NTaskSet run(String taskId,
                    Runnable task,
                    ExecutorService executor)

Specified by:

run in interface NTaskSet

call

public NTaskSet call(Callable<?> task)

Specified by:

call in interface NTaskSet

call

public NTaskSet call(String taskId,
                     Callable<?> task)

Specified by:

call in interface NTaskSet

call

public NTaskSet call(Callable<?> task,
                     ExecutorService exec)

Specified by:

call in interface NTaskSet

call

public NTaskSet call(String taskId,
                     Callable<?> task,
                     ExecutorService exec)

Specified by:

call in interface NTaskSet

call

public NTaskSet call(NCallable<?> task)

Specified by:

call in interface NTaskSet

call

public NTaskSet call(NCallable<?> task,
                     ExecutorService exec)

Specified by:

call in interface NTaskSet

join

public NTaskSet join()

Specified by:

join in interface NTaskSet

first

public <T> T first()

Specified by:

first in interface NTaskSet

first

public <T> T first(boolean cancelOthers)

Specified by:

first in interface NTaskSet

firstOnly

public <T> T firstOnly()

Specified by:

firstOnly in interface NTaskSet

futures

public <T> List<CompletableFuture<T>> futures(Class<T> type)

Specified by:

futures in interface NTaskSet

futures

public List<CompletableFuture<?>> futures()

Specified by:

futures in interface NTaskSet

results

public <T> List<NTaskResult<T>> results()

Specified by:

results in interface NTaskSet

results

public <T> List<NTaskResult<T>> results(Class<T> type)

Specified by:

results in interface NTaskSet

errors

public List<Throwable> errors()

Specified by:

errors in interface NTaskSet

isDone

public boolean isDone()

Specified by:

isDone in interface NTaskSet

hasError

public boolean hasError()

Specified by:

hasError in interface NTaskSet

cancelAll

public NTaskSet cancelAll(boolean mayInterrupt)

Specified by:

cancelAll in interface NTaskSet

clear

public NTaskSet clear()

Specified by:

clear in interface NTaskSet

requireAll

public NTaskSet requireAll()

Specified by:

requireAll in interface NTaskSet

firstMatch

public <T> NOptional<NTaskResult<T>> firstMatch(Predicate<NTaskResult<T>> predicate,
                                                boolean cancelOthers)

Specified by:

firstMatch in interface NTaskSet

firstMatchAsync

public <T> CompletableFuture<NOptional<NTaskResult<T>>> firstMatchAsync(Predicate<NTaskResult<T>> predicate,
                                                                        boolean cancelOthers)

Specified by:

firstMatchAsync in interface NTaskSet