Laufende Agenten in "unendlichen" Schleife Threads ist falsch?

Question

Ich habe eine Web-Crawler, wo das Grundlayout ein Manager ist, die Agenten, die offene Verbindung ausgeführt wird, um den Inhalt holen und sie in einer Datenbank einzufügen.

Jede dieser Agenten ausgeführt werden in einem eigenen Thread in einer Schleife, bis der Benutzer ein Stoppsignal senden. Diese Agenten erhalten die Aufgaben vom Manager-Agenten.

Das Problem ist, wenn eine Ausnahme in einem Mittel erfolgt, kann sie nicht an die Schnittstelle throwed wird (es sei denn, ich einige Beobachter verwenden, um zu signalisieren, dass eine Ausnahme aufgetreten ist).

Ich denke, dass dieses Design falsch ist und die richtige ist eine endliche Aufgabe erstellen und setzen sie in den Executor (erstellen Sie eine Aufgabe für jede URL zu öffnen Verbindung, Inhalte abrufen oder in die Datenbank einfügen).

Ich bin richtig, dass mein aktuelles Design ist falsch und muss das Layout ändern? Was ist das richtige Layout für die Verwendung von Multi-Threading, wenn verschiedene Agenten unterschiedliche Teile des Jobs ausführen?

Answer 1

Ja, ich glaube, Sie sollten die Executors werden. Wenn Sie Callable Klassen einreichen, können Sie von Ihrer Spinne Agenten werfen und die zurück Future untersuchen, die die Ausnahme verursacht an den Auftraggeber geworfen werden, so kann es zu einem UI angemeldet oder angezeigt werden.

ExecutorService pool = Executors.newFixedThreadPool(10); 
Future<Void> future = pool.submit(new Callable<Void>() { 
    public Void call() throws Exception { 
     // your agent code goes here 
     // this can throw an exception in this block which will be re-thrown below 
     return null; 
    } 
}); 
... 
try { 
    // then the exception will be thrown here for you to catch and log 
    future.get(); 
} catch (ExecutionException e) { 
    // log the e.getCause() here 
} 
... 
pool.shutdown();