Форум программистов [Powered by Invision Power Board]

Код

var
ThreadsCount: integer;  // при создании формы задается = 0, следит за общим числом запущенных потоков
CS: TTMultiReadExclusiveWriteSynchronizer;
EndCalcEvent: TEvent;  // создается при создании формы EndCalcEvent := TEvent.Create(nil, false, false, '');


procedure MainForm.Start(Count: integer);
var
i: integer;
F: TClassF;
begin
  for i := 1 to N do     // число N как правило невелико
  begin
    F := TClassF.Create;  // создаем объект F
    F.StartCalc(Count);   // запускаем расчет
    if EndCalcEvent.WaitFor(INFINITE) = wrSignaled then
    begin
      F.CalcStat;         // подсчитываем статистику
      List2.Add(F);       // добавляем объект в список
    end;
  end;
  List2.Show;             // вывод списка на форму
end;




procedure TClassF.StartCalc(Count: integer);
var
i: integer;
T: TClassT;
MyThread: TMyThread;
begin
  EndCalcEvent.ResetEvent;
  for i := 0 to count - 1 do
  begin
    T := TClassT.Create;    // создаем объект Т
    List1.Add(T);           // добавляем его с список
    MyThread := TMyThread.Create(T);   // поток создается приостановленным 
    MyThread.FreeOnTerminate := true;
    inc(ThreadsCount);      // увеличиваем число запущенных потоков на 1
    MyThread.OnTerminate := DecreaseCounter;  
    MyThread.Resume;
  end;
end;


procedure TClassF.DecreaseCounter(Sender: TObject);   // сюда даже не заходит
begin
  CS.BeginWrite;          // зачем тут кртическая секция? сам не знаю, но такой код был в хелпе
  dec(ThreadsCount);      // уменьшаем счетчик числа запущенных потоков на 1
  if ThreadsCount = 0 then  
    EndCalcEvent.SetEvent;  // устанавливаем событие, если все потоки завершены
  CS.EndWrite;
end;




procedure TMyThread.Execute;
begin
  while (LocalT.X = 0) and (not Terminated) do
    LocalT.CalcX;
  Synchronize(Update);   // из цикла while выходит, становится на эту строку и дальше любой шаг Ф7/Ф8 
//вызывает полное отсутствие реакции, в саму процедуру Update ни разу не заходит
end;