ThreadPool ist Executor wie Polling ist?

Question

Javas Executor ist (so weit ich es verstehe) eine Abstraktion über das ThreadPool-Konzept - etwas, das Aufgaben annehmen und ausführen kann.

Ich bin auf der Suche nach einer ähnlichen Ausnahme für das Polling-Konzept. Ich muss fortlaufend Elemente aus einer bestimmten Warteschlange abfragen (die implementiert nichtBlockingQueue), führen Sie sie aus und Ruhezustand, und wiederholen Sie alles bis zum Herunterfahren.

Gibt es eine fertige Abstraktion oder sollte ich etwas selbst schreiben?

(Vorschläge einer besseren Titel sind willkommen)

Answer 1

Polling ist einfach:

Thread t = new Thread(new Runnable() { 
    public void run() { 
     try { 
      while (!t.isInterrupted()) { 
       Object item; 
       while ((item = queue.take()) == null) {//does not block 
        synchronized (lock) { lock.wait(1000L) } //spin on a lock 
       } 
       //item is not null 
       handle(item); 
      } 
     } catch (InterruptedException e) { } 
    } 
}); 
t.start(); 

Vielleicht müssen Sie Ihre Frage neu zu formulieren, wie ich genau bin nicht ganz sicher, was es ist, dass Sie versuchen, machen?