Как узнать завершились ли все потоки (Thread)?

Question

[reus]

Я запускаю потоки через цикл for:

MyThrowClass throw;
for(String i: all) {
  trow = new MyThrowClass(i);
  trow.start()

Поток выполняет код и просто передает результат в статический контейнер (на основе ArrayList)
Для того чтобы проверить количество элементов контейнера у меня есть метод .getLength()
MyContainer.getLength();
Но если вызвать этот метод сразу после for, то результат будет нулевым ( "0" )так как потоки еще не завершили свою работу.
Собственно как узнать завершили ли все потоки работу, чтобы дальше передать результат их работы дальше?

Comments

[reus]

Ivan Sokolov: Просто в этом случае писал код для парсера и переход по ссылкам осуществлялся в разных потоках (типо для ускорения общей работы), а обхекты с html выгружались в static ArrayList

Answer 1

[kodwi]

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

Comments

[reus]

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

[kodwi]

reus: вот у тебя главный поток. В нем ты создаешь несколько потоков, запоминаешь их в массиве например, потом запускаешь. Потом в главном потоке тебе надо дождаться их завершения - идешь по массиву и делаешь каждому потоку join().

[reus]

kodwi: но у них всех же одно имя..

[kodwi]

reus: так это ты такой код написал) перепиши так:

// псевдокод
List threadList = new List();

for (...) {
  MyThrowClass thread = new MyThrowClass(i);
  threadList.add(thread);
  thread.start();
}

...

for (MyThrowClass thread: threadList) {
  thread.join();
}

[reus]

kodwi: а как бы вы подобную задачу с многопоточностью решили?

Answer 2

[Йцу Йцуевич]

trow.isAlive();

А если надо подождать, пока поток не завершится:
trow.join();

Comments

[reus]

а вот такой вопрос. К примеру я до цикла выполнил
MyThrow throw;
У меня в цикле запускается 10 throw (с разными аргументами/разными результатом), то тогда после цикла for я получу trow.isAlive() == false, от первого завершенного потока же? А как быть со всеми остальными?

[kodwi]

reus: так сохраняй каждый созданный поток в массив / список. Я выше в комментах ответил.

[Йцу Йцуевич]

Для начала, имя throw использовать нельзя! Пусть будет threads.
Тебе, наверно, необходимо запустить несколько потоков — список/массив потоков.
Тогда придётся переделать код:

MyThrowClass[] threads = new MyThrowClass[all.length];
for (int i = 0; i < all.length; i++) {
  threads[i] = new MyThrowClass(all[i]);
  threads[i].start();
}

// теперь у тебя есть массив потоков
// проходишься по нему
for (int i = 0; i < threads.length; i++) {
  boolean isAlive = threads[i].isAlive();    // можно проверить, завершён ли поток
  threads[i].join();   // и/или подождать его завершения
}

P.S. Уверен, тебе необходимо ожидать завершения каждого потока!

UPD:
Если all — коллекция, то вызываешь all.size() вместо all.length соответственно.