Package io.inugami.commons.threads

Class ThreadsExecutorService

java.lang.Object

io.inugami.commons.threads.ThreadsExecutorService

All Implemented Interfaces:

LifecycleBootstrap

public class ThreadsExecutorService
extends Object
implements LifecycleBootstrap

ThreadsExecutorService

Since:

13 janv. 2017

Constructor Summary

Constructors

Constructor	Description
ThreadsExecutorService(String name, int maxThreads)
ThreadsExecutorService(String name, int maxThreads, boolean deamon)
ThreadsExecutorService(String name, int maxThreads, boolean deamon, Long timeout)

Method Summary

Modifier and Type	Method	Description
<T> CompletableFuture<T>	buildFuture(Callable<T> taskToProcess)
<T> CompletableFuture<T>	buildFuture(Callable<T> taskToProcess, BiConsumer<T,Callable<T>> onDone)
<T> CompletableFuture<T>	buildFuture(Callable<T> taskToProcess, BiConsumer<T,Callable<T>> onDone, BiConsumer<Exception,Callable<T>> onError)
ExecutorService	getExecutor()
<T> List<CompletableFuture<T>>	run(List<Callable<T>> tasks)
<T> List<CompletableFuture<T>>	run(List<Callable<T>> tasks, BiConsumer<T,Callable<T>> onDone)
<T> List<CompletableFuture<T>>	run(List<Callable<T>> tasks, BiConsumer<T,Callable<T>> onDone, BiConsumer<Exception,Callable<T>> onError)
<T> List<T>	runAndGrab(List<Callable<T>> tasks, long timeout)
<T> List<T>	runAndGrab(List<Callable<T>> tasks, BiConsumer<T,Callable<T>> onDone, long timeout)
<T> List<T>	runAndGrab(List<Callable<T>> tasks, BiConsumer<T,Callable<T>> onDone, BiConsumer<Exception,Callable<T>> onError, long timeout)
void	shutdown()
void	start()
<T> Future<T>	submit(String name, Callable<T> task)
<T> Future<T>	submit(String name, Callable<T> task, TaskFinishListener listener)
<T> Future<T>	submit(String name, Callable<T> task, TaskFinishListener finishListner, TaskStartListener startListner)
<T> void	waitting(List<CompletableFuture<T>> futures, long timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadsExecutorService

public ThreadsExecutorService(String name,
                              int maxThreads)

ThreadsExecutorService

public ThreadsExecutorService(String name,
                              int maxThreads,
                              boolean deamon)

ThreadsExecutorService

public ThreadsExecutorService(String name,
                              int maxThreads,
                              boolean deamon,
                              Long timeout)

Method Detail

run

public <T> List<CompletableFuture<T>> run(List<Callable<T>> tasks)

run

public <T> List<CompletableFuture<T>> run(List<Callable<T>> tasks,
                                          BiConsumer<T,Callable<T>> onDone)

run

public <T> List<CompletableFuture<T>> run(List<Callable<T>> tasks,
                                          BiConsumer<T,Callable<T>> onDone,
                                          BiConsumer<Exception,Callable<T>> onError)

runAndGrab

public <T> List<T> runAndGrab(List<Callable<T>> tasks,
                              long timeout)
                       throws TechnicalException

Throws:

TechnicalException

runAndGrab

public <T> List<T> runAndGrab(List<Callable<T>> tasks,
                              BiConsumer<T,Callable<T>> onDone,
                              long timeout)
                       throws TechnicalException

Throws:

TechnicalException

runAndGrab

public <T> List<T> runAndGrab(List<Callable<T>> tasks,
                              BiConsumer<T,Callable<T>> onDone,
                              BiConsumer<Exception,Callable<T>> onError,
                              long timeout)
                       throws TechnicalException

Throws:

TechnicalException

waitting

public <T> void waitting(List<CompletableFuture<T>> futures,
                         long timeout)
                  throws TechnicalException

Throws:

TechnicalException

buildFuture

public <T> CompletableFuture<T> buildFuture(Callable<T> taskToProcess)

buildFuture

public <T> CompletableFuture<T> buildFuture(Callable<T> taskToProcess,
                                            BiConsumer<T,Callable<T>> onDone)

buildFuture

public <T> CompletableFuture<T> buildFuture(Callable<T> taskToProcess,
                                            BiConsumer<T,Callable<T>> onDone,
                                            BiConsumer<Exception,Callable<T>> onError)

submit

public <T> Future<T> submit(String name,
                            Callable<T> task)

submit

public <T> Future<T> submit(String name,
                            Callable<T> task,
                            TaskFinishListener listener)

submit

public <T> Future<T> submit(String name,
                            Callable<T> task,
                            TaskFinishListener finishListner,
                            TaskStartListener startListner)

start

public void start()

Specified by:

start in interface LifecycleBootstrap

shutdown

public void shutdown()

Specified by:

shutdown in interface LifecycleBootstrap

getExecutor

public ExecutorService getExecutor()