|
#1
|
|||
|
|||
Работа с потоками
Наверняка уже много раз тема обсуждалась, но хочу попросить совета по правильной реализации задачи в словах и примерах кода.
Итак, программа занимается обработкой данных, это может занять продолжительное время, поэтому нужна кнопка приостановки процесса. Во время обработки данных происходит изменение компонентов Gauge и Memo. Открыв проект в новой версии студии получаю ошибку при компилировании, последняя ли это версия проекта и было ли что-то после нормальной сборки непонятно (давно занимался проектом). Итак, вопросы по реализации: при остановке процесса поток приостанавливать с возможностью продолжения или полной остановки, в первом случае вызываем resume, во втором Terminate? в данный момент компилятор ругается на функцию синхронизации. Напишите пример взаимодействия, описания и выполнения действий, у меня пока так реализовано: Код:
type MyThread = class(TThread) protected CriticalSection: TCriticalSection; procedure UpdateMemo(Text: string); procedure UpdateGauge(Position: Integer); procedure Execute; override; procedure Analys; end; var AnalysThread: MyThread; procedure TForm1.FormCreate(Sender: TObject); begin try AnalysThread := MyThread.Create(True); AnalysThread.FreeOnTerminate := False; AnalysThread.Priority := tpLower; //..... end; procedure TForm1.StartProcessClick(Sender: TObject); begin AnalysThread.Resume; //..... end; procedure TForm1.StopProcessClick(Sender: TObject); begin AnalysThread.Terminate; //.... end; procedure MyThread.Analys; begin try if AnalysThread.Terminated then Exit; CriticalSection.Enter; //.... Synchronize(UpdateMemo(StringList.Text)); //.... finally CriticalSection.Leave; end; end; procedure MyThread.Execute; begin inherited; if not AnalysThread.Terminated then AnalysThread.Synchronize(Analys); end; procedure MyThread.UpdateGauge(Position: Integer); begin Form1.Gauge.Progress := Position; end; procedure MyThread.UpdateMemo(Text: string); begin Form1.Memo.Text := Text; Form1.Memo.Refresh; end; Для начала имхо надо вместо двух кнопок для начала/остановки обработки сделать одну и проверять состояние потока (Suspend/Terminate?). И мне не нравится взаимодействие с потоками в процедуре анализа... в общем внимательно выслушаю предложения по приведению кода в нормальный вид и главное рабочий. Последний раз редактировалось novashdima, 12.03.2014 в 06:05. |
#2
|
|||
|
|||
во первых
Код:
procedure MyThread.Execute; begin while not Terminated do Analys; end; end; во вторых, у Synchronize параметром должен быть метод без параметров. В третьих - где Код:
CriticalSection:= TCriticalSection.Create; В четвёртых - что с чем Вы пытаетесь синхронизировать с помощью этой критической секции? Если разные потоки, то для них эта секция должна быть одна, а не по секции в каждом потоке. |
#3
|
||||
|
||||
Цитата:
Цитата:
Цитата:
Цитата:
Последний раз редактировалось novashdima, 12.03.2014 в 14:00. |
#4
|
||||
|
||||
Цитата:
Цитата:
|
#5
|
|||
|
|||
Цитата:
Цитата:
|
#6
|
||||
|
||||
Вероятно имелся ввиду классический вариант "своего" потока, типа как в примере из DRKB
Код:
type TMyThread = class(TThread) private Answer: integer; protected procedure ShowResult; procedure Execute; override; end; implementation //Процедура для вывода информации из потока procedure TMyThread.ShowResult; begin Form1.Memo.Text:= IntToStr(Answer); Form1.Memo.Refresh; end; procedure TMyThread.Execute; var i: Integer; begin for i := 1 to 10000 do begin Inc(answer); Synchronize(ShowResult); end; end; procedure TForm1.Button1Click(Sender: TObject); var MyThread: TMyThread; begin MyThread:= TMyThread.Create(false); end; Я не понял Вашего вопроса, но всё же Вам на него отвечу! |
#7
|
|||
|
|||
Цитата:
И нашел я, где провтыкал, в описании процедур забыл убрать параметр. Вот только при создании критической секции получаю AV по Cx5. Что по этому поводу скажете? |
#8
|
||||
|
||||
Цитата:
Цитата:
Код:
type MyThread = class(TThread) private StringList: TStringList; ..... end; Код:
procedure MyThread.UpdateMemo({БЕЗ ПАРАМЕТРОВ}); begin Form1.Memo.Text := StringList.Text; Form1.Memo.Refresh; end; Цитата:
UPD. Ага. Пока я писал, смотрю ты уже нашёл у себя в чём ошибка. Последний раз редактировалось poli-smen, 12.03.2014 в 15:47. |
#9
|
||||
|
||||
Цитата:
|
#10
|
|||
|
|||
Цитата:
Цитата:
Код:
CriticalSection.Create; Последний раз редактировалось novashdima, 12.03.2014 в 16:02. |
#11
|
||||
|
||||
Вариант от Пачеко - "Поток с доступом к глобальной переменной основной программы"
Код:
{ NOTE: Change GlobalStr from var to threadvar to see difference } var //threadvar GlobalStr: string; type TTLSThread = class(TThread) private FNewStr: string; protected procedure Execute; override; public constructor Create(const ANewStr: string); end; procedure SetShowStr(const S: string); begin if S = '' then MessageBox(0, PChar(GlobalStr), 'The string is...', MB_OK) else GlobalStr := S; end; constructor TTLSThread.Create(const ANewStr: string); begin FNewStr := ANewStr; inherited Create(False); end; procedure TTLSThread.Execute; begin FreeOnTerminate := True; SetShowStr(FNewStr); SetShowStr(''); end; procedure TMainForm.Button1Click(Sender: TObject); begin SetShowStr('Hello world'); SetShowStr(''); TTLSThread.Create('Dilbert'); Sleep(100); SetShowStr(''); end; З.Ы. Приостановить/продолжить/грохнуть выполнение потока, насколько помню это ведь через Suspend/Resume/Terminate выполняется из главного потока сборки Я не понял Вашего вопроса, но всё же Вам на него отвечу! |
#12
|
||||
|
||||
Цитата:
Я имею ввиду вот эту строчку: Цитата:
Цитата:
Код:
CriticalSection := TCriticalSection.Create; |
#13
|
||||
|
||||
Цитата:
А насчет последнего все правильно. Цитата:
Цитата:
Цитата:
Сейчас вроде как даже все работает и программа не виснет, сейчас проверяю, правильно ли все чищу при остановке процесса до начала следующего. А пока вопрос, правильно ли я чищу динамически созданные объекты? Код:
if Assigned(StringList) then FreeAndNil(StringList); Последний раз редактировалось novashdima, 12.03.2014 в 16:46. |
#14
|
||||
|
||||
Цитата:
UPD. Ну то есть, в смысле, зачем тогда методу UpdateMemo нужен параметр? Достаточно просто сообщить форме чтобы она обновила Мемо, а свойство Text из StringList форма может сама без всякой синхронизации прочитать - это же её объект. Последний раз редактировалось poli-smen, 12.03.2014 в 16:40. |
#15
|
|||
|
|||
Посмотрите, все ли правильно, а то вдруг утечки памяти какие и что-то подобное.
Иногда прога подвисает после приостановки и иногда возникает floating point division by zero на строке 73. И когда останавливаю и потом заново стартую обработка начинается с прошлого места, и это связано с ошибкой выше, хотя вроде как все, что можно чищу. Код:
type MyThread = class(TThread) private Position: Integer; protected procedure UpdateMemo; procedure UpdateGauge; procedure Execute; override; procedure Analys; end; var AnalysThread: MyThread; CriticalSection: TCriticalSection; StringList, PathList, ErrorStringList: TStringList; procedure TForm1.StartProcessClick(Sender: TObject); begin if AnalysThread.Suspended then begin AnalysThread.Resume; ***** end else begin AnalysThread.Suspend; ****** end; end; procedure TForm1.StopProcessClick(Sender: TObject); begin AnalysThread.Terminate; ClearForm; end; procedure TForm1.FormCreate(Sender: TObject); begin try AnalysThread := MyThread.Create(True); AnalysThread.FreeOnTerminate := False; AnalysThread.Priority := tpLower; CriticalSection := TCriticalSection.Create; ****** except if Assigned(StringList) then FreeAndNil(StringList); ***** end; end; procedure TForm1.FormDestroy(Sender: TObject); begin if not AnalysThread.Terminated then AnalysThread.Terminate; while not (AnalysThread.Terminated) do begin Sleep(100); Application.ProcessMessages; end; if Assigned(StringList) then FreeAndNil(StringList); **** end; procedure MyThread.Analys; begin try if AnalysThread.Terminated then Exit; CriticalSection.Enter; ***** StringList.LoadFromFile(PathList.Strings[i]); Synchronize(UpdateMemo); ***** Position := Round(Form1.Gauge.MaxValue / Form1.ListBox.Count * i); Synchronize(UpdateGauge); finally Synchronize(Form1.ClearForm); **** CriticalSection.Leave; end; end; procedure MyThread.Execute; begin inherited; while not Terminated do Analys; end; procedure MyThread.UpdateGauge; begin Form1.Gauge.Progress := Position; end; procedure MyThread.UpdateMemo; begin Form1.Memo.Text := StringList.Text; Form1.Memo.Refresh; end; Последний раз редактировалось novashdima, 12.03.2014 в 17:03. |