java.lang.Object
org.jgrapht.util.ConcurrencyUtil
public class ConcurrencyUtil
extends java.lang.Object
Utility class to manage creation and shutting down instance of the
ThreadPoolExecutor
.-
Constructor Summary
Constructors Constructor Description ConcurrencyUtil()
-
Method Summary
Modifier and Type Method Description static java.util.concurrent.ThreadPoolExecutor
createThreadPoolExecutor(int parallelism)
Creates aThreadPoolExecutor
with fixed number of threads which is equal toparallelism
.static void
shutdownExecutionService(java.util.concurrent.ExecutorService service)
Shuts down theexecutor
.static void
shutdownExecutionService(java.util.concurrent.ExecutorService service, long time, java.util.concurrent.TimeUnit timeUnit)
Shuts down theexecutor
.
-
Constructor Details
-
ConcurrencyUtil
public ConcurrencyUtil()
-
-
Method Details
-
createThreadPoolExecutor
public static java.util.concurrent.ThreadPoolExecutor createThreadPoolExecutor(int parallelism)Creates aThreadPoolExecutor
with fixed number of threads which is equal toparallelism
.- Parameters:
parallelism
- number of thread for the executor- Returns:
- created executor
-
shutdownExecutionService
public static void shutdownExecutionService(java.util.concurrent.ExecutorService service) throws java.lang.InterruptedExceptionShuts down theexecutor
. This operation puts theservice
into a state where every subsequent task submitted to theservice
will be rejected. This method callsshutdownExecutionService(ExecutorService, long, TimeUnit)
with $time = Long.MAX_VALUE$ and $timeUnit = TimeUnit.MILLISECONDS$.- Parameters:
service
- service to be shut down- Throws:
java.lang.InterruptedException
-
shutdownExecutionService
public static void shutdownExecutionService(java.util.concurrent.ExecutorService service, long time, java.util.concurrent.TimeUnit timeUnit) throws java.lang.InterruptedExceptionShuts down theexecutor
. This operation puts theservice
into a state where every subsequent task submitted to theservice
will be rejected.- Parameters:
service
- service to be shut downtime
- period of time to wait for the completion of the terminationtimeUnit
- time duration granularity for the providedtime
- Throws:
java.lang.InterruptedException
-