[poli-smen]

Сообщение от novashdima

Посмотрите, все ли правильно, а то вдруг утечки памяти какие и что-то подобное.
Иногда прога подвисает после приостановки и иногда возникает floating point division by zero на строке 73.
И когда останавливаю и потом заново стартую обработка начинается с прошлого места, и это связано с ошибкой выше, хотя вроде как все, что можно чищу.

Код:

.....
procedure TForm1.StartProcessClick(Sender: TObject);
begin
  if AnalysThread.Suspended
  then begin
         AnalysThread.Resume;
         *****
         end
  else begin
        AnalysThread.Suspend;
        ******
        end;
end;

Не рекомендуется насильно приостанавливать из одного потока другой. Об этом написано в справке MSDN и по-русски. Лучше всего сообщить потоку что он должен быть приостановлен и тогда сам поток дойдя до безопасной точки сам себя приостановит.

Сообщение от novashdima

Код:

   Position := Round(Form1.Gauge.MaxValue / Form1.ListBox.Count * i);

Здесь может быть деление на ноль.

И ещё немного смущают манипуляции с StringList. Создавать его лучше по-нужде, перед использованием проверять на наличие и разрушать в завершении приложения. Либо же создавать однажды при запуске приложения и разрушать при завершении приложения.

[novashdima]

Сообщение от poli-smen

Не рекомендуется насильно приостанавливать из одного потока другой. Лучше всего сообщить потоку что он должен быть приостановлен и тогда сам поток дойдя до безопасной точки сам себя приостановит.

И где эта безопасная точка находится? При выполнении в форе произойдет остановка? Как сообщить?
Сделать еще один флаг, и вместо фора поставить вайл с проверкой флага? Просто одно действие в форе может выполняться достаточно долго и будет впечатление что или прога зависла или вообще никак не реагирует на кнопку.

Сообщение от poli-smen

Здесь может быть деление на ноль.

Добавлю проверку, но вообще по логике программы не должна вызывать процедура обработки, если данные пустые.

Сообщение от poli-smen

И ещё немного смущают манипуляции с StringList. Создавать его лучше по-нужде, перед использованием проверять на наличие и разрушать в завершении приложения. Либо же создавать однажды при запуске приложения и разрушать при завершении приложения.

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

[icWasya]

Код:

if Assigned(StringList) then
    FreeAndNil(StringList); 

Внутри FreeAndNil проверка на Nil уже есть, та кчто можно писать просто

Код:

 FreeAndNil(StringList); 

Далее
Я уже спрашивал - что с чем синхронизируется спомощью CriticalSection ?
Если она используется только в одном потоке, то она не нужна.

[poli-smen]

Сообщение от novashdima

И где эта безопасная точка находится?

Ну это когда поток отпустит все критические секции и другие объекты.
Например здесь:

Код:

procedure MyThread.Execute;
begin
//  inherited; Это здесь не нужно
  while not Terminated do
  begin
    // Безопасная точка - проверяем не нужно ли приостановиться (Suspend)
     Analys;
  end;
end;

Сообщение от novashdima

При выполнении в форе произойдет остановка? Как сообщить?
Сделать еще один флаг, и вместо фора поставить вайл с проверкой флага? Просто одно действие в форе может выполняться достаточно долго и будет впечатление что или прога зависла или вообще никак не реагирует на кнопку.

Можно использовать для оповещения например сигнал TEvent, а проверять не приостановился ли поток через TEvent.WaitFor(100).

Сообщение от novashdima

Добавлю проверку, но вообще по логике программы не должна вызывать процедура обработки, если данные пустые.

Всегда лучше перестраховаться

Сообщение от novashdima

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

Если так, то вот этого делать не нужно:

Сообщение от novashdima

Код:

procedure TForm1.FormCreate(Sender: TObject);
begin
  try
.....
    ******
  except
    if Assigned(StringList) then
      FreeAndNil(StringList);
    *****
  end;
end;

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

[novashdima]

Сообщение от poli-smen

Ну это когда поток отпустит все критические секции и другие объекты.
Например здесь:

Код:

procedure MyThread.Execute;
begin
//  inherited; Это здесь не нужно
  while not Terminated do
  begin
    // Безопасная точка - проверяем не нужно ли приостановиться (Suspend)
     Analys;
  end;
end;

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

Сообщение от poli-smen

Можно использовать для оповещения например сигнал TEvent, а проверять не приостановился ли поток через TEvent.WaitFor(100).

Вот это уже хорошая идея, надо будет попробовать.

Сообщение от poli-smen

Всегда лучше перестраховаться.

Я обычно очень много проверок ставлю, но потом постепенно улучшаю правило проверки и убираю ненужное после этого.

Сообщение от poli-smen

Если так, то вот этого делать не нужно:Т.е. при запуске приложения создали при завершении приложения разрушили, а посреди никаких созданий и разрушений быть не должно, в том числе и при ошибках.

Так этот код выполняется только если вылетело исключение, там же try except, если все завершилось удачно то ничего не разрушается

[poli-smen]

Сообщение от novashdima

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

Метод Execute это уже и есть работа потока, так что проверка выполнится уже во время работы параллельного потока, и не один раз - там же цикл "while not Terminated do", т.е. пока поток не попросят завершиться этот цикл будет вертеться. Хотя конечно ничто не мешает поставить проверку и после вызова Analys

Сообщение от novashdima

Вот это уже хорошая идея, надо будет попробовать.

Можно сделать ещё проще - с помощью InterlockedExchange:

Код:

type
  MyThread = class(TThread)
  private
    FSuspendNeeded: LongBool;
    procedure SetSuspendNeeded(const Value: LongBool);
  public
    property SuspendNeeded: LongBool read FSuspendNeeded write SetSuspendNeeded;
  protected
    procedure Execute; override;
  end;

{ MyThread }

procedure MyThread.Execute;
begin
  while not Terminated do
  begin
    Analys;
    if SuspendNeeded then Suspend;
  end;
end;

procedure MyThread.SetSuspendNeeded(const Value: LongBool);
begin
  if FSuspendNeeded <> Value then
    Windows.InterlockedExchange(LongInt(FSuspendNeeded), LongInt(Value));
end;

Таким образом в главном потоке можно без проблем просить приостановки параллельного потока:

Код:

AnalysThread.SuspendNeeded := True;

А через свойство AnalysThread.Suspended периодически проверять не приостановлся ли уже поток.

Сообщение от novashdima

Так этот код выполняется только если вылетело исключение, там же try except, если все завершилось удачно то ничего не разрушается

Но при ошибке то разрушается. И тем временем уже созданный параллельный поток будет пытаться работать с уже разрушенным объектом.

[novashdima]

Сообщение от poli-smen

Но при ошибке то разрушается. И тем временем уже созданный параллельный поток будет пытаться работать с уже разрушенным объектом.

Почему это? Он только создан будет, но он будет приостановлен и не запуститься, пока я ему не передам Resume.
Насчет остального спасибо, завтра буду пробовать, а то надо на работу бежать уже.

[poli-smen]

Сообщение от novashdima

Почему это? Он только создан будет, но он будет приостановлен и не запуститься, пока я ему не передам Resume.

В любом случае зачем его при возникновении исключения разрушать если при завершении приложения он будет всё равно разрушен. Лишний код на который потом (при разрастании приложения) можно наступить как на грабли.

[novashdima]

Сообщение от poli-smen

Таким образом в главном потоке можно без проблем просить приостановки параллельного потока

Вроде как поток останавливается, но прогрессбар и мемо продолжают обновляться...

ап. поставил в цикле обработки в процедуре Анализ проверку на AnalysThread.Suspended, он всегда равен false, запустил программу, запустил обработку данных, приостановил выполнение и оказывается SuspendNeeded меняется на true, но поток не приостанавливается. Мне еще и в сам цикл во время обработки данных впихнуть проверку значения SuspendNeeded?

Да, еще всегда интересовали, можно настроить отладчик так, чтобы при отладке я трассировал только код своей программы, не заходя в System.SysUtils и тому подобные?

[poli-smen]

Сообщение от novashdima

ап. поставил в цикле обработки в процедуре Анализ проверку на AnalysThread.Suspended, он всегда равен false, запустил программу, запустил обработку данных, приостановил выполнение и оказывается SuspendNeeded меняется на true, но поток не приостанавливается.

Ну так SuspendNeeded и не останавливает поток, оно только сообщает потоку, что ему следует приостановиться сразу же как он дойдёт до ближайшей безопасной точки.

Сообщение от novashdima

Мне еще и в сам цикл во время обработки данных впихнуть проверку значения SuspendNeeded?

Если там есть безопасная точка. Чем чаще будут проверки значения SuspendNeeded, тем быстрее поток будет реагировать на просьбу приостановиться.

Сообщение от novashdima

Да, еще всегда интересовали, можно настроить отладчик так, чтобы при отладке я трассировал только код своей программы, не заходя в System.SysUtils и тому подобные?

Сними в настройках проекта галочку: Меню -> "Project" -> "Options..." -> "Compiler" -> "Debugging" -> "Use Debug DCUs" (Это в Delphi 7. В XE3 должно быть примерно так же.)
После чего сохрани и перестрой проект: Меню -> "Project" -> "Build All Projects"

[novashdima]

Сообщение от poli-smen

Ну так SuspendNeeded и не останавливает поток, оно только сообщает потоку, что ему следует приостановиться сразу же как он дойдёт до ближайшей безопасной точки.Если там есть безопасная точка. Чем чаще будут проверки значения SuspendNeeded, тем быстрее поток будет реагировать на просьбу приостановиться.

Так мне самому нужно указывать эту самую безопасную точку?
Каким образом в коде обработки указать, что поток может быть приостановлен?

Сообщение от poli-smen

Сними в настройках проекта галочку: Меню -> "Project" -> "Options..." -> "Compiler" -> "Debugging" -> "Use Debug DCUs" (Это в Delphi 7. В XE3 должно быть примерно так же.)
После чего сохрани и перестрой проект: Меню -> "Project" -> "Build All Projects"

Галочка итак снята

[poli-smen]

Сообщение от novashdima

Так мне самому нужно указывать эту самую безопасную точку?

Ну конечно же самому. Здесь всего 2 варианта. Либо в наглую остановить поток через Suspend. Или же установить некий флаг сообщающий потоку, что он должен быть остановлен, тогда поток в тех местах в которых может безопасно остановится должен проверять этот флаг и при необходимости останавливаться. Например, если поток сейчас выполняет запись на лазерный диск (DVD-R), а мы его внаглую остановим через Suspend, то вместе с ним остановится и запись диска, которая уже вряд-ли продолжится если вновь запустить приостановленный поток, а недописанную болванку можно выкинуть.

Сообщение от novashdima

Каким образом в коде обработки указать, что поток может быть приостановлен?

Проверять флаг SuspendNeeded и при необходимости самого себя останавливать с помощью Suspend

Сообщение от novashdima

Галочка итак снята

В Delphi 7 снятия этой галочки достаточно. Видимо в XE3 что-то ещё намудрили - нужно с настройками XE3 отдельно разбираться.

[novashdima]

Сообщение от poli-smen

Ну конечно же самому.

Ну я так и думал, сделал, все работает, разве что есть вопрос, не лишние ли действия делаю, вот код:

Код:

procedure TForm1.StartProcessClick(Sender: TObject);
begin
  if AnalysThread.Suspended
  then begin
        AnalysThread.SuspendNeeded := False;
        AnalysThread.Resume;
       end
  else begin
        AnalysThread.SuspendNeeded := True;
       end;
end;

procedure TForm1.StopProcessClick(Sender: TObject);
begin
  AnalysThread.Terminate;
  ClearForm;
end;

procedure MyThread.Analys;
begin
  try
   if AnalysThread.Terminated then Exit;
   if AnalysThread.SuspendNeeded then AnalysThread.Suspend;
   CriticalSection.Enter;
   for i := 0 to Form1.ListBox.Count - 1 do
    begin
    if SuspendNeeded then AnalysThread.Suspend;
    .....
  finally
      Synchronize(Form1.ClearForm);
  end;
end;

procedure MyThread.Execute;
begin
  while not Terminated do
  begin
    if SuspendNeeded then Suspend;
    Analys;
  end;
end;

procedure MyThread.SetSuspendNeeded(const Value: LongBool);
begin
  if FSuspendNeeded <> Value then
     InterlockedExchange(LongInt(FSuspendNeeded), LongInt(Value));
end;

procedure MyThread.UpdateGauge;
begin
  if not AnalysThread.Suspended
  then Form1.Gauge.Progress := Position;
end;

procedure MyThread.UpdateMemo;
begin
  if not AnalysThread.Suspended
  then begin
        Form1.Memo.Text := StringList.Text;
        Form1.Memo.Refresh;
       end;
end;

[icWasya]

Просто правила хорошего тона

Код:

procedure MyThread.UpdateGauge;
begin
  if not AnalysThread.Suspended
   then Form1.Gauge.Progress := Position; 
end; 

Внутри методов MyThread не рекомендуется использовать переменную AnalysThread - лучше писать Self, во так

Код:

procedure MyThread.UpdateGauge;
begin
  if not Self.Suspended
   then Form1.Gauge.Progress := Position; 
end; 

или ничего вообще, вот так

Код:

procedure MyThread.UpdateGauge;
begin
  if not Suspended
   then Form1.Gauge.Progress := Position; 
end; 

[NumLock]

а разве использование глобальной Form1 в потоке хороший тон?