Delphi создание экземпляра класса в потоке?

Question

[Игорь]

Сложно правильно сформулировать вопрос, но я постараюсь.

У меня есть достаточно представление как всё устроено.
Работаю с потоками, управляю.
Синхронизация.
Проблемы.
И прочие ошибки при многопоточном проектировании.

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

Приведу пример кода

threadCard := TCardThread.CreateAnonymousThread(
    procedure
    var
      this: TCardThread;
    begin
      this := TThread.CurrentThread as TCardThread;
      FDQueryUrl := Dm.GetQuery();
      ...
   end;

function TDm.GetQuery: TFDQuery;
begin
  Result := TFDQuery.Create(nil);
  Result.Connection := TFDConnection.Create(nil);
  Result.Connection.Params.Assign(FDConnection.Params);
end;

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

И я вроде как по устранял явные, грубые, ошибки при использовании потоков.

Обратите внимание на строку
FDQueryUrl := Dm.GetQuery();

Где теперь храниться это экземпляр, в контексте потока или в стеке/куче основного потока?
Я правильно создаю экземпляр для потока?

Comments

[zed]

Переменная FDQueryUrl хранится там, где она объявлена. В приведенном примере кода я её объявления не вижу, а значит она хранится за пределами потока. Чтобы хранилась внутри - она должна быть в секции var анонимной процедуры созданного потока.

[Игорь]

zedxxx, Следовательно это суицид?

[Игорь]

Мне кажется я понял.
Экземпляр храниться вне потока, но ошибки не может быть, так как 1 поток 1 экземпляр.

И пофиг, где храниться экземпляр, главное что бы он был один для одного потока.

Как я понимаю, экземпляр храниться вне потока.
Мы работаем со ссылкой на него.

Ну об этом мне известно.

[Игорь]

Вывод:

Данный пример не приведёт к ошибке.

Жду подтверждения.

[zed]

Игорь, Ну да, ничего хорошего - утечки памяти и использование одной и той же переменной из нескольких потоков сразу.

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

[Игорь]

Вот так

threadCard := TCardThread.CreateAnonymousThread(
    procedure
    var
      this: TCardThread;
    begin
      this := TThread.CurrentThread as TCardThread;
      FDQueryUrl := Dm.GetQuery();
      try
      ...
      finally
         FreeAndNil(FDQueryUrl )
      end;
   end;

[Игорь]

На данный момент использую так.

[Игорь]

Ну или так

threadCard := TCardThread.CreateAnonymousThread(
    procedure
    var
      FDQueryUrl: TFDQuery;
      this: TCardThread;
    begin
      this := TThread.CurrentThread as TCardThread;
      TTHread.Synchronize(this,
        procedure
        begin
          FDQueryUrl := Dm.GetQuery();
        end);
      try
      ...
      finally
         FreeAndNil(FDQueryUrl )
      end;
   end;

[zed]

Игорь, У вас одна переменная, в которую вы из 10 (условно) потоков записываете ссылку на объект. В итоге, вы потеряете 9 ссылок, которая в итоге будет перезаписана последним потоком (переменная-то одна!). И затем, все эти потоки будут работать с этой ссылкой, а затем 10 раз попытаются её удалить из памяти.

[Игорь]

zedxxx, Ну где 1?

Каждый раз новая

function TDm.GetQuery: TFDQuery;
begin
  Result := TFDQuery.Create(nil);
  Result.Connection := TFDConnection.Create(nil);
  Result.Connection.Params.Assign(FDConnection.Params);
end;

[zed]

Игорь, Это код создания, а вот когда вы ссылку присваиваете переменной FDQueryUrl, которая глобальна для нескольких потоков, вот там и начинаются проблемы. Как я уже сказал, решение - перенос переменной в секцию var, как у вас в последнем примере кода в комментариях.

[Игорь]

zedxxx, переменная в анонимной функции

threadCard := TCardThread.CreateAnonymousThread(
    procedure
    var
      FDQueryUrl: TFDQuery;
      this: TCardThread;
    begin
      this := TThread.CurrentThread as TCardThread;
      TTHread.Synchronize(this,
        procedure
        begin
          FDQueryUrl := Dm.GetQuery();
        end);
      try
      ...
      finally
         FreeAndNil(FDQueryUrl )
      end;
   end;

[zed]

Игорь, И зачем вы в Synchronize обернули создание объекта?

[Игорь]

zedxxx, Да, спасибо, я так использовал, просто не указал в самом начале.
Пардон.

[zed]

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

[Игорь]

zedxxx, Да, вы правы.
Я не верно привёл пример.
Но мы думали об одном и том же.

Спасибо.

[zed]

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

[Игорь]

zedxxx,

И зачем вы в Synchronize обернули создание объекта?

Понял, лишняя.
Так как мы потоки создаём последовательно .

[Игорь]

zedxxx, Да вы правы.
Сейчас мне эти проблемы бьют по башке, ой как больно.

Спасибо.

[zed]

Игорь, Нет. Лишняя - потому что нет конкуррентного доступа к глобальным переменным. Если FDConnection.Params никто специально не изменяет в процессе создания потоков (а это наверняка так), то всё Ок - читать переменную можно из нескольких потоков одновременно.