mormot.core.threads--TSynThread

mormot.core.threads--TSynThread

1. { ************ 面向服务器进程的线程池 }
3. type
4.   {$M+} // 开启内存管理消息，用于调试
6.   /// 一个简单的TThread，具有在线程上下文中运行的"Terminate"事件
7.   // - TThread.OnTerminate事件在Synchronize()内部运行，因此不符合我们的期望，
8.   // 即在线程创建的上下文中释放资源（例如，对于COM对象或某些数据库驱动程序）
9.   // - 由THttpServerGeneric.NotifyThreadStart()内部使用 - 您不应该使用受保护的fOnThreadTerminate事件处理程序
10.   // - 还定义了一个Start方法，以与Delphi的旧版本兼容
11.   TSynThread = class(TThreadAbstract)
12.   protected
13.     fStartNotified: TObject; // 标记线程是否已通知开始
14.     // 我们定义了一个fOnThreadTerminate事件，该事件将在终止的线程上下文中运行
15.     // （而TThread.OnTerminate在主线程中调用）
16.     // -> 参见THttpServerGeneric.OnHttpThreadTerminate事件属性
17.     fOnThreadTerminate: TOnNotifyThread;
18.     procedure DoTerminate; override; // 重写DoTerminate方法
19.   public
20.     /// 初始化线程实例，处于非挂起状态
21.     constructor Create(CreateSuspended: boolean); reintroduce; virtual;
22.     /// Sleep的安全版本，不会中断线程进程
23.     // - 如果线程已终止，则返回TRUE
24.     // - 如果成功等待了MS毫秒，则返回FALSE
25.     function SleepOrTerminated(MS: cardinal): boolean;
26.     /// 确保仅在NotifyThreadStart完成后调用fOnThreadTerminate
27.     property StartNotified: TObject
28.       read fStartNotified write fStartNotified;
29.   end;
31.   /// 实现具有开始/停止通知功能的线程的抽象类
32.   // - 例如，服务器线程
33.   // - 不要使用这个类，而是使用THttpServer, THttpApiServer或TWebSocketServer（如mormot.net.websock中定义的）
34.   TNotifiedThread = class(TSynThread)
35.   protected
36.     fProcessName: RawUtf8; // 进程名称
37.     fOnThreadStart: TOnNotifyThread; // 线程开始通知事件
38.     procedure SetOnTerminate(const Event: TOnNotifyThread); virtual; // 设置线程终止事件
39.     procedure NotifyThreadStart(Sender: TSynThread); // 通知线程开始
40.   public
41.     /// 初始化服务器实例，处于非挂起状态
42.     constructor Create(CreateSuspended: boolean;
43.       const OnStart, OnStop: TOnNotifyThread; // 开始和停止通知事件
44.       const ProcessName: RawUtf8); reintroduce; virtual;
45.     /// 将每个线程分配给单个逻辑CPU核心
46.     // - 例如，对于HTTP服务器，它可能确保具有短生命周期请求和高线程数的更好的可扩展性
47.     procedure SetServerThreadsAffinityPerCpu(
48.       const log: ISynLog; const threads: TThreadDynArray);
49.     /// 将每个线程分配给单个硬件CPU插槽
50.     // - 例如，对于具有多个物理CPU包的复杂硬件上的HTTP服务器，它可能确保更好的可扩展性
51.     // - 但这非常挑剔，因此仅应在实际硬件上进行适当测试后才能启用
52.     procedure SetServerThreadsAffinityPerSocket(
53.       const log: ISynLog; const threads: TThreadDynArray);
54.   end;
56.   /// 实现具有日志通知功能的线程的抽象类
57.   TLoggedThread = class(TSynThread)
58.   protected
59.     fProcessName: RawUtf8; // 进程名称
60.     fLogClass: TSynLogClass; // 日志类
61.     fLog: TSynLog; // 在DoExecute线程上下文中的日志实例
62.     fProcessing: boolean; // 标记线程是否正在处理
63.     procedure Execute; override; // 重写Execute方法
64.     // 继承类应该重写此方法以实现适当的处理逻辑
65.     procedure DoExecute; virtual; abstract;
66.   public
67.     /// 初始化服务器实例，处于非挂起状态
68.     constructor Create(CreateSuspended: boolean; Logger: TSynLogClass;
69.       const ProcName: RawUtf8); reintroduce; virtual;
70.     /// 通知线程终止，并等待DoExecute完成
71.     procedure TerminateAndWaitFinished(TimeOutMs: integer = 5000); virtual;
72.     /// 关联的日志类
73.     property LogClass: TSynLogClass
74.       read fLogClass;
75.   published
76.     /// 此线程的名称，作为SetCurrentThreadName()的参数提供
77.     property ProcessName: RawUtf8
78.       read fProcessName;
79.   end;
81.   /// 在后台线程中由TLoggedWorkThread.Create调用的事件
82.   TOnLoggedWorkProcess = procedure(const Context: TDocVariantData) of object;
84.   /// 一个能够在后台线程中运行某些进程，并具有适当日志记录和最终通知功能的类
85.   TLoggedWorkThread = class(TLoggedThread)
86.   protected
87.     fSender: TObject; // 发送者对象
88.     fOnExecute, fOnExecuted: TNotifyEvent; // 执行前后的事件
89.     fOnExecuteParam: TOnLoggedWorkProcess; // 执行参数的事件
90.     fContext: TDocVariantData; // 上下文数据
91.     procedure DoExecute; override; // 重写DoExecute方法
92.   public
93.     /// 此构造函数将直接在后台启动线程
94.     // - 上下文作为常规的TNotifyEvent
95.     constructor Create(Logger: TSynLogClass; const ProcessName: RawUtf8;
96.       Sender: TObject; const OnExecute: TNotifyEvent;
97.       const OnExecuted: TNotifyEvent = nil);
98.         reintroduce; overload;
99.     /// 此构造函数将直接在后台启动线程
100.     // - 上下文作为具有名称/值对的TDocVariantData对象
101.     constructor Create(Logger: TSynLogClass; const ProcessName: RawUtf8;
102.       const NameValuePairs: array of const; const OnExecute: TOnLoggedWorkProcess;
103.       const OnExecuted: TNotifyEvent = nil);
104.         reintroduce; overload;
105.   end;

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。