Design - Exception in Thread

[Thread-Ersteller]

Guten Tag die Herren (und Damen),

ich habe derzeit ein Designproblem.

Kurz skizziert:

Ich habe einen / mehrere Threads in denen irgendwas passiert (oh, Wunder!).
Nun kann es jedoch passieren, dass in einem Thread eine Exception fliegt. Leider kann ich die nicht einfach so lange weiter reichen, bis sie in einem Logikgerüst angelangt, wo entsprechend darauf reagiert werden kann.

Konkret:
In dem jeweiligen Thread wird über ein Socket etwas eingelesen. Dabei kann eben eine Exception fliegen. Nur frage ich mich nun, wie ich darauf reagieren soll. Wenn über das Socket nichts gelesen werden kann, okay, dann ist das ungut. Ich könnte die Exception in der run() Methode abfangen und dann mit "nichts" darauf reagieren. Allerdings muss dann der Hauptteil des Programms über das Unglück berichtet werden. Nur will ich in den Thread keine Programmlogik unterbringen, weil das Thread-Konstrukt relativ ünabhängig sein soll:

	// e ist ein Objekt, dessen Methode aufgerufen wird, wenn der Lesevorgang abgeschlossen ist
	public void asyncRead(OperationDoneEvent e) {
		new EventThread(e) {
			public void run() {
				try {
					// rdr ist der InputStream des Sockets
					int val = rdr.read();
					// getEvent() ist das oben beschriebene Objekt e
					getEvent().OperationFinished(ba);
				}
				catch (IOException ex) {
					// Tja, und nun?
				}
			}
		}.start();
	}

Wie löse ich also nun das Problem elegant?

Ich hoffe, dass man mir irgendwer helfen kann.

Mit freundlichen Grüßen

ich

 

[schalentier]

Dein Code is bissel unklar irgendwie, aber offensichtlich rufst du eine Methode auf, wenn alles korrekt gelesen wurde (OperationFinished, Methoden werden in Java aber klein geschrieben!).

Wenn meine Annahme korrekt ist, dann man doch einfach eine zweite Methode und aender das so ab:

// e ist ein Objekt, dessen Methode aufgerufen wird, wenn der Lesevorgang abgeschlossen ist
   public void asyncRead(OperationDoneEvent e) {
      new EventThread(e) {
         public void run() {
            try {
               // rdr ist der InputStream des Sockets
               int val = rdr.read();
               // getEvent() ist das oben beschriebene Objekt e
               getEvent().operationFinished(ba);
            }
            catch (IOException ex) {
               getEvent().operationFailed( ex );
            }
         }
      }.start();
   }

 

[Niki]

Registrier bei deinen Runnable-Objekten eigene ExceptionListener. Diese können dann den notwendigen Logik-Teil ausführen:

public class MyRunnable implements Runnable{

  private List<ExceptionListener> exceptionListener= null;

  public MyRunnable(){
    exceptionListener = new ArrayList<ExceptionListener>();
  }

  public void addExceptionListener(ExceptionListener ex){
    exceptionListener.add(ex);
  }
  
  //genauso eine remove Methode....

  private void notifyListener(Throwable t){
    for(ExceptionListener e : exceptionListener)
      e.exceptionOccured(t);
  }

  public void run(){

  try{
    //hier Code ausführen...
  }catch(Exception ex){
    notifyListener(ex);
  }

  }

}

und das ExceptionListener Interface:

public interface ExceptionListener{
  public void exceptionOccured(Throwable t);
}

 

[Thread-Ersteller]

Danke an beide.

Hat mir sehr geholfen