Gestione errori di multithreading Java

Question

Ho un thread principale che ha creato molti worker, ogni worker è un thread.

Come posso ottenere errori dagli operatori nel thread principale se c'era un'eccezione in qualche lavoratore o lavoratore non riuscita correttamente?

Come inviare un errore prima che il thread di lavoro sia morto?

Answer 1

Se si utilizzano i quadri Executor java.util.concurrent e generare un Futuro da ciascun lavoratore inviato, quindi chiamare get() sul Futuro ti darà il risultato del lavoratore, o l'eccezione generata/catturata all'interno di quel lavoratore.

Answer 2

Un modo per ottenere ciò è utilizzare il segnale che passa nei thread. Il passaggio del segnale viene ampiamente utilizzato, quando è necessario che i thread comunichino tra loro. Un modo semplice per ottenere ciò potrebbe essere quello di accedere agli oggetti condivisi tra i thread e monitorare il valore dell'oggetto (indicazione di un segnale). È possibile assegnare un valore all'oggetto che indica l'errore (in forma di segnale) in modo che altri thread possano eseguire le azioni appropriate.
Utilizzando i segnali, è possibile non solo trasmettere segnali di errore ma diversi altri segnali di stato impostando il valore appropriato su un oggetto condiviso (ad esempio, Enum con valori diversi che indicano lo stato del thread).
consultare questo link per maggiori informazioni: http://tutorials.jenkov.com/java-concurrency/thread-signaling.html

Answer 3

È possibile impostare globale UncaughtExceptionHandler che intercettare tutte le eccezioni non gestite fanno in tutte le discussioni

Thread.setDefaultUncaughtExceptionHandler(new UncaughtExceptionHandler() { 
    @Override 
    public void uncaughtException(Thread t, Throwable e) { 
     ... 
    } 
}); 

Answer 4

Usa ExecutorService o ThreadPoolExecutor

È possibile intercettare le eccezioni in tre modi

1. Future .get()
2. Wrap intero metodo run() or call() in try{}catch{}Exceptoion{} blocchi
3. Override afterExecute metodo ThreadPoolExecutor

Fare riferimento al di sotto di SE domanda per maggiori dettagli:

Handling Exceptions for ThreadPoolExecutor