Как определить закончил ли работу поток?

[fredwriter]

Здравствуйте, как определить закончил ли работу поток?

 begin
    Potok1 := ParallelObj.Create(true);
    Potok2 := Potok2Obj.Create(true);
    Potok1.Priority := tpNormal;
    Potok2.Priority := tpNormal;
    Potok1.Resume;
    Potok2.Resume;
  end;

[veniside]

if (WAIT_OBJECT_0 = WaitForSingleObject(Potok1.Handle, 1)) then ... // Potok1 завершился

[fredwriter]

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

begin
  // запуск потоков
  Potok1 := ParallelObj.Create(true);
  Potok2 := Potok2Obj.Create(true);
  Potok1.Priority := tpNormal;
  Potok2.Priority := tpNormal;
  Potok1.Resume;
  Potok2.Resume;
  // ниже код, который должен выполниться через мгновение после завершения двух 
  // потоков, то есть, это значит, что данные получаемые из потоков уже есть и их 
  // можно обрабатывать, это должно произойти незамедлительно после завершения
  // двух потоков.
  if (WAIT_OBJECT_0 = WaitForSingleObject(Potok1.Handle, 1))
  and (WAIT_OBJECT_0 = WaitForSingleObject(Potok2.Handle, 1)) then
  begin
    ....;
    ....;
  end;

end;

[fredwriter]

Может быть, то, что я спрашиваю, сейчас не актуально и есть в инете куча примеров работы с потоками, но конкретного примера с нормальными объяснениями того, что мне нужно нигде нет. Помогите пожалуйста.

[Rififi]

fredwriter

сначала сюда, потом - сюда.

[fredwriter]

Почитал про функцию WaitForSingleObjects, она заставляет поток ждать пока освободится объект. Какой объект занят потоком когда он выполняется? Например если в потоках происходит перемножение двух массивов M1 и M2: array of array of integer. В каждом по половине массива. Мне нужно самому создать объекты и занять ими потоки? Не понимаю концепции.

[veniside]

для начала постарайтесь верно формулировать задачу.

как определить закончил ли работу поток

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

эти задачи принципиально отличаются. Для решения второй, код будет такой:

handles: array[0..1] of THandle;

handles[0] := Potok1.Handle;
handles[1] := Potok2.Handle;
if (WAIT_OBJECT_0 = WaitForMultipleObjects(2, @handles, true, timeout)) then .. // оба завершились

Отличие не только в количестве. Обратите внимание на timeout, этот параметр задаёт, сколько вы готовы ждать окончания работы потоков (в мс). Если готовы ждать бесконечно, задайте INFINITE.

она заставляет поток ждать пока освободится объект. Какой объект занят потоком когда он выполняется

Для хэндлов потоков WaitForХХХ() работает просто: хендл считается установленным (signaled), когда поток завершился. Никаких других объектов там нет.

[fredwriter]

Огромнейшее спасибо, veniside,

Если готовы ждать бесконечно, задайте INFINITE.

Зачем же мне ждать бесконечно, я точно знаю, что потоки завершатся.
А если они еще не завершились, то он просто пропустит ветку if then что ли? Мне нужно обязательно дождаться завершения, а только потом продолжить.

[veniside]

timeout — это верхний потолок ожидания. Если оба потока завершатся через 1 мс, то и WaitFor() вернётся через 1 мс, даже если был задан INFINITE.

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

ОСНОВНОЕ РАЗЛИЧИЕ МЕЖДУ ПРЕДМЕТОМ, КОТОРЫЙ МОЖЕТ ИСПОРТИТЬСЯ, И ПРЕДМЕТОМ, КОТОРЫЙ ИСПОРТИТЬСЯ НЕ МОЖЕТ, СОСТОИТ В ТОМ, ЧТО ПРЕДМЕТ, КОТОРЫЙ НЕ МОЖЕТ ИСПОРТИТЬСЯ, НЕВОЗМОЖНО ПОЧИНИТЬ. ЕСЛИ ОН ВСЕ-ТАКИ ИСПОРТИЛСЯ.

Поэтому я обычно указываю какой-то reasonable timeout, например, 20 секунд (зависит от задачи). Если по истечении этого времени потоки не завершились, значит, что-то пошло не так, и их надо прибивать.

[fredwriter]

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

Не может быть никакой ошибки, в потоках просто матрицы перемножаются, которые заранее инициализированы в основном потоке, если они не инициализированы, то потоки не запустятся, поэтому мне timeout не нужен. В принципе, на всякий случай можно и воспользоваться, но я не знаю, почему вдруг у меня могут не выполниться потоки. Я не это хотел узнать а следующее: WaitFor() застявляет ждать один поток пока не освободиться объект занятый другим потоком, но условие

if WAIT_OBJECT_0 = WaitFor(...) then

как я понял лишь проверяет завершены ли потоки, если да, то программа зайдет на эту ветку if then, если нет, то пропустит её и продолжится.
Может я не правильно понял?