Package io.inugami.commons.threads

Class RunAndCloseService<T>

java.lang.Object

io.inugami.commons.threads.RunAndCloseService<T>

All Implemented Interfaces:

ThreadFactory

public class RunAndCloseService<T>
extends Object
implements ThreadFactory

ThreadsExecutor

Since:

24 mars 2018

Constructor Summary

Constructors

Constructor	Description
RunAndCloseService(String threadsName, long timeout, int nbThreads, Callable<T>... tasks)
RunAndCloseService(String threadsName, long timeout, int nbThreads, BiFunction<Exception,Callable<T>,T> onError, Callable<T>... tasks)
RunAndCloseService(String threadsName, long timeout, int nbThreads, List<Callable<T>> tasks)
RunAndCloseService(String threadsName, long timeout, int nbThreads, List<Callable<T>> tasks, BiFunction<Exception,Callable<T>,T> onError)

Method Summary

Modifier and Type	Method	Description
void	forceShutdown()
Thread	newThread(Runnable runnable)
List<T>	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

RunAndCloseService

@SafeVarargs
public RunAndCloseService(String threadsName,
                          long timeout,
                          int nbThreads,
                          BiFunction<Exception,Callable<T>,T> onError,
                          Callable<T>... tasks)

RunAndCloseService

@SafeVarargs
public RunAndCloseService(String threadsName,
                          long timeout,
                          int nbThreads,
                          Callable<T>... tasks)

RunAndCloseService

public RunAndCloseService(String threadsName,
                          long timeout,
                          int nbThreads,
                          List<Callable<T>> tasks)

RunAndCloseService

public RunAndCloseService(String threadsName,
                          long timeout,
                          int nbThreads,
                          List<Callable<T>> tasks,
                          BiFunction<Exception,Callable<T>,T> onError)

Method Detail

run

public List<T> run()

newThread

public Thread newThread(Runnable runnable)

Specified by:

newThread in interface ThreadFactory

forceShutdown

public void forceShutdown()