io.sarl.sre.services.executor

Class JreExecutorUtils

java.lang.Object

io.sarl.sre.services.executor.JreExecutorUtils

public final class JreExecutorUtils
extends Object

Utilities for running tasks on the standard JRE executor service.

Since:

0.11

Version:

io.janusproject.plugin 0.12.0 20210527-171007

Author:

Stéphane Galland

Maven Group Id:

io.janusproject.sre

Maven Artifact Id:

io.janusproject.plugin

Method Summary

Modifier and Type	Method and Description
static void	executeInThreadsAndWait(executorService : ExecutorService, tasks : Collection<Runnable>, interceptExceptions : boolean, wrapper : (Boolean,Runnable)=>Runnable) Execute the given tasks in parallel and wait for the termination.
static int	executeInThreadsAndWait(executorService : ExecutorService, task : SreRunnable, nbExecutions : int, runGroupSize : int) Execute the given task in parallel and wait for the termination.
static void	executeInThreadsWithoutWaiting(executorService : ExecutorService, task : SreRunnable, nbExecutions : int, runGroupSize : int) Execute the given task in parallel but do not wait for the termination.

Methods inherited from class java.lang.Object

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

Method Detail

executeInThreadsAndWait

public static def executeInThreadsAndWait(executorService : ExecutorService,
                                          tasks : Collection<Runnable>,
                                          interceptExceptions : boolean,
                                          wrapper : (Boolean,Runnable)=>Runnable) : void 

Description copied from class: JreExecutorUtils

Execute the given tasks in parallel and wait for the termination.

Parameters:

executorService - the service to use.

tasks - the tasks to run.

interceptExceptions - indicates if the exceptions in the tasks are thrown into a combined exception.

a - callback for wrapping the tasks. The first argument of the lambda indicates if the errors should be catched and the second argument is the task to run.

executeInThreadsAndWait

public static def executeInThreadsAndWait(executorService : ExecutorService,
                                          task : SreRunnable,
                                          nbExecutions : int,
                                          runGroupSize : int) : int 

Description copied from class: JreExecutorUtils

Execute the given task in parallel and wait for the termination.

Parameters:

executorService - the service to use.

task - the task to run.

nbExecutions - number of runs

runGroupSize - the size of a parallel group

executeInThreadsWithoutWaiting

public static def executeInThreadsWithoutWaiting(executorService : ExecutorService,
                                                 task : SreRunnable,
                                                 nbExecutions : int,
                                                 runGroupSize : int) : void 

Description copied from class: JreExecutorUtils

Execute the given task in parallel but do not wait for the termination.

Parameters:

executorService - the service to use.

task - the task to run.

nbExecutions - number of runs

runGroupSize - the size of a parallel group