Обход блокировки главного потока при использовании OmniThreadLibrary в Delphi XE4

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

При работе с многопоточностью в Delphi XE4 с использованием библиотеки OmniThreadLibrary может возникнуть проблема блокировки главного потока, когда графический интерфейс пользователя (GUI) перестает реагировать на ввод пользователя до завершения всех фоновых потоков. В данной статье мы рассмотрим, как можно обойти эту проблему, используя примеры кода на Object Pascal.

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

Пользователь столкнулся с проблемой, при использовании библиотеки OmniThreadLibrary в Delphi XE4. При вызове следующей процедуры, интерфейс GUI замораживал ввод пользователя до тех пор, пока все фоновые потоки не завершали свою работу:

procedure Test(input: TStringList; output: TList<TMaintFore>);
var
  outQueue: IOmniBlockingCollection;
  transaction: TOmniValue;
begin
  outQueue := TOmniBlockingCollection.Create;
  Parallel.ForEach(0, input.Count - 1)
    .NoWait
    .Into(outQueue)
    .Execute(
      procedure(const value: integer; var result: TOmniValue)
      begin
        result := TMaintFore.Create(input[value]);
      end
    );
end;

Пользователь ожидал, что использование параметра .NoWait позволит процедуре завершиться, даже если фоновые потоки все еще выполняются.

Решение проблемы

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

Для решения этой проблемы необходимо сохранить интерфейс, возвращаемый Parallel.ForEach, в глобальной переменной (например, переменной формы) и уничтожить его только после завершения работы Parallel.ForEach.

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

var
  loop: IOmniParallelLoop<Integer>;
begin
  loop := Parallel.ForEach(1, N).NoWait;
  loop.OnStop(
    procedure(const task: IOmniTask)
    begin
      task.Invoke(
        procedure
        begin
          // здесь можно выполнить любые действия
          loop := nil;
        end
      );
    end
  );
  loop.Execute(
    procedure(const value: Integer)
    begin
      // здесь код, который выполняется в каждом потоке
    end
  );
end;

Этот метод документирован в официальной документации OmniThreadLibrary.

Заключение

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

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

При работе с многопоточностью в Delphi XE4 с использованием библиотеки OmniThreadLibrary возникает проблема блокировки главного потока, и рассматриваются методы ее решения.

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

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

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