[Статья] Реализация многопоточности

[D.E.Z.E.R.T.I.R]

Цитата: Сообщение от Skrillex3 try final

try finally

[[Na`Vi]DendI]

Цитата: Сообщение от OpenFeint А как можно самому выберать количество потоков?Например я хочю зделать 1000 потоков,как зделать именно до 1000? Я в делфи новичек

for pot:=1  to strtoint(edit1.text) do  
  a[pot]:=potok.Create(false);

этот код на кнопку в эдите пишите кол-во потоков.

[[Na`Vi]DendI]

Цитата: Сообщение от OpenFeint Там где едит написано там точка и текст написанно.Нужно оставлять или удалять?

edit1.text это компонент,мне кажеться вам еще рано с потоками общаться
Выучите азы !

[Skrillex3]

Цитата: Сообщение от [Na`Vi]DendI Выучите азы !

Сам то их знаешь? уж очень сомневаюсь

[VeTaL_UA(1)]

Цитата: Сообщение от [Na`Vi]DendI edit1.text это компонент

Это параметр компонента.

Цитата: Сообщение от [Na`Vi]DendI мне кажеться вам еще рано с потоками общаться

Как и тебе, по сути.

Цитата: Сообщение от [Na`Vi]DendI Выучите азы !

И автора поста захватите с собой.

[Tip.the.besT]

Цитата: Сообщение от VeTaL_UA(1) Это параметр компонента. Как и тебе, по сути. И автора поста захватите с собой.

Согласен Учитывая, что тот кто пытается учить/попрекать других, сам, не знает конструкцию try except|finally end

[VeTaL_UA]

Цитата: Сообщение от ncdos По результату видно, что есть повторения. Выполнение цикла почему-то не до трех!? Бывает что цикл выполняется несколько раз. Например, если потоков десять, может выполнится десять раз. Кодеры объясните что к чему!

Что ж тут объяснять то. При использовании многопоточности необходимо синхронизировать работу потоков

[VeTaL_UA]

Цитата: Сообщение от ncdos VeTaL_UA, помогите пожалуйста, поправьте код.

Так не интересно. Подскажу:
1) Не используй цикл for в потоке
2) Засунь инкремент в процедуру синхронизации

[~MaXиK~]

Цитата: Сообщение от Tip.the.besT procedure potok.Execute;//начинаем описывать главную процедуру потока var I:integer; begin for i:=0 to 100 do begin sleep(1000); synchronize(synchro);//этой строкой мы вызываем процедуру synchro в единичном экземпляре end; end;

Многопоточность? Простой цикл,в котором потоки роли не играют(кроме первого создавшегося).

unit Unit1;

interface

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

type
  TForm1 = class(TForm)
    Button1: TButton;
    Edit1: TEdit;
    UpDown1: TUpDown;
    potoki: TMemo;
    procedure Button1Click(Sender: TObject);
  private
    { Private declarations }
  public
    { Public declarations }
  end;
potok = class(TThread)
protected
    procedure meniala;
    procedure Execute; override;
end;
var
  a: array [1..9999999] of potok;
  Form1: TForm1;
  nom: Integer=0;

implementation

{$R *.dfm}

procedure potok.Execute;
begin
Synchronize(meniala);
end;

procedure TForm1.Button1Click(Sender: TObject);
var
i: Integer;
begin
for i:=1 to updown1.position do
  a[i]:=potok.Create(false);
end;

Procedure potok.meniala;
begin
Sleep(1000);
nom:=nom+1;
form1.Caption:= inttostr(nom);
form1.potoki.lines.add(inttostr(nom));
end;

end

Это многопоточность.

[avi2011class]

а как к каждому потоку привязать прокси из списка так, чтобы они не повторялись? => случайный выбор прокси-плохая идея.

[VeTaL_UA]

Цитата: Сообщение от avi2011class а как к каждому потоку привязать прокси из списка так, чтобы они не повторялись? => случайный выбор прокси-плохая идея.

Ну по очереди из списка дёргать, пропатчив стандартную функцию TThread - Create.

[KiRo_Lajt]

А почему мало кто использует автоматический модуль создания потоков? Там же удобнее. Прошу дописать инструкцию, если не лень

[~MaXиK~]

Цитата: Сообщение от KiRo_Lajt А почему мало кто использует автоматический модуль создания потоков? Там же удобнее. Прошу дописать инструкцию, если не лень

Чем?В модуле только строка xxx=class(TThread); добвляется.


Можешь переделать под модуль,если не лень.

unit Unit1;

interface

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

type
  TForm1 = class(TForm)
    Button1: TButton;
    Edit1: TEdit;
    UpDown1: TUpDown;
    potoki: TMemo;
    procedure Button1Click(Sender: TObject);
  private
    { Private declarations }
  public
    { Public declarations }
  end;
potok = class(TThread)
protected
    procedure meniala;
    procedure Execute; override;
end;
var
  a: array [1..9999999] of potok;
  Form1: TForm1;
  nom: Integer=0;

implementation

{$R *.dfm}

procedure potok.Execute;
begin
Synchronize(meniala);
end;

procedure TForm1.Button1Click(Sender: TObject);
var
i: Integer;
begin
for i:=1 to updown1.position do
  a[i]:=potok.Create(false);
end;

Procedure potok.meniala;
begin
Sleep(1000);
nom:=nom+1;
form1.Caption:= inttostr(nom);
form1.potoki.lines.add(inttostr(nom));
end;

end.

[VeTaL_UA]

Цитата: Сообщение от ~MaXиK~ a: array [1..9999999] of potok;

это серьёзно. памяти не жалко?

[V.I.R.U.S.]

А вы в курсе, что Synchronize стопает все потоки на время запуска метода, указанного в нем?
Если потоков 1-10, то это не сильно влияет на работоспособность. А есть 100-1000? Каждый из потоков атомарно будет больше простаивать, чем работать, т.к., еще раз повторяю, пока 1 поток синхронизируется, остальные 999 его ждут.

Наилучшим способом, будет сделать какой-либо невизуальный класс, и обернуть "многопоточные" методы в CriticalSection.

Если уж надо синхронизировать данные с VCL, то PostMessage и SendMessage.

ИМХО.

Добавлено через 2 минуты

Цитата: Сообщение от ~MaXиK~ unit Unit1; interface uses Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms, Dialogs, StdCtrls, ComCtrls; type TForm1 = class(TForm) Button1: TButton; Edit1: TEdit; UpDown1: TUpDown; potoki: TMemo; procedure Button1Click(Sender: TObject); private { Private declarations } public { Public declarations } end; potok = class(TThread) protected procedure meniala; procedure Execute; override; end; var a: array [1..9999999] of potok; Form1: TForm1; nom: Integer=0; implementation {$R *.dfm} procedure potok.Execute; begin Synchronize(meniala); end; procedure TForm1.Button1Click(Sender: TObject); var i: Integer; begin for i:=1 to updown1.position do a[i]:=potok.Create(false); end; Procedure potok.meniala; begin Sleep(1000); nom:=nom+1; form1.Caption:= inttostr(nom); form1.potoki.lines.add(inttostr(nom)); end; end. [/CODE]

В чем смысл создавать поток, если ваш поток ничего не делает, как выполняет метод Procedure potok.meniala; в общем потоке? - то бишь, как-будто потока и нет.

Добавлено через 15 минут

Цитата: Сообщение от avi2011class а как к каждому потоку привязать прокси из списка так, чтобы они не повторялись? => случайный выбор прокси-плохая идея.

примерно так:

PHP код:

uses SysUtils, Classes, SyncObjs;

TProxyList = class
 protected
  FList: TStrings;
  FIndex: Integer;
  FSync: TCriticalSection;

  function GetHost: string;
  function GetPort: string;
 public
  constructor Create; virtual;
  destructor Destroy; override;
  
  procedure Next;
  property Host: string read GetHost;
  property Port: string read GetPort;  
end;

constructor TProxyList.Create;
begin
 FList:=TStringList.Create;
 FSync:=TCriticalSection.Create;
end;

destructor TProxyList.Destroy;
begin
 FreeAndNill(FList);
 FreeAndNill(FSync);
end;

function GetHost: string;
begin
 FSync.Enter;
 try
  Result:=FList.Names[FIndex];
 except
 end
 FSync.Leave;
end;

function GetPort: string;
begin
 FSync.Enter;
 try
  Result:=FList.ValuesFromIndex[FIndex];
 except
 end
 FSync.Leave;
end;

procedure Next;
begin
 FSync.Enter;
 try
  if FIndex >= FList.Count-1
   FIndex:=0
  else
   FIndex:=Findex+1;
 except
 end
 FSync.Leave;
end; 


================================

прокси добавляются примерно так:

PHP код:

FList.Add('127.0.0.1'+'='+'8888'); 


в потоке используется примерно так
без(!) необходимости синхронизации

PHP код:

var
 ProxyList: TProxyList;

procedure TMyThread.Execute;
var
 x: TSomeAnyHttpClass;
begin
 x:=TSomeAnyHttpClass.Create;

 ProxyList.Next; 

 x.Proxy.Host:=ProxyList.Host;
 x.Proxy.Port:=ProxyList.Port;
 
 x.Get('http://yandex.ru');
end;