Добрый день! У меня стоит задача сделать ScheduledThreadPool, запихнуть в него execute потоки, и остановить текущий поток пока все остальные не выполняться или они не зависнут. Я имею ввиду, что может возникнуть такая ситуация, что хотя бы 1 поток прервется(выполняется именно Runnable, исключений не выкидывает), необходимо в этом случае, что бы сотальные доработали и основной поток продолжил выполнение. Я пробовал awaitTerminator, но тот не реагирует на прервавшийся поток и продолжает ждать тайм-аута. Есть какие решения еще? Спасибо
-
Зачем использовать ScheduledThreadPool и дожидаться выполнения задач в основном потоке? Разве смысл Scheduled не в том, чтобы задачи выполнялись по расписанию? Может быть вас интересует вопрос, как запустить N задач и долждаться их выполнения в основном потоке?– a_gura25 дек 2013 в 9:09
-
да меня именно это инетересует– voipp25 дек 2013 в 9:40
2 ответа
Оформите ваши задачи в виде Future и используйте метод invokeAll
List<Future> futures = new ArrayList<Future>();
futures.add(f1);
futures.add(fn);
List<Future> results = executor.invokeAll(futures); //блокирует основной поток в ожидании завершения всех задач.
При необходимости можно в вызове invokeAll
можно устнаовить таймаут на ожидание заверешеня. Затем пробегаетесь по всем результатам. Те экземпляры Future
, которые завершились корректно, вернут true
при вызове isDone
, а результат можно получить методом get
.
Не очень понятна ваша задача.
Наверное так можно ошибки обработать в потоке:
Thread t = new Thread(new Runnable(){
public void run() {
throw new RuntimeException();
}
});
t.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
public void uncaughtException(Thread t, Throwable e) {
System.out.println("exception " + e + " from thread " + t);
}
});
t.start();
-
я имел ввиду, что мне необходимо что бы главный поток после запуска всех остальных потоков(ScheduledThreadPool.execute)остановился и ждал пока они не завершаться. Но только есть одна проблема, вдруг какие-то потоки прервутся,а остальные проработают. Завершится ли главный поток? Есть предложение испольовать awaitTerminator– voipp25 дек 2013 в 9:40