Потоки - проблема с закрытием программы

[abb777]

Hi, All,

Есть наследник от TThread и список объектов, в каждом из которых создается экземпляр этого наследника. Еще каждый объект списка содержит событие (Event), созданное при помощи CreateEvent(). Суть в том, что все объекты списка связаны через взаимную генерацию этих событий. Т.е. Каждый объект ожидает события при помощи WaitForSingleObject(), работает и генерирует событие для другого объекта. И так в цикле. Все работает прекрасно, если дать этой системе доработать до конца метода Execute каждого потока. Но при попытке прервать работу всех потоков, например, при закрытии окна программы, все виснет. Причем несколько потоков все-таки завершается корректно, а остальные виснут на WaitForSingleObjject(), хотя там используется таймаут, а не бесконечное ожидание.

Вот код Execute:

procedure TLayerThread.Execute;
begin
  FLayer.FCurStep := 0;
  FLayer.FIsActive := true;
  while true do
  begin
    // принудительный выход
    if Terminated or
       FLayer.FTerminating or
       (FLayer.FEvent = INVALID_HANDLE_VALUE) then break;
..........................
      repeat
        //
        if Terminated or
           FLayer.FTerminating or
           (FLayer.FEvent = INVALID_HANDLE_VALUE) then break;
        Fres := WaitForSingleObject(FLayer.FEvent, 100);
      until Fres <> WAIT_TIMEOUT;
............................
  end;
  FLayer.FIsActive := false;
end;

Место, где генерируется событие для другого потока, здесь опущено, т.к., насколько я понимаю, суть не в нем.

А это код принудительного завершения:

.............
  for i := 0 to FLayers.Count - 1 do
  begin
    FLayers.Layer[i].FTerminating := true;
    f := true;
    while f do
    begin
      f := FLayers.Layer[i].IsActive;
      if f then
      begin
        Sleep(100);
        Application.ProcessMessages;
      end;
    end;
    FLayers.Layer[i].FTerminating := false;
  end;
..................

Может быть этот последний кусок и не совсем кошерный, но работать-то он должен по-моему.

Все это в DElphi 7 под WinXP.

Буду рад любым советам умных людей

[abb777]

Путем последовательных отключений кусков кода выяснил, что проблема, как ни странно, в этой строчке метода Execute:

    //Synchronize(DoOnStep);

А метод DoOnStep() ничего особенного с виду не представляет:

procedure TLayerThread.DoOnStep;
begin
  if not FLayer.FTerminating then
    if Assigned(FLayer.FEngine.FOnStep) then
      FLayer.FEngine.FOnStep(FLayer.FEngine, FLayer);
end;

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

Это что, баг в Delphi 7 или что???