Запуск потоков в цикле, как?

[jskorvin]

Доброго времени суток!
Не понимаю от чего подвисание, раньше стартовал потоки таймером, а тут возникла ситуация в которой нужно именно циклы.

Код конечно условный, но суть полностью отражает.
Нужно запускать не больше 11 потоков одновременно, while в цикле какраз для ожидания уменьшения количества работающих потоков.

форма

unit main;

interface

uses
  Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  Dialogs, StdCtrls, Tgen;

type
  TForm1 = class(TForm)
    Button1: TButton;
    Memo1: TMemo;
    procedure Button1Click(Sender: TObject);
  private
    { Private declarations }
  public
    { Public declarations }
  end;

var
  Form1: TForm1;
  Cth: integer; // счетчик количества запущеных потоков

implementation

{$R *.dfm}

procedure TForm1.Button1Click(Sender: TObject);
var
TH: gen;
i, j, k: integer;
begin

 for i := 0 to 10 do
   for j := 0 to 5 do
     for k := 0 to 3 do
     begin

        while Cth > 10 do
        Application.ProcessMessages;


        TH:=gen.Create(true);
        TH.FreeOnTerminate:=true;
        TH.value:=i+j+k;
        TH.Resume;

//      memo1.Lines.Add(IntToStr(i+j+k));
     end;




end;

end.

На форме кнопка и мемо

Поток

unit Tgen;

interface

uses
  Classes, sysutils;

type
  gen = class(TThread)
  private
    { Private declarations }
  public
  value: integer;
  protected
    procedure Execute; override;
    procedure incCth;  // увеличение количества работающих потоков
    procedure decCth;  // уменьшение количества работающих потоков
    procedure toMemo;  // вывод чегото в мемо
  end;

implementation
      uses main;

{ gen }

procedure gen.incCth;
begin
inc(main.Cth)
end;


procedure gen.decCth;
begin
dec(main.Cth)
end;


procedure gen.toMemo;
begin
 main.Form1.Memo1.Lines.Add(IntToStr(value));
end;

procedure gen.Execute;
begin
 Synchronize(incCth);

   Synchronize(toMemo);

 Synchronize(decCth);
 self.Terminate;
end;


end.

Мне так кажется происходит следующее: отрабатывают циклы, создаются потоки, после этого все потоки разом пытаются стартануть. В голову приходит синхронизация, но как? Цикл то поидее и так в главном (VCL) потоке отрабатывает. Если устроить вывод в мемо прямо из цикла то все работает как положено.

Чего-то я видимо в свое время не дочитал, помогите пожалуйста разобраться.

Проект прикрепляю, писалось в Delphi XE. Осторожно подвешивает машину.

[veniside]

1) замените Synchronize(incCth); и Synchronize(decCth); на InterlockedIncrement(incCth); и InterlockedDecrement(incCth); соответсвенно. Каждый лишний вызов Synchronize() — это выстрел в голову главному потоку.

2) походу, как только потоков становится > 10, ваш while дедлочит дальнейшие вызовы Synchronize(), но точно не уверен.

3) Избавьтесь вобще от Synchronize(), общайтесь с мемо через PostMessage() или с использованием одного из десятка других методов межпоточного взаимодействия.

[jskorvin]

Сообщение от veniside

1) замените Synchronize(incCth); и Synchronize(decCth); на InterlockedIncrement(incCth); и InterlockedDecrement(incCth); соответсвенно. Каждый лишний вызов Synchronize() — это выстрел в голову главному потоку.

2) походу, как только потоков становится > 10, ваш while дедлочит дальнейшие вызовы Synchronize(), но точно не уверен.

3) Избавьтесь вобще от Synchronize(), общайтесь с мемо через PostMessage() или с использованием одного из десятка других методов межпоточного взаимодействия.

InterlockedIncrement действительно оптимальнее использовать для увеличения и уменьшения счетчика, спасибо. Но даже если убрать все функции из потока проблема остается =(

[veniside]

Так, проблема хуже, чем я думал. Потоки действительно накапливаются и большинство из них запускается фактически уже после того, как программа вышла из Button1Click(), так что проверка (Cth > 10) никогда не срабатывает.

Что можно сделать? Добавить Sleep(10); после TH.Resume;
Это даст шанс хоть кому-то запуститься и не насиловать систему созданием и одновременным запуском 264 потоков.

Походу обнаружилось, что все потоки, основанные на TThread создаются в suspensed mode, не зависимо от параметра CreateSuspensed. Более того, если у потока FreeOnTerminate = True, то его в конце прогонят через общую критическую секцию, из-за чего потоки скапливаются на выходе. Ну а самый ужос творится внутри Synchronize(), но это и так было известно )