Comment mettre en œuvre un ExecutorService pour exécuter des tâches sur une rotation de base?

La réponse est plus liée à la mise en œuvre de la file d'attente de travail utilisé pour l'instance de ExecutorService. Donc, je vous suggère de:

1. Choisissez d'abord une mise en œuvre de java.util.de façon concomitante.BlockingQueue (un exemple) qui fournit une file d'attente circulaire fonctionnalité. NOTE, la raison BlockingQueue a été choisi, c'est que pour attendre jusqu'à la prochaine tâche de la file d'attente; ainsi, en cas de circulaire + blocage file d'attente, vous devez être prudent sur la manière de fournir le même comportement et la fonctionnalité.

2. Au lieu d'utiliser Executors.new... pour créer un nouveau ThreadPoolExecutor utiliser un direct constructeur comme

public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)

De cette façon, à moins que vous commande l'exécuteur de shutdown, il va essayer de récupérer la tâche suivante de la file d'attente pour l'exécution de ses file d'attente de travail qui est un circulaire conteneur pour les tâches.

Vous pouvez simplement vérifier que toutes les tâches ont été exécutées et les soumettre de nouveau une fois que c'est le cas, comme ceci par exemple:

    List<Future> futures = new ArrayList<>();
for (Runnable task : myTasks) {
futures.add(threadPoolService.submit(task));
}
//wait until completion of all tasks
for (Future f : futures) {
f.get();
}
//restart
......

MODIFIER

Il semble que vous voulez soumettre une tâche dès qu'il est achevé. Vous pouvez utiliser un ExecutorCompletionService qui vous permet de récupérer des tâches lorsqu'elles sont exécutées, - voir ci-dessous un exemple simple avec 2 tâches que soumis de nouveau à quelques reprises dès qu'ils sont terminés. Exemple de sortie:

Tâche 1 soumis pool-1-thread-1

Tâche 2 soumis pool-1-thread-2

Tâche 1 terminé pool-1-thread-1

Tâche 1 soumis pool-1-thread-3

Tâche 2 terminé pool-1-thread-2

Tâche 1 terminé pool-1-thread-3

Tâche 2 soumis pool-1-thread-4

Tâche 1 soumis pool-1-thread-5

Tâche 1 terminé pool-1-thread-5

Tâche 2 terminé pool-1-thread-4

public class Test1 {
public final ConcurrentMap<String, String> concurrentMap = new ConcurrentHashMap<>();
public final AtomicInteger retries = new AtomicInteger();
public final Object lock = new Object();
public static void main(String[] args) throws InterruptedException, ExecutionException {
int count = 0;
List<Runnable> myTasks = new ArrayList<>();
myTasks.add(getRunnable(1));
myTasks.add(getRunnable(2));
ExecutorService threadPoolService = Executors.newFixedThreadPool(10);
CompletionService<Runnable> ecs = new ExecutorCompletionService<Runnable>(threadPoolService);
for (Runnable task : myTasks) {
ecs.submit(task, task);
}
//wait until completion of all tasks
while(count++ < 3) {
Runnable task = ecs.take().get();
ecs.submit(task, task);
}
threadPoolService.shutdown();
}
private static Runnable getRunnable(final int i) {
return new Runnable() {
@Override
public void run() {
System.out.println("Task " + i + " submitted " + Thread.currentThread().getName() + "  ");
try {
Thread.sleep(500 * i);
} catch (InterruptedException ex) {
System.out.println("Interrupted");
}
System.out.println("Task " + i + " completed " + Thread.currentThread().getName() + "  ");
}
};
}
}