Как в Java узнать о том, что поток (thread) закончил выполняться?

Question

[VasG]

Я только вчера начал использовать эти потоки, и ещё «не в теме».

Хочется организовать пакетную обработку изображений, и для этого было сделано два потока: thrProcess и thrUpdateUI, соответственно для выполнения обработки изображений и обновления интерфейса (добавление уменьшенных копий результата). Причём второй запускается из первого (просто в конце написано thrUpdateUI.start())


Есть массив, в котором хранятся абсолютные пути до изображений: imgToProcPath[].


Собственно и всё, выше описаны потоки, и я пытаюсь их запустить:

for (int i = 0; i < imgToProcPath.length; i++) {

    thrProcess.start();
}

(если так делать ни в коем случае нельзя — большая просьба не точить на меня вилы сразу)


Но почему-то вызывается только один поток (нулевой).

Может быть есть способ дождаться, пока оба потока завершатся и тогда уже приступать к следующей итерации? Но как?

Comments

[VasG]

Я добавил в потоки вывод счётчика.
В первый раз (i =0) он нормально запускает поток, но остальные разы просто «прощёлкивает» цикл вхолостую. Почему? Как этого избежать?

Answer 1

[sainnr]

Насколько я понимаю, у вас немного неверное представление о потоках. В коде, приведенном вами, одному и тому же потоку thrProcess дается команда запуска при каждой итерации. Зачем его запускать несколько раз, если он уже выполнил start() после первой итерации (при i = 0)?

В таком случае, вы можете:
1) перенести цикл, проходящий по всем изображениям массива, внутрь рабочего метода потока thrProcess и запустить данный поток один раз;
2) создавать в цикле на каждой итерации новый поток (thrProcess1, thrProcess2, ..., thrProcessN), в котором будет проводиться обработка текущего изображения, и запускать его.

Второй вариант весьма странный — согласитесь, если у вас 1000 изображений, то создавать по 1 потоку для каждого из них, т.е. 1000 потоков всего, будет как-то не хорошо.

Comments

[sainnr]

Про потоки хорошо написано в этой статье — www.rsdn.ru/article/dotnet/CSThreading1.xml. Правда, на примере C#, но общие вещи можно в любом случае почитать.

[VasG]

Спасибо большое! Я воспользовался первым из ваших советов, и всё тут же встало на свои места: и дело делается, и GUI отзывчивый!
Ещё раз спасибо!

Answer 2

[romik]

Один объект Thread — один поток, даже если вы вызовете start несколько раз. В вашем случае разумно воспользоваться более высокоуровневой абстракцией типа ExecutorService.

ExecutorService executor = Executors.newFixedThreadPool(4);
List<Future<MyResult>> futures = new ArrayList<>();
for (File path: imgToProcPath) {
    executor.submit(new MyImageProcessingTask(path);
}
for (Future<MyResult> future: futures) {
   displayThumbnail(future.get());
}

Comments

[VasG]

Да! Точно! Зачем звать к столу того, кто и так уже обедает! Спасибо большое!

Answer 3

[antoo]

for (int i = 0; i < 10; i++)
            {
                
                Thread thread = new Thread(new ThreadStart(ФУНКЦИЯ ВЫПОЛНЯЮЩАЯСЯ В ПОТОКЕ));
                thread.Name = Convert.ToString(i);
                thread.Start();
            }

И не забудь проверить imgToProcPath.length;

Comments

[antoo]

Если необходимо дождаться завершения и только после этого сделать новый —

thread.Join();

[VasG]

Ругается на new ThreadStart() — а что это вообще такое? Предлагает поменять на new Runnable(), — но у меня уже и так это сделано.
Потом ругается на Convert.ToString(i); — нет такого метода (пишет)…
Netbeans 7.0.1

[antoo]

Вы язык не написали, я подумал что это C# почему-то :)

[VasG]

Да, действительно :(
Извиняюсь.