Параллельное программирование в Delphi XE7

Ta2i4 написал:

Ta2i4 — Tue, 17 Sep 2019 01:44:50 +0300

Жаль, что примеров по параллельному программированию на Delphi в гугле пока мало. Сейчас у меня такой код: Всё работает. Но мне понадобилось в этот цикл засунуть еще одну задачу, также стартующую с разными параметрами, которая будет также стартовать с разными параметрами одновременно с первой, но должна быть независима от нее (может завершаться раньше или позже и при необходимости стартовать снова, если первая задача еще не завершена). И вот здесь я наткнулся на проблему.

Alex написал:

Alex — Mon, 20 Nov 2017 22:45:55 +0300

Правильный способ - это подать сигнал внутреннему потоку, что ему пора завершаться. После этого можно подождать завершения задания. Сигнал можно подать через переменную (например, установив её в true) или событие (TEvent). Плохой способ - это убивать поток задания функцией TerminateThread: https://msdn.microsoft.com/ru-ru/library/windows/desktop/ms686717(v=vs.85).aspx.

ruslan123456 написал:

ruslan123456 — Sun, 19 Nov 2017 14:16:20 +0300

Как остановить task, если он в данный момент выполняет длительную операцию?

Максим написал:

Максим — Sun, 19 Mar 2017 20:56:49 +0300

Не знал про volatile. Спасибо за помощь, проблема решена.

Alex написал:

Alex — Sun, 19 Mar 2017 19:25:02 +0300

Если у вас Delphi Berlin, то используйте атрибут volatile: http://docwiki.embarcadero.com/RADStudio/Berlin/en/Compiler_Attributes#Volatile, иначе используйте System.TMonitor.Enter: http://docwiki.embarcadero.com/Libraries/Berlin/en/System.TMonitor.Enter(...) - System.TMonitor.Exit: http://docwiki.embarcadero.com/Libraries/Berlin/en/System.TMonitor.Exit(...).

Максим написал:

Максим — Sun, 19 Mar 2017 12:19:49 +0300

В таком случае получается не синхронизированный доступ к переменной, что может привести к плохим последствиям. А если из таска получать эту переменную через Synchronize, то от проблемы мы никуда не уходим. Пока единственное решение, которое мне приходит в голову это вот такой костыль: Вызвать его и ждать пока не отработает таск. Ещё можно HandleMessage заменить на ProcessMessages и Sleep, но смысл тот же.

Alex написал:

Alex — Sun, 19 Mar 2017 07:18:37 +0300

Здравствуйте. Вместо вызова Cancel, можете просто завести boolean-переменную, выствлять её в true, если нужно завершить таск, и ждать вызовом Wait. А в таске всё время проверять значение этой переменной, и, если оно true, то завершать таск.

Максим написал:

Максим — Fri, 17 Mar 2017 13:05:23 +0300

Здравствуйте. Помогите пожалуйста с такой проблемой. Допустим есть объект в котором запускается Task, этот таск после своей работы должен вернуть данные в основной поток, я их возвращаю через TThread.Synchronize. Однако объект может быть разрушен до отработки потока, разрушать объект в котором ещё работает таск не хорошо, нужно как-то заблокировать разрушение объекта, пока не отработает таск. Но сделать это через Wait невозможно, иначе я получу Deadlock, главный поток будет ждать окончания работы таска, а таск будет ждать освобождения главного потока, чтобы выполнить Synchronize. Классно было бы если бы можно вызвать Cancel для таска и внутри не вызывать Synchronize, если было вызвано прерывание. Но если вызвать Cancel, то уже невозможно использовать Wait. Какой-то замкнутый круг, непонятно как решить эту проблему.

Евгений написал:

Евгений — Tue, 05 Apr 2016 10:38:13 +0300

Спасибо, видимо пропустил:)

Alex написал:

Alex — Tue, 05 Apr 2016 08:45:30 +0300

Посмотрите комментарий #11: http://proghouse.ru/programming/36-delphi-xe7-ppl#comment-142 к этой статье, я там как раз привёл такой пример.

Евгений написал:

Евгений — Mon, 04 Apr 2016 11:43:13 +0300

А не могли бы сделать небольшой пример? Просто не могу понять как передать адрес функции. Все, что видел в интернете сводится к тому, что тело функции описывается при создании задания. Заранее спасибо за ответ.

Alex написал:

Alex — Sat, 02 Apr 2016 14:18:10 +0300

Можете написать функцию, которая будет принимать на вход, например, адрес сайта и циклично делать то, что вы описали. Затем создать 4 задания, в конструкторе каждому из них передать адрес сайта и адрес этой функции. Затем запустить все эти 4 задания. Только, чтобы сделать паузы, нужно использовать не таймер, а Sleep или TEvent.WaitFor.

Евгений написал:

Евгений — Sat, 02 Apr 2016 03:36:27 +0300

Здравствуйте. Подскажите пожалуйста, как с помощью этого можно реализовать следующее: Есть 4 сайта, с которых с определенной периодичностью нужно получать информацию через их API. Раз, например, в секунду нужно вызывать idhttp.get, получить из него результат и как-то обработать. Я так понимаю, что это будет вызов по таймеру, но нужно, чтобы этот запрос не "вешал" программу, т.к. параллельно должны быть запущены еще 3 таких запроса. При всем при этом пользователь должен продолжать работать с программой. Буду очень признателен за помощь.

Alex написал:

Alex — Mon, 02 Nov 2015 09:17:27 +0300

В этом случае, конечно, код программы не будет простым. Нужно отслеживать, какие элементы массива обработаны, какие не обработаны, какие изменились и их нужно обработать повторно. Также нужно контролировать количество элементов в массиве.

Maximus написал:

Maximus — Mon, 02 Nov 2015 01:56:35 +0300

А если поток цикла начнёт читать элемент и в этот момент его прервёт основной поток, который не только читает, но и пишет в массив, да ещё и изменяет его размеры? Потом цикл снова возобновит работу и начнётся "веселье".

Alex написал:

Alex — Tue, 27 Oct 2015 15:50:10 +0300

Ну, если массив не изменяется, а только читается, можете не использовать TMonitor.Enter и TMonitor.Exit.

Maximus написал:

Maximus — Tue, 27 Oct 2015 14:28:30 +0300

Что делать если мне в TParallel.For необходимо использовать проверку значений массиве структур, описанных вне этого цикла? Вызывать напрямую нельзя, а если ставить TMonitor.Enter и TMonitor.Exit тогда теряется основной смысл параллельной обработки.

Alex написал:

Alex — Tue, 08 Sep 2015 20:37:00 +0300

Официально такое не предусмотрено. Количеством потоков управляет объект TThreadPool и вы можете только изменить минимальное и максимальное количество потоков с помощью свойств MinWorkerThreads и MaxWorkerThreads. Но если очень нужно, то можно прочитать значение из приватных переменных (см. ниже). Но делать это не рекомендуется, т.к. в следующей версии библиотеки PPL всё может поменяться! Если посмотрите исходники, то увидите, что потоками управляет класс TThreadPool, у которого количество потоков хранится в переменной FWorkerThreadCount, а сами потоки - в списке FThreads. Обе эти переменные объявлены в приватной секции, так что напрямую доступа к ним нет. Поэтому используем RTTI, чтобы добраться до приватных переменных. Безопасно читать значение из переменной FWorkerThreadCount не получится, поэтому будем читать количество элементов из списка FThreads. Вот функция, которая вернёт текущее количество потоков: function GetThreadCount(threadPool: TThreadPool): integer; var rttiContext: TRttiContext; threadList: TThreadList; begin rttiContext := TRttiContext.Create; threadList := TThreadList(rttiContext.GetType(TTh readPool).GetField('FThreads').GetValue(threadPool ).AsObject); Result := threadList.LockList.Count; threadList.UnlockList; end; А вот как ею пользоваться: ShowMessage(IntToStr(GetThreadCount(TThreadPool.De fault))); Чтобы всё заработало, нужно подключить System.Rtti и Generics.Collections. Также нужно учитывать, что в общем пуле потоков будут потоки из разных TParallel.For отрабатывающих в один момент времени. Поэтому, если хотите знать, сколько потоков породилось в определёной TParallel.For, то создайте объект TThreadPool и передайте указатель на него в метод TParallel.For.

Алексей Анатольевич написал:

Алексей Анатольевич — Tue, 08 Sep 2015 05:37:16 +0300

А как узнать текущее количество запущенных с помощью TParallel.For потоков?

Alex написал:

Alex — Mon, 07 Sep 2015 22:00:57 +0300

Естествено вываливается на строке "TTask.WaitForAll(tasks);". У вас же массив из 101 элемента, вы создали только 9 заданий и сохранили указатели на них в начало массива, а остальные 92 элемента массива остались nil. Вот вы и получаете ошибку, что как минимум одно задание в массиве nil. В вашем примере массив должен быть объявлен так: inputdata: array [0..8] of integer;

Алексей Анатольевич написал:

Алексей Анатольевич — Mon, 07 Sep 2015 04:05:44 +0300

procedure TForm4.Button4Click(Sender: TObject); var i: integer; begin try for i := 0 to 8 do begin tasks := TTask.Create(TObject(i), TaskProc); tasks.Start; end; memo1.Lines.Add('wait... '); TTask.WaitForAll(tasks); memo1.Lines.Add('waited!'); Memo1.Clear; for i := 0 to 8 do Memo1.Lines.Add('Результат выполнения задачи ' + IntToStr(i) + ': ' + inttostr(inputdata)); finally for i := 0 to 8 do inputdata:=0; end; end; Вываливается с ошибкой: First chance exception at $000007FEFD71B3DD. Exception class EArgumentNilException with message 'At least one task in array nil'. Process BG.exe (5676) Последняя запись в мемо при этом: wait... Delphi XE8, Win7x64

Алексей Анатольевич написал:

Алексей Анатольевич — Mon, 07 Sep 2015 04:03:41 +0300

{ ... } type TForm4 = class(TForm) { ... } private { Private declarations } tasks: array[0..100] of ITask; inputdata: array [0..100] of integer; procedure TaskProc(Sender: TObject); { ... } procedure TForm4.TaskProc(Sender: TObject); var myIndex: integer; begin myIndex := Integer(Sender); Sleep(myIndex * 1000); System.TMonitor.Enter(self); try inputdata[myIndex] := myIndex*myIndex; finally System.TMonitor.Exit(self); end; end;

Alex написал:

Alex — Fri, 29 May 2015 12:12:55 +0300

Чтобы передать параметры в задание, нужно использовать конструктор Create(Sender: TObject; Event: TNotifyEvent). И здесь уже с помощью первого аргумента (Sender) можно передать что угодно. Вот пример использования: unit Unit1; interface uses Winapi.Windows, Winapi.Messages, System.SysUtils, System.Variants, System.Classes, Vcl.Graphics, Vcl.Controls, Vcl.Forms, Vcl.Dialogs, Vcl.StdCtrls, System.Threading; type TForm1 = class(TForm) Button1: TButton; Memo1: TMemo; procedure Button1Click(Sender: TObject); private { Private declarations } tasks: array[0..8] of ITask; inputdata: array [0..8] of TStrings; procedure TaskProc(Sender: TObject); public { Public declarations } end; var Form1: TForm1; implementation {$R *.dfm} procedure TForm1.TaskProc(Sender: TObject); var myIndex: integer; begin //Получаем индекс задания. myIndex := Integer(Sender); //Что-то делаем. Sleep(myIndex * 1000); //Блокируем доступ к общим ресурсам. System.TMonitor.Enter(self); try //Создаём объект TStringList. inputdata[myIndex] := TStringList.Create; //Заполняем его. inputdata[myIndex].Text := 'Задача ' + IntToStr(myIndex) + ' выполнена'; finally //Разблокируем доступ к общим ресурсам. System.TMonitor.Exit(self); end; end; procedure TForm1.Button1Click(Sender: TObject); var i: integer; task1: ITask; begin try for i := 0 to 8 do begin //Инициализируем массив. inputdata := nil; //При создании задачи используем конструктор //class function Create(Sender: TObject; Event: TNotifyEvent): ITask; overload; static; inline; //и вместо указателя на TObject передаём наш индекс (Integer). //Вообще здесь можно и нужно передавать указатель на экземпляр класса, //в котором хранятся необходимые для задачи данные. tasks := TTask.Create(TObject(i), TaskProc); end; //Запускаем задачи. for task1 in tasks do task1.Start; //Ждём завершение всех задач. TTask.WaitForAll(tasks); //Выводим результат. Memo1.Clear; for i := 0 to 8 do if assigned(inputdata) then Memo1.Lines.Add('Результат выполнения задачи ' + IntToStr(i) + ': ' + inputdata.Text); finally //Удаляем мусор. for i := 0 to 8 do if assigned(inputdata) then inputdata.Free; end; end; end.

Smog написал:

Smog — Fri, 29 May 2015 11:23:27 +0300

Писал код в блокнотие, ИДЕ прям щас под рукой нет, само собой tasks := TTask.Create(procedure()

Smog написал:

Smog — Fri, 29 May 2015 10:15:18 +0300

var tasks: array[0....8] of ITask; task1: ITask; inputdata : array [0..8] of TStringsList; Я пытаюсь динамически создавать задания, а не в ручную создавать каждое. for i:=0 to 8 do Begin tasks := TTask.Create(procedure() // я так понимаю это фактически анонимный метод var task: ITask; stopwatch, curPos, maxPos: integer; begin //вопрос в том как мне передать индекс i внутрь этой констркции //ЧТобы каждый отдельный ITask работал с inputdata; //при обычно создании все воркеры будет запущены с i=9 в моем примере //а я пытаюсь добится tasks[0]->inputdata[0], //tasks[1]->inputdata[1] и и.д. //Можно руками запрограмировать если без динамического создания, но если потоков много.... end;); for task1 in tasks do task1.Start;

Smog написал:

Smog — Fri, 29 May 2015 10:14:47 +0300

Спасибо огромное за отличную статью, я основной косяк своего прилождения на FMX и PLL уже набросал, благодаря Вашей статье все работает. Нашел 1 странный момент в котором так и не смогу разобратся. ДОпустим есть

Smog написал:

Smog — Fri, 29 May 2015 09:54:19 +0300

Спасибо, теперь все очень понятно написано. itasks.Status; не работало потому что взаимодействие с формой через Label6.Text:='0'; нужно делать из Thread.Synchronize.

Alex написал:

Alex — Thu, 28 May 2015 16:00:46 +0300

Добавил пример для прерывания цикла TParallel.For.

Alex написал:

Alex — Wed, 27 May 2015 10:27:30 +0300

Метод CheckCanceled просто вызывает ошибку EOperationCanceled, если статус Canceled. А что конкретно не заработало со статусом? Происходит ошибка или статус не определяется? У меня ваш код выдаёт 2-ку, а после отмены - 5-ку. Пример с отменой и проверкой статуса добавил в статью.

Smog написал:

Smog — Tue, 26 May 2015 19:11:30 +0300

Для отмены работы потока помолго: ttask.CurrentTask.CheckCanceled; До єтого конечно надо команду на остановку дать: tasks[2].Cancel; А вот проверка статуса потока, так и не заработала. Код такого вида, упорно не отрабатывает: status:=itasks[2].Status; // status.Running case status of ttaskstatus(0): Label6.Text:='0'; ttaskstatus(1): Label6.Text:='1'; ttaskstatus(2): Label6.Text:='2'; ttaskstatus(3): Label6.Text:='3'; ttaskstatus(4): Label6.Text:='4'; ttaskstatus(5): Label6.Text:='5'; ttaskstatus(6): Label6.Text:='6'; end;

Smog написал:

Smog — Tue, 26 May 2015 09:58:01 +0300

Спасибо огромное! А можно мини пример очистки мусора и выхода из задачи. Как проверять - понял.

Alex написал:

Alex — Tue, 26 May 2015 07:54:32 +0300

Извне вы никак не можете завершить задачу (т.е. поток). Вы только можете оповестить задачу о том, что ей нужно завершиться: вызвать метод Cancel. А внутри процедуры задачи в цикле нужно всё время проверять статус (свойство Status), и, если статус установился в Canceled, то нужно подчищать мусор и выходить из процедуры задачи.

Smog написал:

Smog — Mon, 25 May 2015 21:53:57 +0300

День добрый, как принудительно завершить выполнение потока. Например такого бесконечного цикла внутри потока: itasks[0] := TTask.Create (procedure () var d:Integer; begin d:=0; while d=0 do begin sleep (2000); // 2 seconds TInterlocked.Add (a, 2000); Label1.Text:=a.ToString; Progressbar1.Value:=Progressbar1.Value+1; end; end );