net.thevpc.nuts.runtime.standalone.concurrent

Class NTaskSetImpl

java.lang.Object

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

All Implemented Interfaces:

net.thevpc.nuts.concurrent.NTaskSet

public class NTaskSetImpl
extends Object
implements net.thevpc.nuts.concurrent.NTaskSet

Constructor Summary

Constructors

Constructor and Description
NTaskSetImpl()

Method Summary

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

Specified by:

executorService in interface net.thevpc.nuts.concurrent.NTaskSet

add

public net.thevpc.nuts.concurrent.NTaskSet add(Future<?> future)

Specified by:

add in interface net.thevpc.nuts.concurrent.NTaskSet

add

public net.thevpc.nuts.concurrent.NTaskSet add(String taskId,
                                               Future<?> future)

Specified by:

add in interface net.thevpc.nuts.concurrent.NTaskSet

add

public net.thevpc.nuts.concurrent.NTaskSet add(CompletableFuture<?> future)

Specified by:

add in interface net.thevpc.nuts.concurrent.NTaskSet

add

public net.thevpc.nuts.concurrent.NTaskSet add(String taskId,
                                               CompletableFuture<?> future)

Specified by:

add in interface net.thevpc.nuts.concurrent.NTaskSet

supply

public net.thevpc.nuts.concurrent.NTaskSet supply(Supplier<?> supplier)

Specified by:

supply in interface net.thevpc.nuts.concurrent.NTaskSet

supply

public net.thevpc.nuts.concurrent.NTaskSet supply(String taskId,
                                                  Supplier<?> supplier)

Specified by:

supply in interface net.thevpc.nuts.concurrent.NTaskSet

supply

public net.thevpc.nuts.concurrent.NTaskSet supply(Supplier<?> supplier,
                                                  ExecutorService exec)

Specified by:

supply in interface net.thevpc.nuts.concurrent.NTaskSet

supply

public net.thevpc.nuts.concurrent.NTaskSet supply(String taskId,
                                                  Supplier<?> supplier,
                                                  ExecutorService executor)

Specified by:

supply in interface net.thevpc.nuts.concurrent.NTaskSet

run

public net.thevpc.nuts.concurrent.NTaskSet run(Runnable task)

Specified by:

run in interface net.thevpc.nuts.concurrent.NTaskSet

run

public net.thevpc.nuts.concurrent.NTaskSet run(String taskId,
                                               Runnable task)

Specified by:

run in interface net.thevpc.nuts.concurrent.NTaskSet

run

public net.thevpc.nuts.concurrent.NTaskSet run(Runnable task,
                                               ExecutorService exec)

Specified by:

run in interface net.thevpc.nuts.concurrent.NTaskSet

run

public net.thevpc.nuts.concurrent.NTaskSet run(String taskId,
                                               Runnable task,
                                               ExecutorService executor)

Specified by:

run in interface net.thevpc.nuts.concurrent.NTaskSet

call

public net.thevpc.nuts.concurrent.NTaskSet call(Callable<?> task)

Specified by:

call in interface net.thevpc.nuts.concurrent.NTaskSet

call

public net.thevpc.nuts.concurrent.NTaskSet call(String taskId,
                                                Callable<?> task)

Specified by:

call in interface net.thevpc.nuts.concurrent.NTaskSet

call

public net.thevpc.nuts.concurrent.NTaskSet call(Callable<?> task,
                                                ExecutorService exec)

Specified by:

call in interface net.thevpc.nuts.concurrent.NTaskSet

call

public net.thevpc.nuts.concurrent.NTaskSet call(String taskId,
                                                Callable<?> task,
                                                ExecutorService exec)

Specified by:

call in interface net.thevpc.nuts.concurrent.NTaskSet

call

public net.thevpc.nuts.concurrent.NTaskSet call(net.thevpc.nuts.concurrent.NCallable<?> task)

Specified by:

call in interface net.thevpc.nuts.concurrent.NTaskSet

call

public net.thevpc.nuts.concurrent.NTaskSet call(net.thevpc.nuts.concurrent.NCallable<?> task,
                                                ExecutorService exec)

Specified by:

call in interface net.thevpc.nuts.concurrent.NTaskSet

join

public net.thevpc.nuts.concurrent.NTaskSet join()

Specified by:

join in interface net.thevpc.nuts.concurrent.NTaskSet

first

public <T> T first()

Specified by:

first in interface net.thevpc.nuts.concurrent.NTaskSet

first

public <T> T first(boolean cancelOthers)

Specified by:

first in interface net.thevpc.nuts.concurrent.NTaskSet

firstOnly

public <T> T firstOnly()

Specified by:

firstOnly in interface net.thevpc.nuts.concurrent.NTaskSet

futures

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

Specified by:

futures in interface net.thevpc.nuts.concurrent.NTaskSet

futures

public List<CompletableFuture<?>> futures()

Specified by:

futures in interface net.thevpc.nuts.concurrent.NTaskSet

results

public <T> List<net.thevpc.nuts.concurrent.NTaskResult<T>> results()

Specified by:

results in interface net.thevpc.nuts.concurrent.NTaskSet

results

public <T> List<net.thevpc.nuts.concurrent.NTaskResult<T>> results(Class<T> type)

Specified by:

results in interface net.thevpc.nuts.concurrent.NTaskSet

errors

public List<Throwable> errors()

Specified by:

errors in interface net.thevpc.nuts.concurrent.NTaskSet

isDone

public boolean isDone()

Specified by:

isDone in interface net.thevpc.nuts.concurrent.NTaskSet

hasError

public boolean hasError()

Specified by:

hasError in interface net.thevpc.nuts.concurrent.NTaskSet

cancelAll

public net.thevpc.nuts.concurrent.NTaskSet cancelAll(boolean mayInterrupt)

Specified by:

cancelAll in interface net.thevpc.nuts.concurrent.NTaskSet

clear

public net.thevpc.nuts.concurrent.NTaskSet clear()

Specified by:

clear in interface net.thevpc.nuts.concurrent.NTaskSet

requireAll

public net.thevpc.nuts.concurrent.NTaskSet requireAll()

Specified by:

requireAll in interface net.thevpc.nuts.concurrent.NTaskSet

firstMatch

public <T> net.thevpc.nuts.util.NOptional<net.thevpc.nuts.concurrent.NTaskResult<T>> firstMatch(Predicate<net.thevpc.nuts.concurrent.NTaskResult<T>> predicate,
                                                                                                boolean cancelOthers)

Specified by:

firstMatch in interface net.thevpc.nuts.concurrent.NTaskSet

firstMatchAsync

public <T> CompletableFuture<net.thevpc.nuts.util.NOptional<net.thevpc.nuts.concurrent.NTaskResult<T>>> firstMatchAsync(Predicate<net.thevpc.nuts.concurrent.NTaskResult<T>> predicate,
                                                                                                                        boolean cancelOthers)

Specified by:

firstMatchAsync in interface net.thevpc.nuts.concurrent.NTaskSet