ReSQL.ru
     
powered by simpleCommunicator - 2.0.36     © 2025 Programmizd 02
Мобильная версия    Контакт    Правила    FAQ    Помощь
Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр
Форумы / Delphi [игнор отключен] [закрыт для гостей] / Как правильно убивать thread
25 сообщений из 52, страница 2 из 3
  2  все
Как правильно убивать thread
    #40128051
svd
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
svd
Участник
@GunSmoker
авторТы до сих пор свой .Execute так и не показал - а это ведь самое важное в вопросе, а вовсе не как ты создаёшь или завершаешь поток.
каюсь и исправляюсь.


автор- При смене фильтра: если есть старый поток - делай ему .Terminate, но не жди его, сразу запускай новый
- Если надо остановить поток - делай ему .Terminate и забывай ссылку
- В самом потоке проверяй .Terminated в .Execute
- При выходе из потока - вызывай OnTerminate для того места, где у тебя ссылка на поток. Если ссылка = ты, то скидывай результаты на UI, если ссылка = не ты, то просто удаляй результаты. В конце удали себя

так и делал. Назначил обработчик на OnTerminate. в нем сделал Free для объекта. В Execute добавил в конце цикла фетчинга Terminate. Вся цепочка отрабатывет прекрасно - датасет и база закрываются и разрушаются, ссылка освобождается и аозволяет создать и запустить новую нить, но переходит в inherited Destroy и останавливается на WaitFor.

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

--------------------------------------

Множественные копии нити дают тормоза. Поэтому решил перейти к совету коллеги @Fr0sT-Brutal - нить не убивать, но каждый раз менять ей SQL

 
Код: pascal
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
procedure TFetchThread.Execute;
begin
  {$IFDEF RUNWATCH}
  AddThread(Self, 'Start>>>');
  {$ENDIF}
  try
    while not Terminated do
    begin
      if sqlChanged then
      begin
        if not DB.Connected then
          DB.Open(False);
        DS.Close;
        DS.SelectSQL.Text := getSQL;
        DS.Open;

      end;

      if DS.Active then
        if not DS.Eof then
        begin
            if Assigned(FDSNotify) then
              Synchronize(
                         procedure
                         begin
                             FDSNotify(DS);
                         end
                        ) ;
              //else
              //  Break;
            DS.Next;
        end;

      if DS.Active then
        if DS.Eof then
        begin
          DS.Close;
          suspend;
        end;

    end;  //while not Terminated

  finally
    DS.Close;
    DB.Close;
  end;

  {$IFDEF RUNWATCH}
  AddThread(Self, 'Stop<<<');
  {$ENDIF}
end;

class function TFetchThread.StartThreadFetch(const aSQL: String;
  const aAction: TFetchThreadAction; var aRef: TFetchThread; const aSortDesc: Boolean;
  aDSNotify: TDataSetNotifyEvent
  ): TFetchThread;
begin

  if Assigned(aRef) then
  begin
    Result := aRef;
    Result.Suspend;
    Result.SQL := aSQL;
    Result.Resume;
  end
  else
    Result := TFetchThread.Create( aSQL, aDSNotify, aRef, aSortDesc);
end;



При запуске стартует нормально. Сделал ограничение в запросе на показ только 3х записей за раз. При скроллинге ListBox идет запрос следующих трех и т.д. Это идея.

В реальности саспендед нить разбудить не получается. В доке нашел такую фигню:
авторWarning: Suspend is deprecated.

Pauses a running thread. Suspend was intended to be used by debuggers and is deprecated in RAD Studio XE, in the year 2010.

Call Suspend to temporarily halt the execution of the thread. To resume execution after a call to Suspend, call Resume. Calls to Suspend can be nested; Resume must be called the same number of times Suspend was called before the thread resumes execution.

Warning: The Resume and Suspend methods should only be used for debugging purposes. Suspending a thread using Suspend can lead to deadlocks and undefined behavior within your application. Proper thread synchronization techniques should be based on TEvent and TMutex.

... и по resume поток более не просыпается. Как тогда "усыплять" нить?
...
Рейтинг: 0 / 0
20.01.2022, 12:34
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128052
svd
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
svd
Участник
два раза запостил..
...
Рейтинг: 0 / 0
20.01.2022, 12:35
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128059
Dimitry Sibiryakov
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Dimitry Sibiryakov
Участник
svdКак тогда "усыплять" нить?

TQueue.Wait.
Posted via ActualForum NNTP Server 1.5
...
Рейтинг: 0 / 0
20.01.2022, 12:58
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128061
svd
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
svd
Участник
Dimitry Sibiryakov,

авторTQueue.Wait.

нигде не нашел такого класса. Это что то нестандартное? Можно пример как с этим работать?
...
Рейтинг: 0 / 0
20.01.2022, 13:08
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128062
Belotsky Serge
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Belotsky Serge
Гость
svd
Dimitry Sibiryakov,

авторTQueue.Wait.


нигде не нашел такого класса. Это что то нестандартное? Можно пример как с этим работать?

Не слушай ты его :) Зачем? Просто делай sleep(10) или sleep(100) в конце цикла? Тебе же условие Terminated нужно же проверять периодически!

PS: не увидел WaitFor(). Не понял зачем он нужен, ведь потока уже к этому наверняка прибит.
...
Рейтинг: 0 / 0
20.01.2022, 13:12
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128065
Dimitry Sibiryakov
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Dimitry Sibiryakov
Участник
svdнигде не нашел такого класса.

Странно, вроде бы в свежих дельфях была очередь с ожиданием...
Posted via ActualForum NNTP Server 1.5
...
Рейтинг: 0 / 0
20.01.2022, 13:24
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128075
Фотография _Vasilisk_
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
_Vasilisk_
Участник
Dimitry Sibiryakov
Странно, вроде бы в свежих дельфях была очередь с ожиданием...
Код: pascal
1.
2.
3.
uses System.Generics.Collections;

TThreadedQueue<T>.PopItem
...
Рейтинг: 0 / 0
20.01.2022, 13:41
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128079
svd
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
svd
Участник
Belotsky Serge,

авторне увидел WaitFor(). Не понял зачем он нужен, ведь потока уже к этому наверняка прибит.

System.Classes:
Код: pascal
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
destructor TThread.Destroy;
begin
  if (FThreadID <> 0) and not FFinished and not FExternalThread then
  begin
    Terminate;
    if FCreateSuspended or FSuspended then
      Resume;
{$IFDEF MSWINDOWS}
    while not FStarted do
{$ELSE}
    while not ((not FCreateSuspended or FInitialSuspendDone) and FStarted) do
{$ENDIF}
      Yield;
    WaitFor;
  end;
  RemoveQueuedEvents(Self);
{$IF Defined(MSWINDOWS)}
  if (FHandle <> 0) and not FExternalThread then CloseHandle(FHandle);
{$ELSEIF Defined(POSIX)}
  // This final check is to ensure that even if the thread was never waited on
  // its resources will be freed.
  if (FThreadID <> 0) and not FExternalThread then pthread_detach(pthread_t(FThreadID));
{$IF Defined(LINUX)}
  sem_destroy(FCreateSuspendedSem);
{$ELSE}
  pthread_mutex_destroy(FCreateSuspendedMutex);
{$ENDIF LINUX or POSIX}
{$ENDIF POSIX}
  inherited Destroy;
  FFatalException.Free;
end;



Сторока 13 в коде. Он нужен, чтоб освободить доступ к какому то объекту. И он дествует до бесконечности, пока этот лок не снимет счетчик. Где он делает захват - не представляю.
...
Рейтинг: 0 / 0
20.01.2022, 14:15
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128090
Belotsky Serge
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Belotsky Serge
Гость
svd
Belotsky Serge,

авторне увидел WaitFor(). Не понял зачем он нужен, ведь потока уже к этому наверняка прибит.


System.Classes:
Код: pascal
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
destructor TThread.Destroy;
begin
  if (FThreadID <> 0) and not FFinished and not FExternalThread then
  begin
    Terminate;
    if FCreateSuspended or FSuspended then
      Resume;
{$IFDEF MSWINDOWS}
    while not FStarted do
{$ELSE}
    while not ((not FCreateSuspended or FInitialSuspendDone) and FStarted) do
{$ENDIF}
      Yield;
    WaitFor;
  end;
// ...
end;



Сторока 13 в коде. Он нужен, чтоб освободить доступ к какому то объекту. И он дествует до бесконечности, пока этот лок не снимет счетчик. Где он делает захват - не представляю.

Как-то все сложно для меня.
Обычно WaitFor вызывается из основного потока, что-то типа:
Код: pascal
1.
2.
3.
4.
5.
procedure TForm1.StopThread;
begin
 MyThread.Terminate; // сказать потоку - заканчивай цикл и выйди из Execute;
 MyThread.WaitFor; // Подождать пока он вывалится из Execute и вернет результат
end;



Но если у вас есть обработчик OnTerminate, то зачем WaitFor?
...
Рейтинг: 0 / 0
20.01.2022, 14:36
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128095
svd
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
svd
Участник
Belotsky Serge,

если смотреть внимательно - то это не мой класс, а класс "из коробки". Я могу его изменить у себя, у коллег он не изменится. Да и не правильно это делать. И игнорировать его тоже нельзя - Destroy должен всю цепочку вложений выполнить.

Если войти в WaitFor, то там он вызывает WaitForSingeObject на этот хэндл с параметром ждать до бесконечности. То есть хэндл гдето застрял. Подозреваю в каких то списках. Могу к этому еще добавить, что иногда программа при завершении делает долгую финализацию. При ислледовании оказалось, что другая нить при определенных обстоятельствах тоже долго не завершается, но по протоколу вроде как "умирает" с освобождением ресурсов.
...
Рейтинг: 0 / 0
20.01.2022, 14:44
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128102
Dimitry Sibiryakov
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Dimitry Sibiryakov
Участник
svdЯ могу его изменить у себя

Зато у себя ты можешь его правильно использовать, не загоняя в deadlock.
Posted via ActualForum NNTP Server 1.5
...
Рейтинг: 0 / 0
20.01.2022, 14:52
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128126
Belotsky Serge
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Belotsky Serge
Гость
svd
Belotsky Serge,

если смотреть внимательно - то это не мой класс, а класс "из коробки". Я могу его изменить у себя, у коллег он не изменится. Да и не правильно это делать. И игнорировать его тоже нельзя - Destroy должен всю цепочку вложений выполнить.

Если войти в WaitFor, то там он вызывает WaitForSingeObject на этот хэндл с параметром ждать до бесконечности. То есть хэндл гдето застрял. Подозреваю в каких то списках. Могу к этому еще добавить, что иногда программа при завершении делает долгую финализацию. При ислледовании оказалось, что другая нить при определенных обстоятельствах тоже долго не завершается, но по протоколу вроде как "умирает" с освобождением ресурсов.


Ну и будете ждать до потери пульса :)
Вы откуда вызываете Free потока из OnTerminate? Так OnTerminate вызывается по выходу из Execute потока. После того как вызвали Free потока вызывается Destroy, в котором вы говорите ему завершить Execute (Terminate) и потом ждете пока он завершится. Но поток уже вышел из Excecute и обратно уже никогда не вернется :)
...
Рейтинг: 0 / 0
20.01.2022, 15:35
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128135
svd
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
svd
Участник
Belotsky Serge,

не, эта схема не живая. Сделал трэд все время живой. только по окончании фетча отключается датасет и ждет прихода нового запроса.
Вроде работает, неплохо. Сейчас возникла идея использовать всего единственный фетч для показа во всех фреймах.
...
Рейтинг: 0 / 0
20.01.2022, 15:56
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128147
shalamyansky
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
shalamyansky
Участник
Мнение сугубо личное, но проверенное практикой. Дельфийская оболочка с объектами вокруг CreateThread скорее мешает, чем помогает. Точнее, не помогает вообще никак. Пишется чистая процедура потока, запускается через CreateThread, все управление - через объекты синхронизации. Если задача потока разовая - запустил и забыл. Если задача циклическая - в конце цикла поток ждет сигнал либо на новый цикл (или не ждет - ваша логика), либо на выход. Приложению в таком случае не забыть перед закрытием дать сигнал на выход. Все.

А Delphi к этому простому делу пристраивает объекты, с которыми теперь надо репу чесать - кто, когда и как их должен освобождать?
...
Рейтинг: 0 / 0
20.01.2022, 16:16
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128154
ъъъъъ
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
ъъъъъ
Гость
shalamyansky
Мнение сугубо личное, но проверенное практикой. Дельфийская оболочка с объектами вокруг CreateThread скорее мешает, чем помогает. Точнее, не помогает вообще никак. Пишется чистая процедура потока, запускается через CreateThread, все управление - через объекты синхронизации. Если задача потока разовая - запустил и забыл. Если задача циклическая - в конце цикла поток ждет сигнал либо на новый цикл (или не ждет - ваша логика), либо на выход. Приложению в таком случае не забыть перед закрытием дать сигнал на выход. Все.

А Delphi к этому простому делу пристраивает объекты, с которыми теперь надо репу чесать - кто, когда и как их должен освобождать?

Имхо, всё же проще ч/з System.BeginThread(). 22423366
...
Рейтинг: 0 / 0
20.01.2022, 16:27
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128159
s62
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
s62
Участник
svd
так и делал. Назначил обработчик на OnTerminate. в нем сделал Free для объекта.
Зачем? Задаете в конструкторе FreeOnTerminate := True; и не надо никаких обработчиков OnTerminate, поток сам уничтожится, и не будет при этом висеть. Как я понимаю, gunsmoker про OnTerminate написал по другому поводу, а не в связи с уничтожением TThread. (Про уничтожение он написал: "суть тут в том, что когда тебе надо "уничтожить поток", ты просто ставишь ему флажок и идёшь дальше. Сам поток увидит этот флажок после и завершится - тоже когда-то потом, тебе уже не важно когда.")

Останавливать поток удобно с помощью функций WaitForSingleObject/WaitForMultipleObjects или при помощи класса TEvent и его методов WaitFor, SetEvent, ResetEvent.
Например в коде потока, если нужно, чтобы поток что-то сделал и снова приостановился.

Код: pascal
1.
2.
3.
4.
5.
6.
7.
8.
  while not Terminated do
  begin
    ThreadEvent.WaitFor(INFINITE);
    if Terminated then break;
    //тут разные действия
    ...
   ThreadEvent.ResetEvent;
  end;



Из главной формы:
чтобы разбудить и поток сделал что-то:
Код: pascal
1.
ThreadEvent.SetEvent;


чтобы прекратить выполнение потока
Код: pascal
1.
2.
Thread.Terminate; //устанавливает Terminated в True
ThreadEvent.SetEvent;
...
Рейтинг: 0 / 0
20.01.2022, 16:41
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128167
YuRock
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
YuRock
Участник
svd
Назначил обработчик на OnTerminate. в нем сделал Free для объекта.

svd
В Execute добавил в конце цикла фетчинга Terminate.

svd
Вся цепочка отрабатывет прекрасно


Разбил на отдельные цитаты для удобства, наглядности.
...
Рейтинг: 0 / 0
20.01.2022, 17:13
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128168
YuRock
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
YuRock
Участник
svd
Если войти в WaitFor, то там он вызывает WaitForSingeObject на этот хэндл с параметром ждать до бесконечности. То есть хэндл гдето застрял. Подозреваю в каких то списках.
...
Рейтинг: 0 / 0
20.01.2022, 17:17
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128169
YuRock
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
YuRock
Участник
ъъъъъ
shalamyansky
Мнение сугубо личное, но проверенное практикой. Дельфийская оболочка с объектами вокруг CreateThread скорее мешает, чем помогает. Точнее, не помогает вообще никак. Пишется чистая процедура потока, запускается через CreateThread, все управление - через объекты синхронизации. Если задача потока разовая - запустил и забыл. Если задача циклическая - в конце цикла поток ждет сигнал либо на новый цикл (или не ждет - ваша логика), либо на выход. Приложению в таком случае не забыть перед закрытием дать сигнал на выход. Все.

А Delphi к этому простому делу пристраивает объекты, с которыми теперь надо репу чесать - кто, когда и как их должен освобождать?

Имхо, всё же проще ч/з System.BeginThread(). 22423366
Да нет разницы почти. Ту переменную (в dll, например) всё равно выставлять надо вручную, ведь многопоточный доступ к памяти может возникнуть до первого запуска BeginThread, извне.
...
Рейтинг: 0 / 0
20.01.2022, 17:20
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128171
ъъъъъ
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
ъъъъъ
Гость
YuRock,

кроме "той" переменной, посмотри, как функция треда в CreateThread() передается.
...
Рейтинг: 0 / 0
20.01.2022, 17:32
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128181
Dimitry Sibiryakov
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Dimitry Sibiryakov
Участник
YuRockмногопоточный доступ к памяти может возникнуть до первого запуска BeginThread,
извне.

Из какого "вне" если у него приложение, а не библиотека?
Posted via ActualForum NNTP Server 1.5
...
Рейтинг: 0 / 0
20.01.2022, 18:34
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128192
ъъъъъ
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
ъъъъъ
Гость
Dimitry Sibiryakov
YuRockмногопоточный доступ к памяти может возникнуть до первого запуска BeginThread,
извне.

Из какого "вне" если у него приложение, а не библиотека?
Ага, я как-то не установил IsMultiThread, было смешно.
...
Рейтинг: 0 / 0
20.01.2022, 18:54
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128203
YuRock
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
YuRock
Участник
ъъъъъ
YuRock,

кроме "той" переменной, посмотри, как функция треда в CreateThread() передается.
Какая такая? Ну, соглашение вызова не такое, и что?
...
Рейтинг: 0 / 0
20.01.2022, 19:31
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128207
YuRock
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
YuRock
Участник
Dimitry Sibiryakov
YuRockмногопоточный доступ к памяти может возникнуть до первого запуска BeginThread,
извне.

Из какого "вне" если у него приложение, а не библиотека?Я про то, что BeginThread вместо CreateThread - это не панацея в общем случае от неинициализированной переменной IsMultiThreaded.
И "в приложении, а не в библиотеке" тоже никто не запрещает инициализировать её после begin в dpr и затем использовать CreateThread.
Как минимум это быстрее на один вызов функции.
Для меня до сих пор загадка, для чего BeginThread вообще ввели. Написали бы в хелпе обязательно инициализировать IsMultiThreaded, да и всё. Тем более, что не редко приходится это делать даже в библиотеках, не стартующих потоки вообще.
...
Рейтинг: 0 / 0
20.01.2022, 19:35
| Ответить | Цитировать | Написать  
Как правильно убивать thread
    #40128208
YuRock
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
YuRock
Участник
YuRock
Для меня до сих пор загадка, для чего BeginThread
Вернее, я еще понимаю - для мульти-платформенности, да только ее ввели задолго до Delphi 6 с кайликсом.
...
Рейтинг: 0 / 0
20.01.2022, 19:42
| Ответить | Цитировать | Написать  
25 сообщений из 52, страница 2 из 3
  2  все
Форумы / Delphi [игнор отключен] [закрыт для гостей] / Как правильно убивать thread
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение
NoSQL.ru             Фотоальбом: Участники, Встречи
Закрыть
start [/forum/topic.php?fid=58&msg=40128168&tid=2036694]:
 0ms
get settings:
 12ms
get forum list:
 13ms
check forum access:
 4ms
check topic access:
 4ms
track hit:
 42ms
get topic data:
 12ms
get forum data:
 4ms
get page messages:
 59ms
get tp. blocked users:
 1ms
others: 309ms
total:  460ms
созд. / загр.: 460ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]