Обработка событий и отмена задач в Windows приложениях на Delphi: параллельные вычисления и временные ограничения

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

Обработка событий и отмена задач в Windows приложениях на Delphi

В современных Windows приложениях на Delphi часто возникает необходимость обработки событий асинхронно, чтобы освободить основной поток приложения для выполнения других задач. Одной из распространенных проблем является необходимость отмены задач, которые уже запущены, но не выполнены в течение определенного времени. В данной статье мы рассмотрим, как можно реализовать такую функциональность, используя примеры кода на языке Object Pascal.

Проблематика параллельной обработки событий

Разработчик Windows приложения на Delphi столкнулся с задачей обработки событий асинхронно, чтобы освободить основной поток для приема следующих событий. Использование библиотек, таких как OmniThreadLibrary, позволяет реализовать параллельные вычисления. Однако, возникла проблема: часть кода требуется выполнить немедленно для декодирования параметров событий, а другая часть должна выполняться через некоторое время, если за это время не поступали новые события с тем же контекстом.

Подход к решению проблемы

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

Реализация на практике

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

Пример кода

type
  TEvent = record
    Context: string;
    EventParams: TParams;
    Created: TDateTime;
    function IsExpired: Boolean;
  end;

  TEventList = class
  private
    FEvents: TList<TEvent>;
    FCriticalSection: TCriticalSection;
  public
    constructor Create;
    destructor Destroy; override;
    procedure AddEvent(Context: string; EventParams: TParams);
    procedure ProcessExpiredEvents;
  end;

{ TEvent }
function TEvent.IsExpired: Boolean;
begin
  Result := Now - Created > 3000;
end;

{ TEventList }
constructor TEventList.Create;
begin
  inherited;
  FCriticalSection := TCriticalSection.Create;
  FEvents := TList<TEvent>.Create;
end;

destructor TEventList.Destroy;
begin
  FEvents.Free;
  FCriticalSection.Free;
  inherited;
end;

procedure TEventList.AddEvent(Context: string; EventParams: TParams);
begin
  FCriticalSection.Enter;
  try
    FEvents.Add(TEvent.Create(Context, EventParams, Now));
  finally
    FCriticalSection.Leave;
  end;
end;

procedure TEventList.ProcessExpiredEvents;
var
  Event: TEvent;
  Index: Integer;
begin
  FCriticalSection.Enter;
  try
    Index := FEvents.Count - 1;
    while Index >= 0 do
    begin
      Event := FEvents[Index];
      if Event.IsExpired then
      begin
        // Выполнение задачи
        // ...
        // Удаление события из списка
        FEvents.Delete(Index);
      end;
      Dec(Index);
    end;
  finally
    FCriticalSection.Leave;
  end;
end;

{ Основной код приложения }
var
  EventList: TEventList;
  BackgroundThread: TThread;
begin
  EventList := TEventList.Create;
  BackgroundThread := TThread.CreateAnonymousThread(
    procedure
    begin
      while not Terminated do
      begin
        EventList.ProcessExpiredEvents;
        Sleep(1000);
      end;
    end);
  BackgroundThread.Start;

  // Основной поток приложения обрабатывает события
  // и вызывает EventList.AddEvent(Context, EventParams);
  // ...
end;

Заключение

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

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

Описание 'Context': Разработка механизма для асинхронной обработки событий и отмены задач в Windows приложениях на Delphi, используя многопоточность для оптимизации работы приложения и уменьшения задержек.

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

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

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