Traitement séquentiel des événements via executorservice

Question

J'ai une file d'attente d'événements à traiter. Un thread ajoute des événements à la file d'attente.
J'ai créé une tâche exécutable qui dans la méthode run fait tout ce qui est nécessaire pour traiter l'événement.
J'ai déclaré Executors.newCachedThreadPool(); et I execute chaque tâche.

 public class EventHandler { 

      private static final ExecutorService handlers = Executors.newCachedThreadPool(); 

      public void handleNextEvent(AnEvent event){ 

        handlers.execute(new Task(evt)); 

      } 


     public class Task implements Runnable{ 

     @Override 
      public void run() { 
      //Event processing 
      } 
     } 

public AnotherClass{  
    public void passEvent(AnEvent evt)//This is called by another thread 
    { 
     EventHandler.handleNextEvent(evt); 

    } 
} 

Mon problème est que si je l'appelle execute de l'exécuteur testamentaire, mon code obtiendra le prochain événement et exécuter suivant runnable par l'exécuteur testamentaire. Mon but est de traiter l'événement suivant de la file d'attente seulement après la fin de la tâche précédente.
Comment saurais-je que la tâche précédente est terminée ou non pour que je sache que je peux encore appeler handleNextEvent?
La mise à jour d'un champ de statut par la tâche est-elle une bonne idée?

Merci

Answer 1

Executors.newCachedThreadPool() créera de nouvelles discussions sur la demande, il est donc pas ce que vous voulez. Vous voulez quelque chose comme Executors.newSingleThreadExecutor(), qui va traiter les événements un à la fois, et faire la queue le reste.

Voir javadoc:

Crée un Executor qui utilise un seul thread de travail opérant au large d'une file d'attente sans bornes. (Notez cependant que si ce thread unique se termine en raison d'un échec lors de l'exécution avant l'arrêt, un nouveau prendra sa place si nécessaire pour exécuter les tâches suivantes.) Les tâches sont garanties séquentiellement, et pas plus d'une tâche sera active n'importe quand.

Answer 2

Je pense Executors.newSingleThreadExecutor() et la submit() méthode sont la solution à votre problème: http://download.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/ExecutorService.html