登录/ 注册
 找回密码
 立即注册
关闭

CSDN热搜

程序园 精品问答 技术交流 资源下载
返回列表 发新帖
首页 › 资源区 › 代码 ›mormot.core.threads--TSynBackgroundThread

mormot.core.threads--TSynBackgroundThread

茅香馨 4 天前
mormot.core.threads--TSynBackgroundThread

在mORMot 2框架中，TSynBackgroundThreadEvent、TSynBackgroundThreadMethod、TSynBackgroundThreadProcedure、TSynBackgroundThreadProcess和 TSynBackgroundTimer这几个类虽然都涉及到后台线程的执行，但它们各自有不同的用途和设计目标。以下是对这些类之间差异的概述：

  • TSynBackgroundThreadEvent：

    • 这个类可能设计用于执行与事件相关的回调函数。它可能封装了一个事件处理机制，允许您在后台线程中响应特定的事件。
    • 回调函数的签名可能包括一个事件发送者（Sender）参数，以及可能的其他参数，用于传递事件相关的数据。
    • 由于名称中包含“Event”，它可能特别适用于事件驱动的场景。

  • TSynBackgroundThreadMethod：

    • 这个类设计用于执行标准的 TThreadMethod类型的回调，即无参数且返回 Void的过程。
    • 它提供了一种在后台线程中执行这些回调的简便方式，使得与Delphi标准线程库兼容的代码可以轻松地与mORMot 2框架集成。
    • 由于 TThreadMethod是Delphi中用于线程方法的标准类型，因此这个类可能特别适用于需要这种兼容性的场景。

  • TSynBackgroundThreadProcedure：

    • 这个类可能设计用于执行简单的无参数过程（procedure）回调，而不是一个对象方法或 TThreadMethod。
    • 它与 TSynBackgroundThreadMethod类似，但可能更加专注于那些不需要传递额外参数的过程。
    • 使用这个类可以使代码更加简洁，特别是当回调不需要访问任何外部状态或参数时。

  • TSynBackgroundThreadProcess：

    • 这个类可能是一个更通用的后台线程处理类，它可能提供了执行周期性任务或长时间运行任务的能力。
    • 它可能封装了线程创建、启动、暂停、恢复和终止的逻辑，以及任务调度的机制。
    • 与其他几个类相比，TSynBackgroundThreadProcess可能更加灵活和强大，适用于需要复杂任务调度的场景。

  • TSynBackgroundTimer：

    • 这个类专门设计用于在后台线程中执行定时任务。
    • 它可能内部维护了一个或多个定时器，允许您安排任务在指定的时间间隔后执行。
    • TSynBackgroundTimer可能还提供了向定时任务传递消息或参数的能力，以及查询任务状态和执行结果的方法。
    • 它特别适用于需要定时执行任务的场景，如心跳检测、定时轮询等。

上述描述是基于对类名的一般性推断和假设。实际上，mORMot 2框架中的这些类的具体实现和用途可能有所不同。因此，如果您正在使用mORMot 2框架，并且想要了解这些类的确切差异和用法，最好的做法是查阅mORMot 2的官方文档或源代码。这将为您提供关于这些类的详细信息和示例代码，帮助您更好地理解和使用它们。
TSynBackgroundThreadMethodAbstrac 定义
  1. /// TSynBackgroundThreadAbstract 进程的状态机状态
  2. TSynBackgroundThreadProcessStep = (
  3.     flagIdle,           // 空闲状态
  4.     flagStarted,        // 已启动状态
  5.     flagFinished,       // 已完成状态
  6.     flagDestroying);    // 正在销毁状态
  8. /// TSynBackgroundThreadAbstract进程的状态机状态集合
  9. TSynBackgroundThreadProcessSteps = set of TSynBackgroundThreadProcessStep;
  12. /// 抽象TThread类，能够在其自己的执行内容中运行一个方法
  13. // - 典型用途是作为处理数据或远程访问的后台线程，
  14. // 同时UI通过循环运行OnIdle事件保持响应：
  15. // 例如，查看mormot.rest.client.pas单元中TRestClientUri.OnIdle是如何处理此事件的
  16. // - 您不应直接使用此类，而应继承它并重写Process方法，
  17. // 或者使用TSynBackgroundThreadEvent/TSynBackgroundThreadMethod，
  18. // 并提供一个更加方便的回调函数
  19. TSynBackgroundThreadMethodAbstract = class(TSynBackgroundThreadAbstract)
  20. protected
  21.     fPendingProcessLock: TLightLock;     // 对fPendingProcessFlag的原子访问
  22.     fCallerEvent: TSynEvent;             // 调用者事件
  23.     fParam: pointer;                     // 参数指针
  24.     fCallerThreadID: TThreadID;          // 调用者线程ID
  25.     fBackgroundException: Exception;     // 后台线程异常
  26.     fOnIdle: TOnIdleSynBackgroundThread; // 空闲时回调事件
  27.     fOnBeforeProcess: TOnNotifyThread;   // 处理前通知回调
  28.     fOnAfterProcess: TOnNotifyThread;    // 处理后通知回调
  29.     fPendingProcessFlag: TSynBackgroundThreadProcessStep;        // 待处理标志
  30.     procedure ExecuteLoop; override;     // 重写执行循环
  31.     function OnIdleProcessNotify(var start: Int64): Int64;       // 空闲处理通知，返回已用毫秒数
  32.     function GetOnIdleBackgroundThreadActive: boolean;           // 获取OnIdle事件是否激活
  33.     function GetPendingProcess: TSynBackgroundThreadProcessStep; // 获取待处理状态
  34.     procedure SetPendingProcess(State: TSynBackgroundThreadProcessStep); // 设置待处理状态
  35.     // 如果获取成功则返回flagIdle，如果已终止则返回flagDestroying
  36.     function AcquireThread: TSynBackgroundThreadProcessStep;
  37.     procedure WaitForFinished(start: Int64; const onmainthreadidle: TNotifyEvent); // 等待完成
  38.   
  39.     /// 当fProcessParams<>nil且fEvent被通知时，由Execute方法调用
  40.     procedure Process; virtual; abstract;                           // 抽象方法，需在子类中实现
  41. public
  42.     /// 初始化线程
  43.     // - 如果aOnIdle未设置（即等于nil），它将简单地等待后台进程完成，直到RunAndWait()返回
  44.     // - 您可以定义一些回调来嵌套线程执行，例如，分配给TRestServer.BeginCurrentThread/EndCurrentThread
  45.     constructor Create(const aOnIdle: TOnIdleSynBackgroundThread;
  46.       const aThreadName: RawUtf8;
  47.       const OnBeforeExecute: TOnNotifyThread = nil;
  48.       const OnAfterExecute: TOnNotifyThread = nil); reintroduce;
  49.   
  50.     /// 销毁线程
  51.     destructor Destroy; override;
  52.   
  53.     /// 在后台线程中异步启动Process抽象方法
  54.     // - 等待进程完成，同时调用OnIdle()回调
  55.     // - 在后台线程中引发的任何异常都将在调用者线程中转换
  56.     // - 如果self未设置，或者从当前正在处理的同一线程调用（以避免OnIdle()回调中的竞态条件），则返回false
  57.     // - 当后台进程完成时返回true
  58.     // - OpaqueParam将用于指定后台进程线程安全的内容
  59.     // - 此方法是线程安全的，即它将等待另一个线程已经启动的任何进程：
  60.     // 您可以从任何线程调用此方法，即使其主要用途是从主UI线程调用
  61.     function RunAndWait(OpaqueParam: pointer): boolean;
  62.   
  63.     /// 设置一个回调事件，在远程阻塞过程期间循环执行，
  64.     // 例如，在长时间请求期间刷新UI
  65.     // - 您可以为此属性分配一个回调，例如调用Application.ProcessMessages，
  66.     // 以在后台线程中执行远程请求，但让UI仍然具有响应性：
  67.     // mORMotUILogin.pas中的TLoginForm.OnIdleProcess和OnIdleProcessForm方法将符合此属性的预期
  68.     // - 如果OnIdle未设置（即等于nil），它将简单地等待后台进程完成，直到RunAndWait()返回
  69.     property OnIdle: TOnIdleSynBackgroundThread   read fOnIdle write fOnIdle;
  70.   
  71.     /// 如果后台线程处于活动状态，并且在处理过程中调用了OnIdle事件，则为TRUE
  72.     // - 例如，用于确保没有来自用户界面消息的重新进入
  73.     property OnIdleBackgroundThreadActive: boolean read GetOnIdleBackgroundThreadActive;
  74.   
  75.     /// 在Execute中每次处理之前触发的可选回调事件
  76.     property OnBeforeProcess: TOnNotifyThread   read fOnBeforeProcess write fOnBeforeProcess;
  77.   
  78.     /// 在Execute中每次处理之后触发的可选回调事件
  79.     property OnAfterProcess: TOnNotifyThread    read fOnAfterProcess write fOnAfterProcess;
  80. end;
复制代码
TSynBackgroundThreadEvent，TSynBackgroundThreadMethod，TSynBackgroundThreadProcedure，TSynBackgroundThreadProcess
TSynBackgroundThreadEvent 定义
  1. /// 由 TSynBackgroundThreadEvent 调用的后台进程方法
  2. // - 当执行Process虚拟方法时，将提供RunAndWait()方法中指定的OpaqueParam参数
  3. TOnProcessSynBackgroundThread = procedure(Sender: TSynBackgroundThreadEvent;
  4.     ProcessOpaqueParam: pointer) of object;
  6. /// 允许后台线程处理方法回调
  7. TSynBackgroundThreadEvent = class(TSynBackgroundThreadMethodAbstract)
  8. protected
  9.     fOnProcess: TOnProcessSynBackgroundThread; // 回调事件
  10.   
  11.     /// 仅调用OnProcess处理程序
  12.     procedure Process; override; // 重写Process方法
  14. public
  15.     /// 初始化线程
  16.     // - 如果aOnIdle未设置（即等于nil），它将简单地等待后台进程完成，直到RunAndWait()返回
  17.     constructor Create(const aOnProcess: TOnProcessSynBackgroundThread;
  18.       const aOnIdle: TOnIdleSynBackgroundThread;
  19.       const aThreadName: RawUtf8); reintroduce; // 重引入构造函数
  20.   
  21.     /// 提供一个方法处理程序，在后台线程中执行
  22.     // - 由RunAndWait()方法触发 - 该方法将等待直到完成
  23.     // - 这里将提供RunAndWait()方法中指定的OpaqueParam
  24.     property OnProcess: TOnProcessSynBackgroundThread
  25.       read fOnProcess write fOnProcess; // OnProcess属性，用于访问fOnProcess字段
  26. end;
复制代码
TSynBackgroundThreadMethod 定义
  1. /// 允许后台线程处理可变的TThreadMethod回调
  2. TSynBackgroundThreadMethod = class(TSynBackgroundThreadMethodAbstract)
  3. protected
  4.     /// 仅调用RunAndWait()方法中提供的TThreadMethod
  5.     procedure Process; override; // 重写Process方法
  6. public
  7.     /// 运行一次提供的TThreadMethod回调
  8.     // - 使用此方法，而不是继承的RunAndWait()
  9.     procedure RunAndWait(Method: TThreadMethod); reintroduce; // 重引入RunAndWait方法
  10. end;
复制代码
TSynBackgroundThreadProcedure 定义
  1. /// 由 TSynBackgroundThreadProcedure 调用的后台进程过程
  2. // - 当执行Process虚拟方法时，将提供RunAndWait()方法中指定的OpaqueParam参数
  3. TOnProcessSynBackgroundThreadProc = procedure(ProcessOpaqueParam: pointer);
  5. /// 允许后台线程处理过程回调
  6. TSynBackgroundThreadProcedure = class(TSynBackgroundThreadMethodAbstract)
  7. protected
  8.     fOnProcess: TOnProcessSynBackgroundThreadProc; // 回调过程
  9.     /// 仅调用OnProcess处理程序
  10.     procedure Process; override; // 重写Process方法
  11. public
  12.     /// 初始化线程
  13.     // - 如果aOnIdle未设置（即等于nil），它将简单地等待后台进程完成，直到RunAndWait()返回
  14.     constructor Create(aOnProcess       : TOnProcessSynBackgroundThreadProc;
  15.                        const aOnIdle    : TOnIdleSynBackgroundThread;
  16.                        const aThreadName: RawUtf8); reintroduce; // 重引入构造函数
  17.   
  18.     /// 提供一个过程处理程序，在后台线程中执行
  19.     // - 由RunAndWait()方法触发 - 该方法将等待直到完成
  20.     // - 这里将提供RunAndWait()方法中指定的OpaqueParam
  21.     property OnProcess: TOnProcessSynBackgroundThreadProc
  22.       read fOnProcess write fOnProcess; // OnProcess属性，用于访问fOnProcess字段
  23. end;
复制代码
TSynBackgroundThreadProcess 定义
  1. type
  2.   // TSynBackgroundThreadProcess 类声明（稍后定义）
  3.   TSynBackgroundThreadProcess = class;
  5.   /// 由 TSynBackgroundThreadProcess 定期执行的事件回调
  6.   TOnSynBackgroundThreadProcess = procedure(Sender: TSynBackgroundThreadProcess) of object;
  8.   /// 能够以给定周期运行方法的 TThread 类
  9.   TSynBackgroundThreadProcess = class(TSynBackgroundThreadAbstract)
  10.   protected
  11.     fOnProcess: TOnSynBackgroundThreadProcess; // 定期执行的方法回调
  12.     fOnException: TNotifyEvent; // 当 OnProcess 引发异常时执行的事件回调
  13.     fOnProcessMS: cardinal; // 定期执行任务的时间间隔（毫秒）
  14.     fStats: TSynMonitor; // 处理统计信息
  15.     procedure ExecuteLoop; override; // 重写执行循环
  16.   public
  17.     /// 初始化线程以进行周期性任务处理
  18.     // - 当 ProcessEvent.SetEvent 被调用或自上次处理以来过去了 aOnProcessMS 毫秒时，将调用 aOnProcess
  19.     // - 如果 aOnProcessMS 为 0，则等待直到 ProcessEvent.SetEvent 被调用
  20.     // - 您可以定义一些回调来嵌套线程执行，例如，分配给 TRestServer.BeginCurrentThread/EndCurrentThread
  21.     constructor Create(
  22.         const aThreadName     : RawUtf8;
  23.         const aOnProcess      : TOnSynBackgroundThreadProcess;
  24.         aOnProcessMS          : cardinal;
  25.         const aOnBeforeExecute: TOnNotifyThread = nil;
  26.         const aOnAfterExecute : TOnNotifyThread = nil;
  27.         aStats                : TSynMonitorClass = nil;
  28.         CreateSuspended       : boolean = false); reintroduce; virtual;
  29.   
  30.     /// 终结线程并等待其结束
  31.     destructor Destroy; override;
  32.   
  33.     /// 访问周期性任务的实现事件
  34.     property OnProcess: TOnSynBackgroundThreadProcess
  35.       read fOnProcess;
  36.   
  37.     /// 当 OnProcess 引发异常时执行的事件回调
  38.     // - 提供的 Sender 参数是引发的异常实例
  39.     property OnException: TNotifyEvent
  40.       read fOnException write fOnException;
  41.   
  42.   published
  43.   
  44.     /// 访问周期性任务处理的延迟时间（毫秒）
  45.     property OnProcessMS: cardinal  read fOnProcessMS write fOnProcessMS;
  46.   
  47.     /// 处理统计信息
  48.     // - 如果在类构造函数中 aStats 为 nil，则可能为 nil
  49.     property Stats: TSynMonitor   read fStats;
  50.   end;
复制代码
TSynBackgroundTimer 定义
  1.   // TSynBackgroundTimer 类声明（稍后定义）
  2.   TSynBackgroundTimer = class;
  4.   /// 由 TSynBackgroundThreadProcess 定期执行的事件回调（特定于 TSynBackgroundTimer）
  5.   // - 如果此任务 FIFO 中没有挂起的消息，则 Msg 为 ''
  6.   // - 对于此任务 FIFO 中的每个挂起消息，都会设置 Msg
  7.   // - 在 mORMot 1 中，有一个 TWaitEvent 参数，现在已被移除
  8.   TOnSynBackgroundTimerProcess = procedure(Sender: TSynBackgroundTimer;
  9.     const Msg: RawUtf8) of object;
  11.   /// TSynBackgroundTimer 内部注册列表使用的记录类型
  12.   TSynBackgroundTimerTask = record
  13.     OnProcess: TOnSynBackgroundTimerProcess; // 处理任务的回调过程
  14.     Secs: cardinal; // 任务执行的间隔时间（秒）
  15.     NextTix: Int64; // 下一次执行任务的时间戳
  16.     Msg: TRawUtf8DynArray; // 与此任务关联的待处理消息队列
  17.     MsgSafe: TLightLock; // 保护 Msg[] 列表的轻量级锁
  18.   end;
  20.   /// 存储 TSynBackgroundTimer 内部注册列表的动态数组类型
  21.   TSynBackgroundTimerTaskDynArray = array of TSynBackgroundTimerTask;
  23.   /// 能够在后台线程中以定期的速度运行一个或多个任务的线程类
  24.   // - 例如，通过继承自 TRestBackgroundTimer 的 TRest.TimerEnable/TimerDisable 方法使用
  25.   // - 每个进程可以有自己的文本消息 FIFO 队列
  26.   // - 如果您期望更新某些 GUI，则应该使用 TTimer 组件（例如，周期为 200ms），
  27.   // 因为 TSynBackgroundTimer 将使用它自己的独立线程
  28.   TSynBackgroundTimer = class(TSynBackgroundThreadProcess)
  29.   protected
  30.     fTask: TSynBackgroundTimerTaskDynArray; // 内部任务列表
  31.     fTasks: TDynArrayLocked; // 任务列表的封装和同步访问
  32.     fProcessing: boolean; // 标记当前是否有任务正在处理
  33.     fProcessingCounter: integer; // 处理中的任务计数器（可能是内部使用）
  34.     procedure EverySecond(Sender: TSynBackgroundThreadProcess); // 每秒执行一次的回调，用于处理任务
  35.     function Find(const aProcess: TMethod): PtrInt; // 查找已注册的任务（内部使用）
  36.     function Add(const aOnProcess: TOnSynBackgroundTimerProcess;
  37.       const aMsg: RawUtf8; aExecuteNow: boolean): boolean; // 添加任务到内部列表
  39.   public
  41.     /// 初始化线程以进行周期性任务处理
  42.     // - 您可以定义一些回调来嵌套线程执行，例如，
  43.     // 分配给 TRestServer.BeginCurrentThread/EndCurrentThread，如 TRestBackgroundTimer.Create 所做
  44.     constructor Create(const aThreadName: RawUtf8;
  45.       const aOnBeforeExecute: TOnNotifyThread = nil;
  46.       aOnAfterExecute: TOnNotifyThread = nil;
  47.       aStats: TSynMonitorClass = nil;
  48.       aLogClass: TSynLogClass = nil); reintroduce; virtual;
  49.   
  50.     /// 销毁线程
  51.     destructor Destroy; override;
  52.     /// 为在固定秒数周期上运行的任务定义一个处理方法
  53.     // - 对于 mORMot 服务上的后台进程，请考虑使用 TRest 的
  54.     // TimerEnable/TimerDisable 方法及其关联的 BackgroundTimer 线程
  55.     procedure Enable(const aOnProcess: TOnSynBackgroundTimerProcess;
  56.       aOnProcessSecs: cardinal);
  57.   
  58.     /// 取消定义在固定秒数周期上运行的任务
  59.     // - aOnProcess 应通过之前的 Enable() 方法调用进行注册
  60.     // - 成功时返回 true，如果提供的任务未注册则返回 false
  61.     // - 对于 mORMot 服务上的后台进程，请考虑使用 TRestServer 的
  62.     // TimerEnable/TimerDisable 方法及其 TSynBackgroundTimer 线程
  63.     function Disable(const aOnProcess: TOnSynBackgroundTimerProcess): boolean;
  64.   
  65.     /// 在任务的下一次执行期间添加要处理的消息
  66.     // - 提供的消息将被添加到与 aOnProcess 关联的内部 FIFO 列表中，
  67.     // 然后作为 aMsg 参数传递给每次调用
  68.     // - 如果 aExecuteNow 为 true，则不会等待下一个 aOnProcessSecs 的发生
  69.     // - aOnProcess 应通过之前的 Enable() 方法调用进行注册
  70.     // - 成功时返回 true，如果提供的任务未注册则返回 false
  71.     function EnQueue(const aOnProcess: TOnSynBackgroundTimerProcess;
  72.       const aMsg: RawUtf8; aExecuteNow: boolean = false): boolean; overload;
  73.   
  74.     /// 在任务的下一次执行期间添加要处理的消息（格式化版本）
  75.     // - ...（与上一个 EnQueue 重载类似，但允许格式化消息）
  76.     function EnQueue(const aOnProcess: TOnSynBackgroundTimerProcess;
  77.       const aMsgFmt: RawUtf8; const Args: array of const;
  78.       aExecuteNow: boolean = false): boolean; overload;
  79.   
  80.     /// 从处理列表中删除消息
  81.     // - 提供的消息将在与 aOnProcess 关联的内部 FIFO 列表中进行搜索，
  82.     // 如果找到则从列表中删除
  83.     // - aOnProcess 应通过之前的 Enable() 方法调用进行注册
  84.     // - 成功时返回 true，如果提供的消息未注册则返回 false
  85.     function DeQueue(const aOnProcess: TOnSynBackgroundTimerProcess;
  86.       const aMsg: RawUtf8): boolean;
  87.   
  88.     /// 不等待下一个 aOnProcessSecs 发生，立即执行任务
  89.     // - aOnProcess 应通过之前的 Enable() 方法调用进行注册
  90.     // - 成功时返回 true，如果提供的任务未注册则返回 false
  91.     function ExecuteNow(const aOnProcess: TOnSynBackgroundTimerProcess): boolean;
  92.   
  93.     /// 不等待下一个 aOnProcessSecs 发生，仅执行一次任务
  94.     // - aOnProcess 不需要通过之前的 Enable() 方法调用进行注册
  95.     function ExecuteOnce(const aOnProcess: TOnSynBackgroundTimerProcess): boolean;
  96.   
  97.     /// 等待直到没有后台任务正在处理
  98.     procedure WaitUntilNotProcessing(timeoutsecs: integer = 10);
  99.   
  100.     /// 对内部任务列表的低级访问
  101.     property Task: TSynBackgroundTimerTaskDynArray read fTask;
  102.   
  103.     /// 对内部任务列表封装和安全的低级访问
  104.     property Tasks: TDynArrayLocked read fTasks;
  105.   
  106.     /// 返回当前是否有任务正在处理
  107.     property Processing: boolean read fProcessing;
  108.   end;shi
复制代码
TSynBackgroundThreadEvent 例程代码
  1. uses
  2.   SysUtils, Classes, // 引入必要的单元
  3.   mormot.core.threads;
  5. type
  6.   TParams = record
  7.     Ti :integer;
  8.     Ts :string;
  9.   end;
  11.   { TForm1 }
  13.   TForm1 = class(TForm)
  14.     btThreadEvent :TButton;
  15.     Memo1 :TMemo;
  16.     procedure btThreadEventClick(Sender :TObject);
  17.   private
  19.   public
  20.     procedure OnBackgroundProcess1(Sender :TSynBackgroundThreadEvent; ProcessOpaqueParam :pointer);
  21.   end;   
  23. implementation
  25. procedure TForm1.OnBackgroundProcess1(Sender :TSynBackgroundThreadEvent; ProcessOpaqueParam :pointer);
  26. var
  27.   Call :^TParams absolute ProcessOpaqueParam; // pascal的妙
  28. begin
  29.   if Call = nil then
  30.     exit;
  31.   // 这里是后台处理的代码
  32.   WriteLn('Background process running with param: ', Call^.Ti);
  33.   LogDebug('Background process running with Tparam: T1=%d , T2=%s ', [Call^.Ti, Call^.Ts]);
  34. end;
  37. procedure TForm1.btThreadEventClick(Sender :TObject);
  38. var
  39.   BGThread :TSynBackgroundThreadEvent;
  40.   Param  : ^TParams ;
  41. var
  42.   MyProcessEvent :TOnProcessSynBackgroundThread;
  43. begin
  44.   New(Param);
  45.   Param^.Ti := 10; // 初始化参数
  46.    Param^.Ts := 'S99';
  48.   // 创建并启动后台线程事件
  49.   BGThread := TSynBackgroundThreadEvent.Create(@OnBackgroundProcess1, // 传递我们的处理过程
  50.     nil, // OnIdle回调，这里不使用
  51.     'MyBackgroundThreadEventDemo');
  52.   try
  53.     // 运行后台线程并等待完成
  54.     BGThread.RunAndWait(Param);
  55.     WriteLn('Background process finished. New param value: ', Param^.Ts);
  56.   finally
  57.     BGThread.Free;  // 销毁线程对象
  58.     Dispose(Param); // 释放参数内存
  59.   end;
  60. end;
复制代码
TSynBackgroundThreadMethod 例程代码
  1. interface
  2. uses
  3.   SysUtils, Classes,
  4.   mormot.core.threads;
  5. type
  6.   TForm1 = class(TForm)
  7.     btThreadMethod: TButton;
  8.     Memo1 :TMemo;
  9.     procedure btThreadMethodClick(Sender: TObject);
  10.   private
  12.   public
  13.     procedure ThreadMethod;
  14.   end;
  16. implementation  
  18. procedure TForm1.ThreadMethod;
  19. begin
  20.   // 这里是线程方法的代码
  21.   WriteLn('Thread method running in background');
  22.   // 模拟一些耗时操作
  23.   Sleep(1000);
  24. end;   
  26. procedure TForm1.btThreadMethodClick(Sender: TObject);
  27. var
  28.   BGThread: TSynBackgroundThreadMethod;
  29. begin
  30.   // 创建后台线程方法对象
  31.   BGThread := TSynBackgroundThreadMethod.Create(nil, 'MyBackgroundThreadMethodDemo');
  32.   try
  33.     // 注意：这里我们重写了RunAndWait方法，所以直接传递TThreadMethod
  34.     BGThread.RunAndWait(@ThreadMethod);
  35.   finally
  36.     BGThread.Free; // 销毁线程对象
  37.   end;
  38. end;  
复制代码
注意：上面的 TSynBackgroundThreadMethod示例中，我假设了 RunAndWait方法被重写以接受 TThreadMethod作为参数，但根据原始定义，这并不是直接支持的。通常，您会在 Process方法内部调用传入的 TThreadMethod。为了保持示例简单，我展示了如何可能使用它，但在实际应用中，您可能需要在 Process方法内部处理这一点。
TSynBackgroundThreadProcedure 例程代码
  1. uses
  2.   SysUtils, Classes,
  3.   mormot.core.threads;
  4. type
  6.   TParams = record
  7.     Ti :integer;
  8.     Ts :string;
  9.   end;
  10.   ....xl
  11. implementation
  13. procedure OnBackgroundProcedure(ProcessOpaqueParam :pointer);
  14. var
  15.   Call :^TParams absolute ProcessOpaqueParam;
  16. begin
  17.   if Call = nil then
  18.     exit;
  19.   // 这里是后台处理的代码
  20.   WriteLn('Background Procedure running with param: ', Call^.Ti);
  21.   LogDebug('Background Procedure running with Tparam: T1=%d , T2=%s ', [Call^.Ti, Call^.Ts]);
  23. end;
  25. procedure TForm1.btThreadProcedureClick(Sender: TObject);
  26. var
  27.   BGThread: TSynBackgroundThreadProcedure;
  28.   Param  : ^TParams ;
  29. begin
  30.   New(Param);
  31.   Param^.Ts := 'Hello, Background!';
  32.     Param^.Ti := 100;
  34.   // 创建并启动后台线程过程
  35.   BGThread := TSynBackgroundThreadProcedure.Create(
  36.     @OnBackgroundProcedure, // 传递我们的处理过程
  37.     nil, // OnIdle回调，这里不使用
  38.     'MyBackgroundThreadProcedureDemo'
  39.   );
  40.   try
  41.     // 运行后台线程并等待完成
  42.     BGThread.RunAndWait(Param);
  43.        WriteLn('Background Procedure finished. New param value: ', Param^.Ts);
  44.   finally
  45.     BGThread.Free; // 销毁线程对象
  46.     Dispose(Param); // 释放参数内存
  47.   end;
  48. end;
  49.    
复制代码
TSynBackgroundThreadProcess 例程代码
  1. uses
  2.   SysUtils, Classes, // 引入SysUtils和Classes单元以使用WriteLn和TThread等
  3.   mormot.core.threads;
  5. procedure TForm1.OnBackgroundProcess(Sender :TSynBackgroundThreadProcess);
  6. begin
  7.   WriteLn('Background Process running WriteLn ');
  8.   LogDebug('Background Process running ', []);
  9. end;
  11. procedure TForm1.btThreadProcessClick(Sender :TObject);
  12. var
  13.   BGThread :TSynBackgroundThreadProcess;
  14. begin
  15.   try
  16.       // 创建TSynBackgroundThreadProcess实例
  17.     BGThread := TSynBackgroundThreadProcess.Create('MyBackgroundThread', // 线程名称
  18.       @OnBackgroundProcess, // 周期性执行的方法
  19.       1000, // 周期时间，单位为毫秒
  20.       nil, // OnBeforeExecute回调，这里不使用
  21.       nil  // OnAfterExecute回调，这里不使用
  22.       // aStats和其他参数根据需要进行设置
  23.       );
  24.     try
  25.       // 启动线程（注意：在TSynBackgroundThreadProcess的构造函数中，
  26.       // 如果CreateSuspended参数为false，则线程将自动启动）
  27.       // 在这个例子中，我们假设CreateSuspended默认为false
  29.       // 等待一段时间以观察后台线程的行为
  30.       // 注意：在实际应用中，您可能不需要这样做，因为主线程可能会继续执行其他任务
  31.       Sleep(6000); // 等待6秒
  33.     finally
  34.       // 销毁线程对象（注意：在析构函数中，线程将尝试优雅地终止）
  35.       BGThread.Free;
  36.       // 等待线程真正结束（可选，但在这个例子中我们依赖析构函数的行为）
  37.     end;
  38.   except
  39.     on E :Exception do
  40.       WriteLn('Error: ' + E.Message);
  41.   end;
  42.   WriteLn('Program 结束.');
  43.   LogDebug('Background Process 结束 ', []);
  44. end;
  46. procedure TForm1.btThreadProcess2Click(Sender :TObject);
  47. begin
  48.   LogMSG('StartWatching');
  49.   G_BGThread := TSynBackgroundThreadProcess.Create('watchdog', @OnBackgroundProcess, 1000);
  50. end;  
复制代码
注意：在上面的示例中，我假设 TSynBackgroundThreadProcess的构造函数有一个 CreateSuspended参数（这在标准的 TThread构造函数中是存在的），但根据您提供的类定义，这个参数实际上并没有在 TSynBackgroundThreadProcess的构造函数中明确列出。如果 TSynBackgroundThreadProcess是自动启动线程的，那么您可能不需要显式调用任何启动方法。
TSynBackgroundTimer 例程代码
  1. uses
  2.   SysUtils, // 引入SysUtils单元以使用WriteLn
  3.   mormot.core.threads;
  5. procedure TForm1.OnBackgroundTimer(Sender :TSynBackgroundTimer; const Msg :RawUtf8);
  6. begin
  7.   WriteLn('Timer 0 called in background thread. Message: ' + Msg);
  8. end;
  10. procedure TForm1.OnBackgroundTimer2(Sender :TSynBackgroundTimer; const Msg :RawUtf8);
  11. begin
  12.   WriteLn('Timer 2 called in background thread. Message : ' + Msg);
  13. end;
  15. procedure TForm1.OnBackgroundTimer3(Sender :TSynBackgroundTimer; const Msg :RawUtf8);
  16. begin
  17.   WriteLn('Timer 3 called in background thread. Message : ' + Msg);
  18. end;
  20. procedure TForm1.OnBackgroundTimer5(Sender :TSynBackgroundTimer; const Msg :RawUtf8);
  21. begin
  22.   WriteLn('Timer 5 called in background thread. Message : ' + Msg);
  23. end;
  25. procedure TForm1.btThreadTimerClick(Sender :TObject);
  26. var
  27.   Timer :TSynBackgroundTimer;
  28. begin
  29.   try
  30.      // 创建TSynBackgroundTimer实例
  31.     Timer := TSynBackgroundTimer.Create('MyBackgroundTimer' // 线程名称
  32.       // 其他参数根据需要进行设置，这里省略了OnBeforeExecute、OnAfterExecute、aStats和aLogClass
  33.       );
  34.     try
  36.       // 启用一个周期性任务，每2秒执行一次
  37.       Timer.Enable(@OnBackgroundTimer2, 2);
  39.       // 后面动作都要用同一个  OnBackgroundTimer2  这点很重要
  41.       // 向任务队列添加消息，并请求立即执行（尽管在这个上下文中，立即执行可能不会立即发生）
  42.       Timer.EnQueue(@OnBackgroundTimer2, 'Hello from background timer!', True);
  46.       // 等待一段时间以观察后台定时器的行为
  47.       // 注意：在实际应用中，您可能不需要这样做，因为主线程可能会继续执行其他任务
  48.       // Sleep(10000); // 等待10秒
  50.       // Timer.ExecuteOnce(@OnBackgroundTimer2);
  52.       //Timer.ExecuteNow(@OnBackgroundTimer2);
  53.       Sleep(10000); // 等待10秒
  54.       // 禁用周期性任务（在这个示例中我们不会禁用它，但展示了如何禁用）
  55.       // Timer.Disable(@MyTimerProcess2);
  57.     finally
  58.       // 销毁TSynBackgroundTimer实例（注意：在实际应用中，您可能希望等待所有后台任务完成后再销毁定时器）
  59.       // 但在这个简单示例中，我们立即销毁它
  60.       Timer.Free;
  61.       // 由于我们立即销毁了定时器，并且主线程继续执行（尽管在这个示例中被Sleep阻塞了），
  62.       // 因此后台线程可能没有机会执行更多的回调。
  63.       // 在实际应用中，您应该确保在销毁定时器之前给后台线程足够的时间来完成其工作。
  64.     end;  
  65.   except
  66.     on E :Exception do
  67.       WriteLn('Error: ' + E.Message);
  68.   end;
  69.   WriteLn('Program ended.');
  70. end;  
复制代码
在上面的 TSynBackgroundTimer示例中，我展示了如何创建定时器、启用周期性任务、向任务队列添加消息，并等待一段时间以观察定时器的行为。请注意，由于我们调用了 Sleep并且立即销毁了定时器，因此后台线程可能没有机会执行更多的回调。在实际应用中，您应该确保在销毁定时器之前给后台线程足够的时间来完成其工作，或者调用 Timer.WaitUntilNotProcessing（如果该类提供了这样的方法）来等待所有后台任务完成。然而，根据提供的类定义，TSynBackgroundTimer并没有直接提供 WaitUntilNotProcessing方法，所以您可能需要实现自己的同步机制来达到这个目的。

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

使用道具 举报
相关推荐
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册
发帖
茅香馨
4 天前

0

粉丝关注

13

主题发布

板块介绍填写区域，请于后台编辑
微信扫一扫