Форум АНТИЧАТ - [Delphi] Многопоточность.

Форум АНТИЧАТ (https://forum.antichat.xyz/index.php)

- С/С++, C#, Delphi, .NET, Asm (https://forum.antichat.xyz/forumdisplay.php?f=24)

- - [Delphi] Многопоточность. (https://forum.antichat.xyz/showthread.php?t=200557)

[Delphi] Многопоточность.

Я знаю. Всех эта тема уже ацки задрала. Но прошу вас о помощи. Гугл и тд не предлагать.. просто помогите. Значит суть такова: например у меня в списке 100 проксей, я хочу проверить весь список скажем в 7 потоков. Желательно, что бы все это дело можно было поставить на паузу, возобновить и прервать вовсе. Я немного разобрался с критическими секциями. Но все это сопоставить немогу. Парни! прошу вас о помощи.. Если вам помощь нужна - я помогу и помогал всегда.. Модераторы - простите засранца за темень в знаниях моих...

пишу код на коленке, думаю разберёшся сам :)

Код:

p = class(tthread)

 private

 //переменные

 proxy:striing;

 otver:tstringlist;

  procedure getprx;

  procedure checkprx;

 protected

 procedure execute; override;

end;





var

form1..

p1,p2,p3,p4,p5,p6,p7:tthread;

i:integer;

pr:bool;





//процедура чека проксей



procedure p.checkprx;

begin

 otver:=tstringlist.create;

 // тут подставляешь прокси в инди(или что там у тебя). прокси - переменная proxy

 try

  otver.text:=http.get(somesite);

  if length(otver)<>0 then // наверное можно только except юзать

   прокси валидный

  else 

   прокси не валидный

 except 

  прокси не валидный

 end;

end;





//создаёшь процедуру, которая будет выдавать каждому потоку проксю



procedure p.getprx;

begin

 //чтото типо того

 proxy:= form1.memo1.lines[i];

 i:=i+1;

 if i=form1.memo1.lines.count // если прокся последняя - завершать проверку

 then pr:=false;

end;



procedure p.execute;

begin



//тутсоздаёшь все компоненты инди, или что там у тебя



 Synchronize(getprx); //берёш проксю

 repeat 

   checkprx;   //чекаешь

 until pr=false; 

end;





procedure tform1.button1click(sender: tobject);

begin

pr:=true;

i:=0;

 p1 := tnew.create(true);

 p1.freeonterminate := true;

 p1.priority := tpnormal;

 p1.resume;

p2 := tnew.create(true);

 p2.freeonterminate := true;

 p2.priority := tpnormal;

p2.resume;

// и так до p7



end;

Цитата:

Сообщение от RedFern.89

книга Джона Рихтера 11 глава функция UserWorkItem, делаешь правельные настройки фукции закидываешь все в пул потоков и наслаждаешься жизнью

Всё очень просто :
Разберем что есть 100 прокси и 7 потоков.
Каждый поток должен что делать :
Брать новый прокси и чекать его, если чекать уже не кого(счётчик равен 100) - поток убиваем. Когда поток убиваем проверяем, последний ли поток убили, если да - то программу информиреум о том что чек закончился.

Теперь разберем куда всунуть критическую секцию. Во-первых первая критическая секция должна стоять там где берется новый прокси, во-вторых вторая должна стоять где идёт проверка послдений ли поток был убит, получаем вот такой общий код процедуры выполнения потока :

Код:

procedure TProxyThread.Execute;

var cur_id : Cardinal;

Begin

      repeat

            cs1.Exiter;

            if (pxIndex >= maxProxy) then

            Begin

                  cs1.Leave;

                  Break;

            end;

            cur_id := pxIndex;

            Inc(pxIndex);

            cs1.Leave;

            //Теперь тут мы чекаем прокси с индексом cur_id

            ...

      until Terminated;

      //Тут убираем наш поток из списка активных потоков, проше всего это

      //можно сделать счётчиком убитых потоков и если этот счётчик становится после

      //инкремента равен 7 - значит все потоки остановлены, я проше так и сделаю

      cs2.Enter;

      Inc(termThreads);

      if (termThreads >= 7) then

      Begin

            //Здесь сигнализируем приложению что чек прокси закончился 

      end;

      cs2.Leave;

end;

Вот и всё, только переменные перед началом запуска потоков должны быть равны :
pxIndex := 0;
ermThreads := 0;

Что бы на время приостановить чек - выполняем из главного потока : cs1.Exiter; (1)
Что бы продолжить чек - выполняем из главного потока : cs1.Leave; (2)
Ток следи что бы (1) и (2) выполнялись симметрично.

Цитата:

Сообщение от Jingo Bo

Во-первых первая критическая секция должна стоять там где берется новый прокси, во-вторых вторая должна стоять где идёт проверка послдений ли поток был убит

Не нужно крит.секций
Interlocked-функции WinAPI

Цитата:

Не нужно крит.секций
Interlocked-функции WinAPI

В чем профит?