Как выбросить проверенное исключение из потока java?

Question

Эй, я пишу сетевое приложение, в котором я читаю пакеты какого-то пользовательского двоичного формата. И я начинаю фоновый поток, чтобы ждать входящих данных. Проблема заключается в том, что компилятор не позволяет мне помещать исключения кода (проверенные) в run(). В нем написано:

run() in (...).Listener cannot implement run() in java.lang.Runnable; overridden method does not throw java.io.IOException

Я хочу исключение, чтобы убить поток и позволить ему быть пойманным где-то в родительском потоке. Можно ли достичь или я должен обрабатывать все исключения внутри нить?

Answer 1

Предостережение: это может не соответствовать вашим потребностям, если вам нужно использовать механизм исключения.

Если я правильно вас понимаю, вам действительно не нужно исключение, которое нужно проверить (вы приняли ответ, предлагающий исключение без отметки), так что бы более простой пример прослушивания был более уместным?

Слушатель может жить в родительском потоке, и когда вы поймали проверенное исключение в дочернем потоке, вы можете просто уведомить слушателя.

Это означает, что у вас есть способ разоблачения того, что это произойдет (посредством общедоступных методов) и сможет передавать больше информации, чем это позволит исключение. Но это означает, что между родительским и дочерним потоком будет связь (пусть и свободная). В вашей конкретной ситуации будет зависеть от того, будет ли это иметь преимущество перед переносом проверенного исключения с неконтролируемой.

Вот простой пример (часть кода заимствована из другого ответа):

public class ThingRunnable implements Runnable { 
    private SomeListenerType listener; 
    // assign listener somewhere 

    public void run() { 
     try { 
      while(iHaveMorePackets()) { 
       doStuffWithPacket(); 
      } 
     } catch(Exception e) { 
      listener.notifyThatDarnedExceptionHappened(...); 
     } 
    } 
} 

Соединение происходит из объекта в родительской нити, имеющей быть типа SomeListenerType.

Answer 2

Если вы действительно ничего не можете сделать полезными при возникновении исключения, вы можете обернуть исключенное исключение в RuntimeException.

try { 
    // stuff 
} catch (CheckedException yourCheckedException) { 
    throw new RuntimeException("Something to explain what is happening", yourCheckedException); 
} 

Answer 3

Если код вашей нити вызывает RuntimeExpection, вам не нужно добавлять исключение Run() throw Exception.

Но использовать это решение только в случае необходимости, поскольку это может быть плохой pratice: http://java.sun.com/docs/books/tutorial/essential/exceptions/runtime.html

Любой RuntimeException или незарегистрированное Исключение может помочь вам. Возможно, вам нужно будет создать собственное RuntimeException

Answer 4

нить не может выбросить исключение ни в какую другую нить (ни в основной поток). и вы не можете заставить унаследованный метод run() выкидывать любые проверенные исключения, так как вы можете бросить меньше, чем унаследованный код, а не больше.

Answer 5

В предположении, что ваш код находится в какой-то цикл, вы бы написать:

public class ThingRunnable implements Runnable { 
    public void run() { 
    try { 
     while(iHaveMorePackets()) { 
     doStuffWithPacket() 
     } 
    } catch(Exception e) { 
     System.out.println("Runnable terminating with exception" + e); 
    } 
    } 
} 

Исключение автоматически сломает вас из цикла, и в конце пробега() метод , поток остановится.

Answer 6

Я делаю это, чтобы поймать исключение в потоке и сохранить его как переменную-член Runnable. Это исключение затем открывается через геттер на Runnable. Затем я просматриваю все потоки от родителя, чтобы узнать, есть ли исключения, и предпримите соответствующие действия.

Answer 7

Чтобы иметь возможность отправить исключение в родительском потоке, вы можете поместить свой фоновый поток в Callable (это позволяет бросать также проверяемые исключения), которые вы затем перейти к submit методу some Executor. Метод submit возвращает Future, который затем можно использовать для получения исключения (его метод get будет вызывать ExecutionException, который содержит исходное исключение).

Answer 8

Этот ответ основан на Esko Luontola, но он служит рабочим примером.

В отличие от метода run() интерфейса Runnable метод call() Callable позволяет вызывать некоторые исключения. Вот пример реализации:

public class MyTask implements Callable<Integer> { 

    private int numerator; 
    private int denominator; 

    public MyTask(int n, int d) { 
     this.numerator = n; 
     this.denominator = d; 
    } 

    @Override 
    // The call method may throw an exception 
    public Integer call() throws Exception { 
     Thread.sleep(1000); 
     if (denominator == 0) { 
      throw new Exception("cannot devide by zero"); 
     } else { 
      return numerator/denominator; 
     } 
    } 

} 

Исполнитель предоставляет механизм для запуска отзывных внутри нити и для обработки любых исключений:

public class Main { 

    public static void main(String[] args) { 

     // Build a task and an executor 
     MyTask task = new MyTask(2, 0); 
     ExecutorService threadExecutor = Executors.newSingleThreadExecutor(); 

     try { 
      // Start task on another thread 
      Future<Integer> futureResult = threadExecutor.submit(task); 

      // While task is running you can do asynchronous operations 
      System.out.println("Something that doesn't need the tasks result"); 

      // Now wait until the result is available 
      int result = futureResult.get(); 
      System.out.println("The result is " + result); 
     } catch (ExecutionException e) { 
      // Handle the exception thrown by the child thread 
      if (e.getMessage().contains("cannot devide by zero")) 
       System.out.println("error in child thread caused by zero division"); 
     } catch (InterruptedException e) { 
      // This exception is thrown if the child thread is interrupted. 
      e.printStackTrace(); 
     } 
    } 
} 

Answer 9

Обертывания вашего исключения Внутри RuntimeException, кажется, сделать трюк ,

someMethod() throws IOException 
{ 
    try 
    { 
     new Thread(() -> 
     { 
      try 
      { 
       throw new IOException("a checked exception thrown from within a running thread"); 
      } 
      catch(IOException ex) 
      { 
       throw new RuntimeException("a wrapper exception", ex); // wrap the checked exception inside an unchecked exception and throw it 
      } 
     }).start(); 
    } 
    catch(RuntimeException ex) // catch the wrapped exception sent from within the thread 
    { 
     if(ex.getCause() instanceof IOException) 
      throw ex.getCause; // unwrap the checked exception using getCause method and use it however you need 
     else 
      throw ex; 
    } 
}