Обработка результатов асинхронных задач в GUI-приложениях на Delphi без блокировки основного потока

Delphi , Рабочий стол , TaskBar

Вопрос, поднятый в данном контексте, касается использования асинхронных задач в GUI-приложениях на Delphi и связан с проблемой блокировки основного потока при ожидании результата выполнения асинхронной задачи. Это может привести к тому, что приложение будет восприниматься как "зависшее" пользователем, особенно если выполнение задачи занимает значительное время.

Проблема

В примере, предоставленном в документации Embarcadero, использование свойства IFuture.Value приводит к блокировке основного потока GUI, пока ожидается результат выполнения задачи. Это особенно критично, если задача выполняется долго, например, 30 секунд, что может вызвать реакцию операционной системы в виде уведомления о том, что программа не отвечает.

Решение

В соответствии с подтвержденным ответом, свойство IFuture.Value по дизайну блокирует вызывающий поток до тех пор, пока другой поток не присвоит значение. Следовательно, если вы читаете Value в основном потоке, вы неизбежно заблокируете его до готовности значения.

Варианты решения проблемы:

1. Использование таймера или другого асинхронного механизма для периодической проверки свойства IFuture.Status, чтобы определить, готова ли задача предоставить значение, прежде чем читать его.

2. Организация сигнализации основного потока параллельной задачей о готовности, после чего основной поток может прочитать значение в обработчике сигнала.

Пример кода

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

uses
  System.SysUtils,
  System.Classes,
  System.Threading;

var
  MyValue: Integer;
  FutureObject: IFuture<Integer>;

begin
  FutureObject := TTask.Future<Integer>(function: Integer
    begin
      Sleep(3000);
      Result := 16;
    end);

  // Создаем таймер, который будет проверять статус задачи
  with TTimer.Create(nil) do
  try
    OnTimer := procedure
    begin
      if FutureObject.Status = TTaskStatus.tsCompleted then
      begin
        MyValue := FutureObject.Value;
        Free;
      end;
    end;
    Enabled := True;
    Interval := 100; // Проверяем каждые 100 мс
  end;
end;

В этом примере кода мы используем таймер, который проверяет статус задачи каждые 100 миллисекунд. Как только задача завершится, таймер прочитает значение и остановится.

Альтернативный подход

Также можно использовать другой поток для чтения результата асинхронной задачи:

uses
  System.SysUtils,
  System.Classes,
  System.Threading;

var
  MyValue: Integer;
  FutureObject: IFuture<Integer>;

begin
  FutureObject := TTask.Future<Integer>(function: Integer
    begin
      Sleep(3000);
      Result := 16;
    end);

  TTask.Run(
    procedure
    begin
      MyValue := FutureObject.Value;
      // Здесь можно вызвать функцию для обновления интерфейса, например, TThread.Synchronize
    end
  );
end;

В этом случае основной поток не блокируется, и все вычисления выполняются в фоновом потоке. После завершения задачи, результат можно передать обратно в основной поток, используя, например, TThread.Synchronize.

Заключение

Использование асинхронных задач в GUI-приложениях на Delphi позволяет избежать зависаний интерфейса во время выполнения длительных операций. Важно понимать, как работать с асинхронными операциями, чтобы не блокировать основной поток, и использовать механизмы, такие как таймеры или другие потоки, для обработки результатов без влияния на пользовательский интерфейс.

Создано по материалам из источника по ссылке.

и решений для обработки результатов асинхронных задач в GUI-приложениях на Delphi для избежания блокировки основного потока.

Комментарии и вопросы

Получайте свежие новости и обновления по Object Pascal, Delphi и Lazarus прямо в свой смартфон. Подпишитесь на наш Telegram-канал delphi_kansoftware и будьте в курсе последних тенденций в разработке под Linux, Windows, Android и iOS

:: Главная :: TaskBar ::