Автоматическая очередь потоков

[Alter]

Как сделать очередь, подобной Dоwnlоаd Маstеr?
Например:
_всего(Max) активных потоков разрешено ~5
_на запуск потоков всего ~15
_как освободилось место, запускаются следующие потоки, пока не закончатся те, которые отмечены на закачку

В реальном модуле потока используется sslHTTPCLi или idHTTP.
Интересует только очередь.

Вложение: простой пример для отладки

[Аватар]

Запустить первые 5. Поток сообщает о своем завершении - запускается следующий, если есть что запускать

[eoln]

Семафоры, ИМХО, самое то.
Код из Button3Click нужно вынести в отдельный поток и добавить туды семафоры. Примерно так

  
mySem := CreateSemaphore(nil, 4, 4, 'my_unikal_name_7523457374');//глобальная переменная
  if VST1.RootNodeCount <= 0 then Exit;
  aNode := VST1.RootNode.FirstChild;
  while aNode <> nil do
  begin
    ProcMessages;
    Thr := TMyThread.Create(aNode, VST1.GetNodeData(aNode), Handle, True);
    Thr.Resume;
    aNode := aNode.NextSibling;
    WaitForSingleObject(mySem, INFINITE);
  end;

В деструктор потока Thr добавить освобождение семафора

ReleaseSemaphore(mySem, 1, nil);

Если форма не нужна во время работы потоков (включая моменты синхронизации), то отдельный поток можно не заводить - форма просто подвиснет

[Alter]

Без дополнительного потока получилось.

var
  mySem :THandle;
  ActivThrCount :Integer; // потоков активно
  procedure DelThr(Thrd :TMyThread);
  procedure CreateSemMax(N :Byte=4);
  ...

implementation

procedure DelThr(Thrd :TMyThread);
var
  I :Integer;
begin
  with ThrList.LockList do
    try
  for I := 0 to Count-1 do
  begin
    try
      if TMyThread(Items[I]) = Thrd then
      begin
        ProcMessages;
        if Assigned(Items[I]) then
         TMyThread(Items[I]).Reliase; // Free
        Delete(I);
        Break;
      end;
    except
    end;
  end;
    // sem
  If Count <= 0 then
   CloseHandle(mySem);
    finally
  ThrList.UnlockList;
    end;
end;

procedure CreateSemMax(N :Byte);
begin // переменная глобальная
  mySem := CreateSemaphore(nil, N, N, 'my_unikal_name_7523457374');
end;

procedure TMyThread.Execute;
begin // Анимация
   try
 AddThr(Self);
 WaitForSingleObject(mySem, INFINITE);
 Synchronize(
    procedure
    begin
      Inc(ActivThrCount);
    end
            );
 while not Terminated do
 begin
     try
   if Terminated then Break;
   Synchronize(CheckDeleted);
   If fData^.CupPosI >= fData^.MaxI then
    fData^.CupPosI := 0;
   fData^.CupPosI := fData^.CupPosI + 1;
   Synchronize(RepaintTree);
   Sleep(Random(400));
     finally
   if fData^.CupPosI >= fData^.MaxI then
    Terminate;
     end;
 end;
   finally
  DelThr(Self);
 Synchronize(
    procedure
    begin
      Dec(ActivThrCount);
    end
            );
   end;
end;

procedure TMyThread.Reliase;
begin
 ReleaseSemaphore(mySem, 1, nil);
 FreeOnTerminate := True; 
 Terminate;
 Resume;                  // Будим поток для завершения
end;

...

initialization
  ActivThrCount := 0;
...

В процессе работы потоков, без перезапуска потоков, возможно ли уменьшать и прибавлять число разрешенных потоков? Как например в Dоwnlоаd Маstеr и т.п.

[eoln]

Да, можно просто манимулировать счётчиком.
Создать семафор например, на 1000, а начальный индекс задать на 996. Что-то вроде

mySem := CreateSemaphore(nil, 1001-N, 1000, 'my_unikal_name_7523457374');//N>0

Если надо увеличить число потоков на M штук, то просто вызываем

ReleaseSemaphore(mySem, M, nil);

А вот чтобы уменьшить, наверное, придётся M раз вызвать WaitForSingleObject. Правда при таком раскладе (когда запущены все потоки, но некоторые ждут) неизвестно выполнятся ли эти WaitForSingleObject первее тех WaitForSingleObject, которые ожидают в потоках. А значит снижение числа потоков в худшем случае может и не произойти до самого последнего момента.
Можно другой вариант - в TMyThread.Execute сразу после WaitForSingleObject вызывать ф-ию, которая проверяет не превышает ли число активных потоков разрешённого значения, и если это так, то в этом же потоке снова выполняется WaitForSingleObject. Но, ИМХО, костылями попахивает И этот костыль надо обернуть в критичискую секцию, например