Использование TThread для Мониторинга Базы Данных в Delphi XE2

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

Вопрос, поставленный пользователем, заключается в необходимости создания программы, которая будет постоянно отслеживать изменения в базе данных на основе заданного SQL-запроса. Для этого необходимо использовать фоновый поток (TThread), чтобы пользователь мог продолжать работу с системой, не ожидая результатов мониторинга.

Подход к решению

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

Пример кода

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

Вот примерный код модуля формы:

unit Unit1;
interface
uses
  Winapi.Windows, Winapi.Messages, System.SysUtils, System.Classes, Vcl.Graphics,
  Vcl.Controls, Vcl.Forms, Vcl.Dialogs, Vcl.StdCtrls, Unit2;
type
  TForm1 = class(TForm)
    ListBox1: TListBox;
    Button1: TButton;
    Button2: TButton;
    procedure Button1Click(Sender: TObject);
    procedure Button2Click(Sender: TObject);
  private
    FCollector: TCollector;
    procedure OnCollect(S: TStrings);
  public
  end;
var
  Form1: TForm1;
implementation
{$R *.dfm}
procedure TForm1.Button1Click(Sender: TObject);
begin
  if not Assigned(FCollector) then
  begin
    FCollector := TCollector.Create;
    FCollector.OnCollect := Self.OnCollect;
    FCollector.Start;
  end;
end;
procedure TForm1.Button2Click(Sender: TObject);
begin
  if Assigned(FCollector) then
  begin
    FCollector.Terminate;
    FCollector := nil;
  end;
end;
procedure TForm1.OnCollect(S: TStrings);
begin
  ListBox1.Items.Assign(S);
end;
end.

Далее, создадим модуль для класса TCollector, который будет представлять собой фоновый поток:

unit Unit2;
interface
uses
  System.Classes;
type
  TCollectEvent = procedure(S: TStrings) of object;
  TCollector = class(TThread)
  private
    FTick: THandle;
    FItems: TStrings;
    FOnCollect: TCollectEvent;
    FInterval: Integer;
  protected
    procedure Execute; override;
    procedure DoCollect;
  public
    constructor Create;
    destructor Destroy; override;
    procedure Terminate;
    property Interval: Integer read FInterval write FInterval;
    property OnCollect: TCollectEvent read FOnCollect write FOnCollect;
  end;
implementation
uses
  Windows, SysUtils;
{ TCollector }
constructor TCollector.Create;
begin
  inherited Create(True);
  FreeOnTerminate := True;
  FInterval := 1000; // Интервал проверки в миллисекундах
  FTick := CreateEvent(nil, True, False, nil);
end;
destructor TCollector.Destroy;
begin
  CloseHandle(FTick);
  inherited;
end;
procedure TCollector.DoCollect;
begin
  Synchronize(procedure
    begin
      FOnCollect(FItems);
    end);
end;
procedure TCollector.Terminate;
begin
  inherited;
  SetEvent(FTick);
end;
procedure TCollector.Execute;
begin
  while not Terminated do
  begin
    if WaitForSingleObject(FTick, FInterval) = WAIT_TIMEOUT then
    begin
      FItems := TStringList.Create;
      try
        // Здесь должен быть код для сбора данных из базы
        // Например, FItems.AddObject('Данные из базы');
        Synchronize(DoCollect);
      finally
        FItems.Free;
      end;
    end;
  end;
end;
end.

Важные моменты

• Все операции с интерфейсом пользователя должны выполняться в главном потоке. Для этого используется метод Synchronize.
• Все операции, связанные с доступом к базе данных, должны быть выполнены в безопасном для потоков контексте. Если используется компонент ADO, рекомендуется создавать отдельные соединения (ADOConnection) и наборы данных (ADODataSet) в каждом потоке.
• Для остановки потока необходимо вызвать метод Terminate класса TCollector, что приведет к немедленной остановке потока.

Заключение

Использование фоновых потоков (TThread) в Delphi XE2 позволяет создавать программы, которые могут выполнять длительные или периодические задачи без блокировки основного потока пользовательского интерфейса. Это особенно полезно при работе с базами данных, где необходимо следить за изменениями в реальном времени.

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

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

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

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

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