Java: Set timeout pour les threads dans un pool de threads

Je veux définir les délais pour les threads qui sont exécutés à l'intérieur d'un pool de threads. Pour le moment j'ai code suivant:

ExecutorService executor = Executors.newFixedThreadPool(8);
for(List<String> l: partition) {            
    Runnable worker = new WorkerThread(l);
    executor.execute(worker);
}       

executor.shutdown();
while (!executor.isTerminated()) {

}

Le code divise une grande liste d'objets dans des sous-listes et les processus de ces sous-liste à l'intérieur d'un fils. Mais ce n'est pas le point.

Je veux donner à chaque seul thread dans le pool de threads d'un délai d'attente. Pour un seul thread à la piscine, j'ai trouvé la solution suivante:

Future<?> future = null;

for (List<String> l : partition) {
    Runnable worker = new WorkerThread(l);
    future = executor.submit(worker);
}

try {
    System.out.println("Started..");
    System.out.println(future.get(3, TimeUnit.SECONDS));
    System.out.println("Finished!");
} catch (TimeoutException e) {
    System.out.println("Terminated!");
}

Mais ce ne serait pas travailler pour plus d'un thread. Peut-être que je dois mettre chaque thread dans un List<Future> liste et de parcourir cette liste et définir un délai d'attente pour chaque future objet?

Des suggestions?

MODIFIER APRÈS l'UTILISATION de CountDownLatch:

CountDownLatch doneSignal = new CountDownLatch(partition.size());
List<Future<?>> tasks = new ArrayList<Future<?>>();
ExecutorService executor = Executors.newFixedThreadPool(8);
for (List<String> l : partition) {
    Runnable worker = new WorkerThread(l);
    tasks.add(executor.submit(doneSignal, worker));
}

doneSignal.await(1, TimeUnit.SECONDS);
if (doneSignal.getCount() > 0) {
    for (Future<?> fut : tasks) {
    if (!fut.isDone()) {
        System.out.println("Task " + fut + " has not finshed!");
        //fut.cancel(true) Maybe we can interrupt a thread this way?!
    }
    }
}

Fonctionne bien jusqu'à présent.

Alors, la prochaine question est de savoir comment interrompre un thread qui est expiré? J'essaie fut.cancel(true) et ajouter la suite de construire dans certaines critiques les boucles dans le thread de travail:

if(Thread.interrupted()) {
    System.out.println("!!Thread -> " + Thread.currentThread().getName() + " INTERRUPTED!!");
        return;
}

De sorte que le thread de travail est "tué" après l'expiration du délai. Est-ce une bonne solution?

En outre: Est-il possible d'obtenir le nom du thread qui a expiré au cours de la Future interface? Pour le moment j'ai l'impression de le nom dans la si la condition de la Thread.interrupted() construire.

Merci pour l'aide!

Ce qui concerne

OriginalL'auteur sk2212 | 2013-01-09