Потоки

[PTyTb32]

Привет, можно ли запустить 20 потоков с помощью цикла?

for g := 0 to 20 do
begin
 MyThread := TMyThread.Create(false);
 MyThread.Priority := tpNormal;   
end;

или они все лягут в 1 переменную и в итоге будет 1 поток и мне следует сделать массив потоков?

[Slym]

да. но как их потом ждать, убивать? если не надо ждать и они самоубиваются - норм

[PTyTb32]

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

да. но как их потом ждать, убивать? если не надо ждать и они самоубиваются - норм

что да? с массивом или нет? ждать не надо, они суицидники, сканер порта по диапазону ip делаю

[p51x]

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

что да?

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

Привет, можно ли запустить 20 потоков с помощью цикла?

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

да. если не надо ждать и они самоубиваются - норм

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

[PTyTb32]

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

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

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

это я все пытаюсь ускорить сканер портов путем потоков, по одному долго очень

с параметрами разобрался и потоки создаются, но в случае ошибки except не срабатывает и поток висит
вот его процедура

function scanerIP(Parameter : PMsgRecord): integer;
var
  i, d: integer;
  it: TIdTCPClient;
begin
  form1.Caption:=Parameter.ip;
  listipF := tstringlist.Create;
  it := TIdTCPClient.Create(nil);
    try
      if it.Connected then //тут ввисает
        it.Disconnect;
      it.Host := Parameter.ip;
      it.port := strtoint(Parameter.port);
      it.ConnectTimeout := Parameter.tc;
      it.Connect;
      listipF.Add(listip[i]);
      d := strtoint(Form1.Label12.Caption);
      inc(d);
      Form1.Label12.Caption := inttostr(d);
       d := strtoint(Form1.Label15.Caption);
      inc(d);
      Form1.Label15.Caption := inttostr(d);
      Form1.ProgressBar2.Position:=Form1.ProgressBar2.Position+1;
       EndThread(0);
    except
      it.Disconnect;
       Form1.ProgressBar2.Position:=Form1.ProgressBar2.Position+1;
      EndThread(0);
    end;
end;

все, сделал!
listipF.Add(listip[i]); тут нет цикла и неоткуда брать i, вот так надо listipF.Add(Parameter.ip);

[Slym]

Лучше сделать пул потоков. массив потоков.
поток сам берет параметр из списка, обрабатывает
и убивается столько при отсутствии параметров в списке, не забывая вычистить себя из пула.
и среда какая? Delphi хорошо так шагнул вперед с потоками и параллельной обработкой...

[PTyTb32]

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

Лучше сделать пул потоков. массив потоков.
поток сам берет параметр из списка, обрабатывает
и убивается столько при отсутствии параметров в списке, не забывая вычистить себя из пула.
и среда какая? Delphi хорошо так шагнул вперед с потоками и параллельной обработкой...

XE 10.2 их запускает цикл передавая каждому ip, сейчас борюсь с лютыми утечками, вылетает out of memory если диапазоны огромные. потоки живут не дольше полусекунды если доживет до пол секунды, то except вызванный connectionTimeout приведет к завершению потока, а если подключится то раньше убьется.

[Pavia]

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

вылетает out of memory если диапазоны огромные.

Потоки кушают много памяти. Ограничьте число потоков.

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

борюсь с лютыми утечками,

компоненты VCL не потокобезопасны поэтому вот этот участок следует выполнять через Synchronize в главном потоке.

      listipF.Add(listip[i]);
      d := strtoint(Form1.Label12.Caption);
      inc(d);
      Form1.Label12.Caption := inttostr(d);
       d := strtoint(Form1.Label15.Caption);
      inc(d);
      Form1.Label15.Caption := inttostr(d);
      Form1.ProgressBar2.Position:=Form1.ProgressBar2.Position+1;

И этот

Form1.ProgressBar2.Position:=Form1.ProgressBar2.Position+1;

В XE 10.2 используется Indy 10. А он сам создает по потоку на соединение. Так что ваши потоки тут явно лишнии.

[PTyTb32]

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

Так что ваши потоки тут явно лишнии.

без этих потоков он проверяет адреса последовательно, а это очень долго.
Synchronize используется в других потоках, я использую BeginThread и выглядит это вот так

 for g := 0 to strtoint(Label10.Caption) - 1 do // Label10.Caption = 28  - количество IP в диапазоне
      begin
        New(Params);
        Params.ip := listip[g];
        Params.port := Edit6.Text;
        Params.tc := strtoint(Edit7.Text);
        sss := BeginThread(nil, 0, addr(scanerIP), Params, 0, id1);

        ProgressBar2.Position := Params.p;
        closehandle(sss);
      end;

а сама функция scanerIP вот так

procedure scanerIP(Parameter: PMsgRecord);
var
  d: integer;
  it: TIdTCPClient;
begin
  it := TIdTCPClient.Create(nil);
  it.Host := Parameter.ip;
  it.port := strtoint(Parameter.port);
  it.ConnectTimeout := Parameter.tc;

  try
    it.Connect;
    Parameter.p := Parameter.p + 1;
    Form1.RichEdit1.Lines.Add(Parameter.ip + ' YES');
    d := strtoint(Form1.Label12.Caption);
    d := d + 1;
    Form1.Label12.Caption := inttostr(d);
    d := strtoint(Form1.Label15.Caption);
    d := d + 1;
    Form1.Label15.Caption := inttostr(d);
    it.free;
    EndThread(0);
  except
    on E: exception do
    begin
    it.free;
    Parameter.p := Parameter.p + 1;
    EndThread(0);
    end;

  end;

end;

при этом после сканирования 28 адресов я получаю такие утечки

[Alex11223]

Фигня какая-то, а не функция.

Уберите оттуда всю работу с формой, сделайте чистую функцию, которая просто принимает адрес и возвращает результат.
При завершении потока передавайте куда-нибудь результат, например с помощью событий/callback'ов, синхронизируйтесь с основным потоком. В TThread вроде есть готовый OnTerminate для этого.