VPF::Многопоточность - Форум программистов

SymplyFying

Дата 27.5.2006, 22:05 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 11
Регистрация: 27.5.2006

Репутация: нет
Всего: нет

Здравствуйте.
Есть код:

Код


unit Unit1;

interface

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

type
  TMyThread = class(TThread)
  private
    { Private declarations }
  protected
    procedure Execute; override;
  end;

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

var
   Form1: TForm1;
   wsdata: TWSAData;
   adr: sockaddr_in;
   temp: string;
implementation


{$R *.dfm}



procedure TForm1.Button1Click(Sender: TObject);
var
host:string;
begin
temp                :=edit1.text;
host                :=resolve('host.ru');
adr.sin_addr.s_addr :=inet_addr(pchar(host));
adr.sin_family      :=AF_INET;
adr.sin_port        :=htons(80);
TMyThread.Create(false);
end;

procedure TMyThread.Execute;
var
sock,i: integer;
req: string;
ans: string;
begin
Sock:=Socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
if sock =-1 then Exit;
if connect(sock,adr,sizeof(adr))<>0 then begin
CloseSocket(Sock);
exit;
end;
req:='GET /'+temp+' HTTP/1.1';
SendString(sock, req);
ans:=ans+ReadString(Sock);
CloseSocket(Sock);
Memo1.Lines.Add(ans);
end;

procedure TForm1.FormCreate(Sender: TObject);
begin
wsaStartup(MAKEWORD(1,1), wsData);
end;

end.

Как мне сделать многопоточность на основе данного кода?
И как в поток передавать параметры, если у меня переменная temp будет заменена stringlistom? Т.е. чтобы каждый новый поток получал за место переменной temp следующую строку хранящуюся в stringlist?
За ранее спасибо за ответы.

Демо

Дата 28.5.2006, 09:34 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1278
Регистрация: 3.11.2005

Репутация: 3
Всего: 50

SymplyFying,

Для начала желательно вообще что-нибудь о потоках почитать.
Например, это - http://www.delphimaster.ru/articles/panov/index.html
Это - http://forum.vingrad.ru/index.php?showtopic=60076

--------------------

SymplyFying

Дата 28.5.2006, 11:03 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 11
Регистрация: 27.5.2006

Репутация: нет
Всего: нет

Демо, спасибо что ответил smile

Я читал это уже, но к сожалению не понял smile

Вот и прошу помощи у Вас.

Демо

Дата 28.5.2006, 11:12 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1278
Регистрация: 3.11.2005

Репутация: 3
Всего: 50

SymplyFying,
Для передачи параметров потоку применяется либо переопределение конструктора, либо добавляются методы/свойства - как и в любом другом классе.

Примеров в сети вообще полно, да и в DElphi\demo тоже, но приведу простой пример все равно:

Код


 TMyThread = class(TThread)    
  private    
    FParam: String;
  protected    
    procedure Execute; override;    
  public
    constructor Create(const Param: String);
  end;

...

constructor TMyThread.Create(const Param: String);
begin
  inherited Create(True);
  FParam := Param;
  FreeOnTerminate := True;
  Resume;
end;

Переопределение конструктора применяется и в примерах в первой из приведенных ссылок. Так что все-таки рекомендую сначала прочитать статью.

--------------------

SymplyFying

Дата 28.5.2006, 11:27 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 11
Регистрация: 27.5.2006

Репутация: нет
Всего: нет

Что-то типа:

Код



unit Unit1;
interface
uses
  Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  Dialogs, StdCtrls,Winsock,SockFuncs;
type
  TMyThread = class(TThread)
  private
    { Private declarations }
  protected
    procedure Execute; override;
  end;
type
  TForm1 = class(TForm)
    Edit1: TEdit;
    Button1: TButton;
    Memo1: TMemo;
    procedure Button1Click(Sender: TObject);
    procedure FormCreate(Sender: TObject);
    procedure create;
  private
    { Private declarations }
  public
    { Public declarations }
  end;
var
   Form1: TForm1;
   wsdata: TWSAData;
   adr: sockaddr_in;
   temp: string;
   list: tstringlist;
implementation
{$R *.dfm}

procedure TForm1.Create;
begin
If List.Count=0 then exit;
with TMyThread.Create(True) do
    begin
      FreeOnTerminate:=True;
      temp:=List.Strings[0];
      Resume;
    end;
List.Delete(0);
end;

procedure TForm1.Button1Click(Sender: TObject);
var
host:string;
begin
host                :=resolve('host.ru');
adr.sin_addr.s_addr :=inet_addr(pchar(host));
adr.sin_family      :=AF_INET;
adr.sin_port        :=htons(80);
for i:=1 to 10 do // это типа делаем 10 потоков
create;
end;

procedure TMyThread.Execute;
var
sock,i: integer;
req: string;
ans: string;
begin
Sock:=Socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
if sock =-1 then Exit;
if connect(sock,adr,sizeof(adr))<>0 then begin
CloseSocket(Sock);
exit;
end;
req:='GET /'+temp+' HTTP/1.1';
SendString(sock, req);
ans:=ans+ReadString(Sock);
CloseSocket(Sock);
Memo1.Lines.Add(ans);
end;

procedure TForm1.FormCreate(Sender: TObject);
begin
wsaStartup(MAKEWORD(1,1), wsData);
list:=tstringlist.create;
end;
end

Правильно оформлен код или нет?

Добавлено @ 11:30
Демо, спасибо за быстрые ответы smile

Твой второй пост не видел когда писал ответ и сам написал код smile

Не мог бы ты сказать всё ли там правильно?

Цитата(Демо @ 28.5.2006, 11:12

)

Так что все-таки рекомендую сначала прочитать статью.

Читал. Может просто не вник. Счас ещё раз перечитаю.

Aleksiem

Дата 31.5.2006, 00:21 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 57
Регистрация: 4.5.2006
Где: Выкса

Репутация: 1
Всего: 2

Для начала по-моему не один объект не уничтожается.
В конце процедуры TMyThread.Execute вставь Terminate;
В конце программы StringList тоже уничтожь. Опять же непонятные функции SendString и ReadString (по-моему в winsock они не описаны), но я так понимаю это запись и чтение данных в сокет. Но на счёт многопоточности примерно всё так, хотя можно было и попонятнее оформить.

SymplyFying

Дата 31.5.2006, 01:03 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 11
Регистрация: 27.5.2006

Репутация: нет
Всего: нет

Цитата(Aleksiem @ 31.5.2006, 00:21

)

Для начала по-моему не один объект не уничтожается.

=) Потоки не уничтожаються.
Стринглист уничтожаеться, просто здесь забыл.

Цитата(Aleksiem @ 31.5.2006, 00:21

)

Опять же непонятные функции SendString и ReadString (по-моему в winsock они не описаны)

Они точно работают.

Цитата(Aleksiem @ 31.5.2006, 00:21

)

Но на счёт многопоточности примерно всё так

А вот такой вопрос возник:

Код


for i:=1 to 10 do // это типа делаем 10 потоков
create;

Это получается я делаю 10 потоков для первых 10 строчек? А если надо весь StringList обработать, где, например, около 5000 строк - это надо 5000 потоков создавать? Или нет?
Можно как нибудь оформить, чтобы можно было вводить любое кол-во паралельных потоков, и чтобы при этом обрабатывался весь файл.(сильно не пинайте если что не так сформулировал ;) )

Цитата(Aleksiem @ 31.5.2006, 00:21

)

хотя можно было и попонятнее оформить.

Как? Буду очень признателен за пример ;)

Добавлено @ 01:04
Ну вот, блин. smile

Хотел "+" поставить Демо и Aleksiem. А низя.

Демо

Дата 31.5.2006, 08:51 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1278
Регистрация: 3.11.2005

Репутация: 3
Всего: 50

Цитата(SymplyFying @ 31.5.2006, 01:03

)

Можно как нибудь оформить, чтобы можно было вводить любое кол-во паралельных потоков,

idHTTP

--------------------

N1k

Дата 31.5.2006, 16:04 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 28
Регистрация: 4.1.2006

Репутация: 2
Всего: 2

чтоб весь список обработался...

Код


...
  TMyThread = class(TThread)
  private
    FTmp:string
    { Private declarations }
  protected
    procedure Execute; override;
  public
    property Str:string read FTmp write FTmp
  end;
...
procedure TMyThread.Execute;
var
sock,i: integer;
req: string;
ans: string;
adr: sockaddr_in;
host:string;
begin
host                :=resolve('host.ru');
adr.sin_addr.s_addr :=inet_addr(pchar(host));
adr.sin_family      :=AF_INET;
adr.sin_port        :=htons(80);
Sock:=Socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
if sock =-1 then Exit;
if connect(sock,adr,sizeof(adr))<>0 then begin
CloseSocket(Sock);
exit;
end;
req:='GET /'+FTmp+' HTTP/1.1';
SendString(sock, req);
ans:=ans+ReadString(Sock);
CloseSocket(Sock);
Memo1.Lines.Add(ans);
end;
...
procedure ThreadTerminate(Sender: TObject);
...
procedure TForm1.Create;// я б не стал так называть
begin
If List.Count=0 then exit;
with TMyThread.Create(True) do
    begin
      FreeOnTerminate:=True;
      OnTerminate:=ThreadTerminate;
      Str:=List.Strings[0];
      Resume;
    end;
List.Delete(0);
end;
...
procedure TForm1.ThreadTerminate(Sender: TObject);
begin
create;
end;

Приблизительно так, хотя не все ошибки исправил...

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Delphi: Сети \| Следующая тема »