Java - получить ошибки, распространяемые из фонового потока

Question

Я пытаюсь запустить фоновый сервис как часть моего приложения GUI. Я использую ExecutorService, и я получаю от него Future. Этот код показывает, что я делаю:

play.addActionListener(new ActionListener() { 

     service.submit(new Runnable(){ .... } } 
} 

Теперь, представление происходит на GUI потоке, который должен распространяться исключения из основного потока. Теперь я не хочу блокировать основной поток на future.get, но я предпочел бы некоторый способ проверить результат в будущем, чтобы исключения были пропущены в основной поток. Есть идеи?

Answer 1

Вы можете проверить Future.isDone(), чтобы узнать, закончилось ли это, или вы можете выполнить фоновое задание, например.

play.addActionListener(new ActionListener() { 

    service.submit(new Runnable(){ 
    public void run() { 
     try { 
     // .... 
     } catch(Exception e) { 
      SwingUtils.invokeLater(new Runnable() { 
       public void run() { 
        handleException(e); 
       } 
      } 
     } 
    } 
    }); 

Answer 2

Вы могли бы иметь дополнительный поток просто следить за состоянием будущего:

final Future<?> future = service.submit(...); 
new Thread(new Runnable() { 
    public void run() { 
     try { 
      future.get(); 
     } catch (ExecutionException e) { 
      runOnFutureException(e.getCause()); 
     } 
    } 
}).start(); 

И где-то еще:

public void runOnFutureException(Exception e) { 
    System.out.println("future returned an exception"); 
} 

Answer 3

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

Пример ....

final MySwingWorker mySwingWorker = new MySwingWorker(webPageText); 
    mySwingWorker.addPropertyChangeListener(new PropertyChangeListener() { 

    @Override 
    public void propertyChange(PropertyChangeEvent pcEvt) { 
     if (pcEvt.getNewValue().equals(SwingWorker.StateValue.DONE)) { 
      try { 
       mySwingWorker.get(); 
      } catch (InterruptedException e) { 
       e.printStackTrace(); // this needs to be improved 
      } catch (ExecutionException e) { 
       e.printStackTrace(); // this needs to be improved 
      } 
     } 
    } 
    }); 
    mySwingWorker.execute();