Ждать завершения ExecutorService

@Critically · Регистрация: 14.03.2011

Студворк — интернет-сервис помощи студентам

Добрый день уважаемые форумчане, подскажите пожалуйста...

У меня есть поток, он в свою очередь запускает ExecutorService на 20 потоков...

Как мне ждать главным потоком, пока не завершаться все потоки из ExecutorService...

@turbanoff · 09.04.2013, 14:44

Executor при запуске задачи (потока) возвращает объект, типа Future
У Future есть метод get(), который ожидает завершения связанной с этим объектом задачи.

Waits if necessary for the computation to complete, and then retrieves its result.

Так как у вас 20 потоков, то скорее всего у вас должен быть список из Future. Нужно пробежаться по ним всем и вызывать get.

@mutagen · 09.04.2013, 14:49

Сообщение от turbanoff

Executor при запуске задачи (потока) возвращает объект, типа Future
У Future есть метод get(), который ожидает завершения связанной с этим объектом задачи.

Так как у вас 20 потоков, то скорее всего у вас должен быть список из Future. Нужно пробежаться по ним всем и вызывать get.

Это только если у вас туда Callable положили, а если Runnable ?

@Critically · 09.04.2013, 14:53 **[ТС]**

А можно немного кодом подсказать ? Надо каждый раз в run потока ExecutorService вызывать Future ?

Добавлено через 44 секунды
У меня Runnable...

Добавлено через 1 минуту

Java
1
2
3
for (int j = 0; j < byteMessagesArray.length; j++) {
execService.execute (new MyRunnable (j, byteMessagesArray, hashtable, id, sourceMsisdn, destinationMsisdn, messageClass, alphabet, esmClass, z) {});
}

Вот они так создаются.. Надо подождать главным потоком, пока они завершаться....

@turbanoff · 09.04.2013, 15:01

Сообщение от mutagen

Это только если у вас туда Callable положили, а если Runnable ?

Это ничего не меняет. Future все равно возвращается. И его метод get все равно ожидает окончания выполнения задачи.

Добавлено через 1 минуту

Сообщение от Critically

Вот они так создаются.. Надо подождать главным потоком, пока они завершаться....

Используйте метод submit, вместо execute. Он возвращает Future.
Складывайте возвращаемые Future в список, и потом когда необходимо ждать - пробегаете по ним и вызываете get.

@Critically · 09.04.2013, 15:46 **[ТС]**

execService.execute(new MyRunnable (j, byteMessagesArray, hashtable, id, sourceMsisdn, destinationMsisdn, messageClass, alphabet, esmClass, z) {}); Не получается что то с Future... А как эти Future потом сложить в массив или arraylist ?

@turbanoff · 09.04.2013, 15:54

Сообщение от Critically

А как эти Future потом сложить в массив или arraylist ?

Создать ArrayList перед началом цикла. В цикле вызывать метод ArrayList-a add, в который и передавать Future, возвращенный методом submit.

PS. Я не могу представить себе ситуацию, в которой человеку, который не может пачку объектов сложить в список, понадобилось бы писать сложную многопоточную программу...

@Critically · 09.04.2013, 17:02 **[ТС]**

Так ну вроде бы сложил в список... А как теперь ждать то пока они все завершаться ?

Добавлено через 49 минут
Перебираю их в цикле, наткнулся на не null, что делать в таком случае ?

@turbanoff · 09.04.2013, 17:09

Сообщение от Critically

Перебираю их в цикле, наткнулся на не null, что делать в таком случае ?

Что именно не null? объект Future?

Добавлено через 1 минуту

Сообщение от Critically

А как теперь ждать то пока они все завершаться ?

Я писал в самом первом сообщении - как ждать...

@mutagen · 09.04.2013, 18:13

Сообщение от Critically

А как теперь ждать то пока они все завершаться ?

гет это блокирующийся метод и в цикле как только ты его вызовешь включится ожидание

@Critically · 10.04.2013, 10:57 **[ТС]**

В конце потока в finally делаю так:

Java
1
2
3
4
5
for (int i=0, i<list.size, i++)   // list это ArrayList
{
Future<?> z=list.get(i);
String check=(String) z.get();
}

Тоесть когда закончится этот цикл, то завершаться все потоки из ExecuteService ?

Добавлено через 1 минуту

Сообщение от mutagen

гет это блокирующийся метод и в цикле как только ты его вызовешь включится ожидание

Mutagen, объяснил, спасибо, теперь хоть понятно стало как работает это...

@turbanoff · 10.04.2013, 11:25

Сообщение от Critically

Тоесть когда закончится этот цикл, то завершаться все потоки из ExecuteService ?

Да. Только непонятно зачем у вас там лишний каст к String.
Если ваши задачи - Callable<String>, то Future должен возвращаться такой: .
Соответственно вы должны были сделать список типа List<Future<String>>.

Java
1
2
3
4
5
for (int i=0, i<list.size, i++)   // list должен быть ArrayList<Future<String>>
{
Future<String> z=list.get(i);
String check= z.get();
}

Сообщение от Critically

Mutagen, объяснил, спасибо, теперь хоть понятно стало как работает это...

То есть в вот эти словах вам было что-то непонятно?
У Future есть метод get(), который ожидает завершения связанной с этим объектом задачи.

@Critically · 10.04.2013, 19:05 **[ТС]**

Сообщение от turbanoff

Да. Только непонятно зачем у вас там лишний каст к String.
Если ваши задачи - Callable<String>, то Future должен возвращаться такой: .
Соответственно вы должны были сделать список типа List<Future<String>>.

Java
1
2
3
4
5
for (int i=0, i<list.size, i++)   // list должен быть ArrayList<Future<String>>
{
Future<String> z=list.get(i);
String check= z.get();
}

То есть в вот эти словах вам было что-то непонятно?
У Future есть метод get(), который ожидает завершения связанной с этим объектом задачи.

Просто были ошибки когда я пытался создать Future и ArrayList, поэтому использовал те решения что предлагал Eclipse... Ну и он добавил...

Формулировку я не понял, если бы вы написали как Mutagen конкретно, сделав упор на то что, когда я вызываю Future.get(); то мой основной поток остановится и будет в этом месте ждать когда придет результат.

Но вам тоже спасибо это ведь вы подсказали что использовать для решения мой проблемы...

Новые блоги и статьи Все статьи Все блоги /
Подключение Box2D v3 к SDL3 для Android: физика и отрисовка коллайдеров 8Observer8 29.01.2026 Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами. Версия v3 была полностью переписана на Си, в. . .	Инструменты COM: Сохранение данный из VARIANT в файл и загрузка из файла в VARIANT bedvit 28.01.2026 Сохранение базовых типов COM и массивов (одномерных или двухмерных) любой вложенности (деревья) в файл, с возможностью выбора алгоритмов сжатия и шифрования. Часть библиотеки BedvitCOM Использованы. . .	Загрузка PNG с альфа-каналом на SDL3 для Android: с помощью SDL_LoadPNG (без SDL3_image) 8Observer8 28.01.2026 Содержание блога SDL3 имеет собственные средства для загрузки и отображения PNG-файлов с альфа-каналом и базовой работы с ними. В этой инструкции используется функция SDL_LoadPNG(), которая. . .	Загрузка PNG с альфа-каналом на SDL3 для Android: с помощью SDL3_image 8Observer8 27.01.2026 Содержание блога SDL3_image - это библиотека для загрузки и работы с изображениями. Эта пошаговая инструкция покажет, как загрузить и вывести на экран смартфона картинку с альфа-каналом, то есть с. . .
Влияние грибов на сукцессию anaschu 26.01.2026 Бифуркационные изменения массы гриба происходят тогда, когда мы уменьшаем массу компоста в 10 раз, а скорость прироста биомассы уменьшаем в три раза. Скорость прироста биомассы может уменьшаться за. . .	Воспроизведение звукового файла с помощью SDL3_mixer при касании экрана Android 8Observer8 26.01.2026 Содержание блога SDL3_mixer - это библиотека я для воспроизведения аудио. В отличие от инструкции по добавлению текста код по проигрыванию звука уже содержится в шаблоне примера. Нужно только. . .	Установка Android SDK, NDK, JDK, CMake и т.д. 8Observer8 25.01.2026 Содержание блога Перейдите по ссылке: https:/ / developer. android. com/ studio и в самом низу страницы кликните по архиву "commandlinetools-win-xxxxxx_latest. zip" Извлеките архив и вы увидите. . .	Вывод текста со шрифтом TTF на Android с помощью библиотеки SDL3_ttf 8Observer8 25.01.2026 Содержание блога Если у вас не установлены Android SDK, NDK, JDK, и т. д. то сделайте это по следующей инструкции: Установка Android SDK, NDK, JDK, CMake и т. д. Сборка примера Скачайте. . .

@Critically 10 / 10 / 6 Регистрация: 14.03.2011 Сообщений: 392

	Ждать завершения ExecutorService 09.04.2013, 14:29. Показов 4224. Ответов 12 Метки нет (Все метки) Добрый день уважаемые форумчане, подскажите пожалуйста... У меня есть поток, он в свою очередь запускает ExecutorService на 20 потоков... Как мне ждать главным потоком, пока не завершаться все потоки из ExecutorService... 0

@Critically 10 / 10 / 6 Регистрация: 14.03.2011 Сообщений: 392
	09.04.2013, 15:46 [ТС]
	execService.execute(new MyRunnable (j, byteMessagesArray, hashtable, id, sourceMsisdn, destinationMsisdn, messageClass, alphabet, esmClass, z) {}); Не получается что то с Future... А как эти Future потом сложить в массив или arraylist ? 0

@Critically 10 / 10 / 6 Регистрация: 14.03.2011 Сообщений: 392
	09.04.2013, 17:02 [ТС]
	Так ну вроде бы сложил в список... А как теперь ждать то пока они все завершаться ? Добавлено через 49 минут Перебираю их в цикле, наткнулся на не null, что делать в таком случае ? 0