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

[Tip.the.besT]

Реализация многопоточности в delphi.

Вижу множество вопросов на разных форумах по программированию которые относятся к многопоточности. В этой статье я бы хотел не только объяснить как реализовать это в delphi, но и предоставить готовый шаблон многопоточного приложения который вы бы могли использовать в дальнейшем в своих программах.

Для начала немного теории. Одной из важнейших вещей в многопоточном приложении является синхронизация потоков. Если не учесть, синхронизацию потоков, то это, может привести к плачевным последствиям. Давайте рассмотрим такой пример, после чего у вас в голове всё встанет на свои места.
У нас в программе имеется переменная, назовём её - "int" - типа integer. Если мы будем присваивать ей значение из основного потока, то всё будет хорошо, и проблем не возникнет. Мало того, если даже мы присвоим ей значение из дополнительного потока который мы создали, то всё будет хорошо. Но так как зачастую у многопоточного приложения более одного дополнительного потока, то зададимся вопросом- "А, что будет если мы попытаемся присвоить переменной значение из двух потоков одновременно?". Вот тут, и произойдёт то таинственное события при котором переменной присвоится значение которое скорее всего не будет равно ни одному из значений которых вы планировали ей присвоить. Тогда и вступает в игру метод синхронизации synchronize. С помощь данного нам разработчиками delphi метода, вы можете обеспечить безопасное обращение нескольких потоков к одной переменной. Данный метод обеспечивает следующие: при вызове процедуры с помощью synchronize она начинает выполнятся, а все остальные процедуры вызванные с помощью этого метода встают в очередь и ждут выполнения текущей процедуры. Всё вышеописанное относится только к записи переменных, а читать можно одновременно из нескольких потоков и ничего плохого не произойдёт. Ну а теперь перейдём к практике.

И так создадим новый проект. И начнём писать поток. После вот этих строк:

private
    { Private declarations }
  public
    { Public declarations }
  end;

Добавим свои:

potok = class(TThread) //Этой строкой мы унаследовали класс потока
  private
   str: string;//в разделе private описываются переменные с помощью которых мы 
   nomer : Integer;//будем передавать значения между процедурами внутри потока 
  protected
    procedure Execute; override;//это главная процедура потока, она начинает свою работу 
//после того как мы создали поток
  public
    procedure synchro;//в разделе public вы можете объявить процедуры какие только душе 
//угодно
    constructor Create(CreateSuspended: Boolean);//эта строка говорит о том, что мы в
//implementation опишем конструкцию 
//потока
  end;

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

Под implementation нам надо описать конструкцию потока, в данном примере это не обязательно, но, что бы вы знали на будущие мы всё равно это сделаем.

constructor potok.Create(CreateSuspended: Boolean);
begin
  inherited Create(CreateSuspended);//Эта строка говорит о том, что поток после создания 
//будет приостановлен если ему передать значение true при создание, если false, то сразу 
//начнёт работу.
end;

Добавим в глобальные переменные переменную - "nom" - типа integer, а так же массив наших потоков.

var
  Form1: TForm1;
  nom:integer;
  a: array [1..10] of potok;//массив для хранения наших потоков

Теперь нужно описать процедуры потока, под implementation добавляем следующие:

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

procedure potok.synchro; //описываем ещё одну процедуру потока, которая будет менять 
//загаловок form1
begin
inc(nom);
form1.Caption:='Поток делает своё дело - '+inttostr(nom);
end;

Собственно всё готово, остаются только запустить потоки. Кидаем кнопку на форму, "кастуем на неё даблклик" и пишем:

procedure TForm1.Button1Click(Sender: TObject);
var
pot:integer;
begin
for pot:=1  to 10 do  //цикл запускает 10 потоков, которые будут изменять заголовок
  a[pot]:=potok.Create(false); //формы, так же идёт 
//добавление в массив, что бы потом вы могли уничтожить 
//один поток.
  end;

Вот так выглядит программа в итоге:

unit Unit1;

interface

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

type
  TForm1 = class(TForm)
    Button1: TButton;

    procedure Button1Click(Sender: TObject);
  private
    { Private declarations }
  public
    { Public declarations }
  end;
potok = class(TThread) //Этой строкой мы унаследовали класс потока
  private
   str: string;//в разделе private описываются переменные с помощью которых мы
   nomer : Integer;//будем передавать значения между процедурами внутри потока
  protected
    procedure Execute; override;//это главная процедура потока, она начинает свою работу
//после того как мы создали поток
  public
    procedure synchro;//в разделе public вы можете объявить процедуры какие только душе
//угодно
    constructor Create(CreateSuspended: Boolean);//эта строка говорит о том, что мы в
//implementation опишем конструкцию
//потока
  end;

var
a: array [1..10] of potok;
  Form1: TForm1;
   nom:integer;
implementation
constructor potok.Create(CreateSuspended: Boolean);
begin
  inherited Create(CreateSuspended);//Эта строка говорит о том, что поток после создания
//будет приостановлен если ему передать значение true при создание, если false, то сразу
//начнёт работу.
end;
{$R *.dfm}

procedure TForm1.Button1Click(Sender: TObject);
var
pot:integer;
begin
for pot:=1  to 10 do  //цикл запускает 10 потоков, которые будут изменять заголовок
  a[pot]:=potok.Create(false); //формы, так же идёт добавление в массив, что бы потом вы могли их уничтожить по одному.
  end;

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

procedure potok.synchro; //описываем ещё одну процедуру потока, которая будет менять
//загаловок form1
begin
inc(nom);
form1.Caption:='Поток делает своё дело - '+inttostr(nom);
end;


end.

Запускаем программу, и нажимаем на кнопку. И видим как в заголовке формы по очереди увеличивается число. ЧТД как говорится. Удачи в создание приложений.

С уважением Tip.the.besT.

Автор: Tip.the.besT

[VeTaL_UA]

А где про всеми любимые критические секции?

[Tip.the.besT]

Цитата: Сообщение от VeTaL_UA А где про всеми любимые критические секции?

Ну было дело раньше использовал, но сейчас мне метода sinchronize() достаточно.

[victor20011]

Спасибо огромное только что дописал брут
Брутит на много быстрее жаль спасибо не могу дать
А как сделать что бы пользователь сам выберал сколько потоков?

[pavel!]

хмм... без крит. секций странно (:
сделал, НО пропускает валидные аккаунты T_T
при чем чем больше потоков, тем больше пропускает...
уже около месеца воюю с потоками и так и не чего не навоивал (:

[Tip.the.besT]

Цитата: Сообщение от pavel! хмм... без крит. секций странно (: сделал, НО пропускает валидные аккаунты T_T при чем чем больше потоков, тем больше пропускает... уже около месеца воюю с потоками и так и не чего не навоивал (:

КС не юзаю, только метод синхронайз.

Дело наверно не в потоках. Ты смотрел в снифере, тебе хост отвечает на твой запрос?

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

Так что, повоюй ещё с моими советами и думаю всё получится

Цитата: Сообщение от victor20011 Спасибо огромное только что дописал брут Брутит на много быстрее жаль спасибо не могу дать А как сделать что бы пользователь сам выберал сколько потоков?

Теперь можешь)

Юзаем edit и всё. Где кол-во потоков вставляем:

strtoint(edit1.text)

[VeTaL_UA]

Цитата: Сообщение от J-Fobos крит секции потому и называются критичными, чтоб их юзали как можно меньше

Золотые слова То, что их часто используют не значит, что это хорошее решение.

Метод Synchronize, действительно одно из лучших решений при синхронизации потоков

[-=|GOOBER|=-]

полезная информация!)
Можно ли как-то предотвратить пропускание..?

[Tip.the.besT]

Цитата: Сообщение от -=|GOOBER|=- полезная информация!) Можно ли как-то предотвратить пропускание..?

Сам задавался этим вопросом, как мне известно нет. Видимо всё дело в том, что с одного IP поступает много запросов. Увеличение таймаута, плодов не принесло.

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

[pavel!]

Цитата: Сообщение от Tip.the.besT КС не юзаю, только метод синхронайз. Дело наверно не в потоках. Ты смотрел в снифере, тебе хост отвечает на твой запрос? Нужно ставить проверку, ответил ли хост или нет. Если не ответил, то ещё раз посылаем. Вот так будет робить. Для лёгкого алгоритма советую, генерировать лист - логин;пасс, а не брать из по отдельности. Тогда будет возможность удалять строку пока её обрабатывает поток и добавлять в конец списка если не удалось отправить запрос. Так что, повоюй ещё с моими советами и думаю всё получится Теперь можешь) Юзаем edit и всё. Где кол-во потоков вставляем: strtoint(edit1.text)

С выделенно красным поподробнее

[Tip.the.besT]

Цитата: Сообщение от pavel! С выделено красным поподробнее

Это само собой, просто не хочется исправлять ошибки, хочется предотвратить.

[[Na`Vi]DendI]

как потоки на паузу поставить ? возможно ли такое ?
и если отправляем пост запрос ну например авторизацию на сайте почему потоки не будут работать без TRY EXCEPT ?

[Tip.the.besT]

Цитата: Сообщение от [Na`Vi]DendI как потоки на паузу поставить ? возможно ли такое ? и если отправляем пост запрос ну например авторизацию на сайте почему потоки не будут работать без TRY EXCEPT ?

Потоки будут работать и без исключений, но это приведёт к тому, что потоки просто поумирают со временем или будут вылазить ошибки, в общем полный хаус.

Пауза делается следующим образом:

a[1].suspend;

а для продолжения:

a[1].resume;

[[Na`Vi]DendI]

Цитата: Сообщение от Tip.the.besT Потоки будут работать и без исключений, но это приведёт к тому, что потоки просто поумирают со временем или будут вылазить ошибки, в общем полный хаус.

все понятно а есть какие-то варианты кроме try except ?

[Skrillex3]

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

try final