Работа и корректное завершение потока TThread в любой ситуации...

[spamer]

Всем привет. Возник вопрос по работе с потоками.
Вобщем, есть некий код ("запутанный в классы") который обрабатывает запрос к некоему сайту (авторизируется, забирает нужную информацию, отправляет информацию и т.п.). Как можно понять, при обработке всего этого программа ясное дело "молчит". Посему было решено, некоторый участок кода, который занимается обработкой - вынести в поток. Но появились же вопросы (хотя вроде и перечитал достаточно мануалов, но все равно на практике никогда с потоками не сталкивался поэтому решил уточнить/узнать некоторые моменты).
Вот мой пример того, что сделал (код подчищен - убраны лишние участки для читаемости):

  THttpThread = class(TThread)
    protected
      procedure Execute; override;
  end;
...

var
  HttpThread: THttpThread;

...

procedure TframeUserInfo.DoOnActionFrame(Sender: TObject);
begin
  try
    // Подготовка объектов и необходимых данных для них
    ...
    

    // Основной алгорит который хотелось бы вынести в поток

    // Нужен всего лишь один поток, поэтому выходим из обработчика если поток еще работает (данная часть кода отрабатывает не корректно, ибо поток по завершении не становится nil.  (з.ы. крит. секции тут использовать не хотелось бы). Как быть?
    if Assigned(HttpThread) then
      Exit;

    HttpThread := THttpThread.Create(True);
    try
      /// Что бы поток сам уничтожился после завершения - как я понимаю, этого не происходит, ибо код выше (проверка на выход) работает не правильно. Как быть?
      HttpThread.FreeOnTerminate := True;
      HttpThread.Resume;
      // Ждем пока поток полностью не отработает, после чего идем дальше. Смущает меня эта часть кода. Что скажите?
      while not HttpThread.Finished do
        Application.ProcessMessages;
    except
      // В случае чего кидаем мессагу, что бы корректно (вроде...) завершить и уничтожить поток. Правильно ли?
      on E: Exception do
        PostMessage(Handle, SS_FREE_HTTP_THREAD, 0, 0);
    end;

     // Работа с новыми/старыми объектами
     ...
  finally
    // Уничтожение всего того, что было создано
  end;
end;

...

procedure THttpThread.Execute;
begin
  // Некоторый код для обработки http запросов.
end;

...

// Обработчик мессаги для завершения и уничтожения потока в случае чего либо. Правильно ли?
procedure TframeUserInfo.SSFreeHttpThread(var Msg: TMessage);
begin
  if not Assigned(HttpThread) then
    Exit;

  HttpThread.Terminate;
  HttpThread.WaitFor;
  FreeAndNil(HttpThread);
end;

Так вот, из всего того, что написал выше, могли бы вы указать что в том коде не правильного и как исправить (писать за меня не прошу ). Ну и один из мучающих меня вопросов - а как быть, если пользователь запустил уже обработчик, поток работает, и тут бац пользователю захотелось закрыть программу? При закрытии программы может в таком случае бросать мессагу на завершение потока, как в примере выше? Или что бы вы могли посоветовать?
Заранее спасибо. Надеюсь никого не испугаю написанным здесь...

[GunSmoker]

Кажется, тебе сюда.

По коду:

1. После этих строк:

      HttpThread.FreeOnTerminate := True;
      HttpThread.Resume;

Обращений к переменной HttpThread быть не должно. И вообще, FreeOnTerminate и отдельная переменная потока обычно несовместимы. Либо убирай FreeOnTerminate, либо меняй логику кода. FreeOnTerminate предназначен для "выстрелил - и забыл".

2.

  if not Assigned(HttpThread) then
    Exit;

  HttpThread.Terminate;
  HttpThread.WaitFor;
  FreeAndNil(HttpThread);

Заменяется:

  FreeAndNil(HttpThread);

Если внутри потока проверяется Terminated, то заменяется на:

  if not Assigned(HttpThread) then
    Exit;
  HttpThread.Terminate;
  FreeAndNil(HttpThread);

3. Не ясно, как поток согласован с DoOnActionFrame. В частности:

// Уничтожение всего того, что было создано

В том числе и объектов, необходимых для работы потока?

[spamer]

И вообще, FreeOnTerminate и отдельная переменная потока обычно несовместимы.

Не понял, а за какую отдельную переменную потока вы говорите? Там же только один объект - HttpThread. Или я чего-то не так понял в этом предложении?
С остальными пунктами вроде более ли мение ясно...
Такс, а вот насчет этого:

3. Не ясно, как поток согласован с DoOnActionFrame.
...
В том числе и объектов, необходимых для работы потока?

DoOnActionFrame - это обработчик мессаги для одного из нескольких фреймов. Т.е. из некой формы отсылается мессага нужному фрейму, которая передает управление на некоторое время этому фрейму...вот.
// Уничтожение всего того, что было создано - тут уже идет непосредственное уничтожение всех темповых объектов которые должны были что-то передать главному, перед тем как главный объект запустит свою цепочку действий (можно сказать - основной алгоритм для соответствующего типа объекта); затем удаление именно основных объекта; некоторых менеджеров...ну и т.п.

Вобщем, насколько я понял, должно быть что-то типа такого?

procedure TframeUserInfo.DoOnActionFrame(Sender: TObject);
begin
  try
    // Подготовка объектов и необходимых данных для них
    ...
    if Assigned(HttpThread) then
      Exit;

    HttpThread := THttpThread.Create(True);
    try
      HttpThread.Resume;
      // Ждем пока поток полностью не отработает, после чего идем дальше. Смущает меня эта часть кода. Что скажите?
      while not HttpThread.Finished do
        Application.ProcessMessages;
    except
        PostMessage(Handle, SS_FREE_HTTP_THREAD, 0, 0);
    end;

     // Работа с новыми/старыми объектами
     ...
  finally
    // Уничтожение всего того, что было создано
  end;
end;

procedure TframeUserInfo.SSFreeHttpThread(var Msg: TMessage);
begin
  if not Assigned(HttpThread) then
    Exit;

  FreeAndNil(HttpThread);
end;

Кстати, внутри потока Terminated не проверяется. Там по большому счету вызывается всего лишь метод основного объекта, который выполняет бОльшую часть действий и который я захотел вынести в отдельный поток.
Ах и да, а как же быть с ситуацией закрытия приложения во время обработки потока? Не, ну можно конечно пойти более простым путем - выдавать диалог с информацией о состоянии обработки и этим же запретить закрытие приложения пока все не отработает...но все же интересно как это с потоками именно провернуть...

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

[Аватар]

HttpThread.Resume;
      // Ждем пока поток полностью не отработает, после чего идем дальше. Смущает меня эта часть кода. Что скажите?
      while not HttpThread.Finished do
        Application.ProcessMessages;

Не понятна сама идея - запускаем триаду и ждем пока не завершится. А зачем тогда вообще триада нужна?

[GunSmoker]

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

Не понял, а за какую отдельную переменную потока вы говорите? Там же только один объект - HttpThread.

Про него и говорю. FreeOnTerminte означает, что HttpThread может быть удалена в любой момент. Что означает, что обращение к ней после запуска потока не безопасно.

Это можно обойти, но чем обходить - лучше убрать FreeOnTerminate. Не для того оно предназначено.

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

DoOnActionFrame - это обработчик мессаги для одного из нескольких фреймов. Т.е. из некой формы отсылается мессага нужному фрейму, которая передает управление на некоторое время этому фрейму...вот.
// Уничтожение всего того, что было создано - тут уже идет непосредственное уничтожение всех темповых объектов которые должны были что-то передать главному, перед тем как главный объект запустит свою цепочку действий (можно сказать - основной алгоритм для соответствующего типа объекта); затем удаление именно основных объекта; некоторых менеджеров...ну и т.п.

"главному" - кому/чему?

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

Вобщем, насколько я понял, должно быть что-то типа такого?

Ты определись - ты хочешь действия в потоке выпонять синхронно или асинхронно?

Т.е. синхронно - это: что-то делаешь, запустил поток, потом ждёшь, пока поток не отработает, продолжаешь работать дальше.

Асинхронно - это: что-то делаешь, запустил поток, продолжаешь работать дальше, когда поток завершается - ты доделываешь ещё работу.

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

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

Ах и да, а как же быть с ситуацией закрытия приложения во время обработки потока? Не, ну можно конечно пойти более простым путем - выдавать диалог с информацией о состоянии обработки и этим же запретить закрытие приложения пока все не отработает...но все же интересно как это с потоками именно провернуть...

В потоке нужно проверять условие выхода (Terminated) и досрочно прерывать работу.

Сообщение от Аватар

Не понятна сама идея - запускаем триаду и ждем пока не завершится. А зачем тогда вообще триада нужна?

Во время ожидания потока работает интерфейс и UI не виснет.

[spamer]

"главному" - кому/чему?

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

Ты определись - ты хочешь действия в потоке выпонять синхронно или асинхронно?

Вот...действия должны выполняться синхронно. Я так понимаю, выше приведенная часть кода (пост #3) как раз и является реализацией нечто похоже на синхронный тип потока. Так ведь или все же нет?

[eduard93]

Лучше заменить ProcessMessages на HandleMessage, чтобы не нагружать пустой работой проц.

[GunSmoker]

Если надо синхронно, то получаем:

procedure TframeUserInfo.DoOnActionFrame(Sender: TObject);
begin
  try
    // Подготовка объектов и необходимых данных для них
    ...
    if Assigned(HttpThread) then
      Exit;

    HttpThread := THttpThread.Create(False);
    try
      while not HttpThread.Terminated do
        Application.HandleMessage;
    finally
      FreeAndNil(HttpThread);
    end; 

     // Работа с новыми/старыми объектами
     ...
  finally
    // Уничтожение всего того, что было создано
  end;
end;

Только надо не забыть при выходе из Execute потока дёрнуть главный поток (например, посылкой WM_NULL) - чтобы HandleMessage проснулся.

Ну и по указанной ранее ссылке загляни - там проще будет:

procedure TframeUserInfo.DoOnActionFrame(Sender: TObject);
begin
  try
    // Подготовка объектов и необходимых данных для них
    ...

    EnterWorkerThread;
    try
      // Сюда пиши код, который у тебя в Execute
    finally
      LeaveWorkerThread;
    end; 

     // Работа с новыми/старыми объектами
     ...
  finally
    // Уничтожение всего того, что было создано
  end;
end;

[spamer]

А можно еще уточнить, останавливать поток будем же в Execute(), т.е. так? -

procedure THttpThread.Execute;
begin
    // выполняем некий необходимый код...
    Terminate; // Останавливаем поток.
    SendMessage(Application.Handle, WM_NULL, 0, 0); // Дергаем главный поток.
end;

В потоке нужно проверять условие выхода (Terminated) и досрочно прерывать работу.

Если так, то как же тогда будет выглядеть код, если мы останавливаем в Execute() поток? Так что ли? Но я так подозреваю, что явно что-то не оно.

procedure THttpThread.Execute;
begin
    while not Terminated do
    begin
    // выполняем некий необходимый код...
    Terminate; // Останавливаем поток.
    end;
    SendMessage(Application.Handle, WM_NULL, 0, 0); // Дергаем главный поток.
end;

...

procedure TForm1.FormClose(Sender: TObject; var Action: TCloseAction);
begin
   if Assigned(HttpThread) then
      HttpThread.Terminate;
end;

Ну и по указанной ранее ссылке загляни - там проще будет:

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

[GunSmoker]

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

А можно еще уточнить, останавливать поток будем же в Execute(), т.е. так?

Останов потока в Execute - это просто выход из Execute.

Terminate обычно вызывают по кнопке "Стоп".

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

Если так, то как же тогда будет выглядеть код, если мы останавливаем в Execute() поток? Так что ли? Но я так подозреваю, что явно что-то не оно.

А тебе разве в потоке нужны циклические действия? Вроде нет.

Должно быть:

procedure THttpThread.Execute;
begin
  // Делаем операцию 1
  if Terminated then
    Exit;
  // Делаем операцию 2
  if Terminated then
    Exit;
  // Делаем операцию 3
  if Terminated then
    Exit;
  // Делаем операцию 4
  if Terminated then
    Exit;
  // Делаем операцию 5
  if Terminated then
    Exit;
  // Готово
end;

Или:

procedure THttpThread.Execute;
begin
  while not Terminated do
  begin
    // Делаем очередную операцию
  end; 
end;

Ну и там ещё если какой код тебе надо - вставляем.

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

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

Нет времени.