Асинхронная загрузка файлов в Delphi: решение проблемы блокировки основного потока на Azure

Delphi , Компоненты и Классы , Потоки

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

Проблема блокировки основного потока

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

Пример кода, вызывающего блокировку

В приведенном коде используется библиотека OmniThreadLibrary для создания асинхронного конвейера (pipeline), который должен обрабатывать загрузку файлов в фоновом режиме. Однако, несмотря на использование асинхронного подхода, вызов метода pipeline.WaitFor(INFINITE) приводит к блокировке основного потока до завершения всех операций загрузки.

procedure TCloudManager.UploadTask(const input: TOmniValue; var output: TOmniValue);
var
  FileTask: TFileTask;
begin
  FileTask := input.AsRecord<TFileTask>;
  Upload(FileTask.BaseFolder, FileTask.LocalFile, FileTask.CloudFile);
end;

function TCloudManager.MassiveUpload(const BaseFolder: String; Files: TDictionary<String, String>): TStringList;
var
  pipeline: IOmniPipeline;
  FileInfo: TPair<String, String>;
  FileTask: TFileTask;
begin
  // Настройка конвейера
  pipeline := Parallel.Pipeline
    .Stage(UploadTask)
    .NumTasks(Environment.Process.Affinity.Count * 2)
    .Run;
  // Добавление задач в конвейер
  for FileInfo in Files do
  begin
    // Инициализация данных о файле
    FileTask.LocalFile := FileInfo.Key;
    FileTask.CloudFile := FileInfo.Value;
    FileTask.BaseFolder := BaseFolder;

    // Добавление задачи в очередь конвейера
    pipeline.Input.Add(TOmniValue.FromRecord(FileTask));
  end;
  pipeline.Input.CompleteAdding;
  // Ожидание завершения всех операций
  pipeline.WaitFor(INFINITE);
end;

Подтвержденное решение проблемы

Для решения проблемы блокировки основного потока необходимо отказаться от использования pipeline.WaitFor(INFINITE), который блокирует основной поток до завершения всех операций. Вместо этого следует использовать обработчик события OnStop, который будет вызван по завершении всех операций конвейера.

procedure TCloudManager.MassiveUpload(const BaseFolder: String; Files: TDictionary<String, String>);
var
  FileInfo: TPair<String, String>;
  FileTask: TFileTask;
begin
  // Настройка конвейера с обработчиком завершения
  FPipeline := Parallel.Pipeline
    .Stage(UploadTask)
    .NumTasks(Environment.Process.Affinity.Count * 2)
    .OnStop(
      procedure
      begin
        ShowMessage('All done');
        FPipeline := nil;
      end)
    .Run;
  // Добавление задач в конвейер
  for FileInfo in Files do
  begin
    // Инициализация данных о файле
    FileTask.LocalFile := FileInfo.Key;
    FileTask.CloudFile := FileInfo.Value;
    FileTask.BaseFolder := BaseFolder;

    // Добавление задачи в очередь конвейера
    FPipeline.Input.Add(TOmniValue.FromRecord(FileTask));
  end;
  FPipeline.Input.CompleteAdding;
end;

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

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

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

Заключение

Асинхронная загрузка файлов в Azure с использованием Delphi и OmniThreadLibrary позволяет избежать блокировки основного потока и повысить отзывчивость приложения. Использование обработчика OnStop для конвейера и обновление библиотеки до последней версии являются ключевыми моментами в решении данной проблемы.

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

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

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

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

:: Главная :: Потоки ::