mormot.core.threads--TSynParallelProcess
<h1 id="mormotcorethreads--tsynparallelprocess">mormot.core.threads--TSynParallelProcess</h1><pre><code class="language-pascal">{ ************ 线程池中的并行执行 }
type
/// TSynParallelProcess 的并行化过程回调
// - 如果 0<=IndexStart<=IndexStop，则应执行某些过程
TOnSynParallelProcess = procedure(IndexStart, IndexStop: integer) of object;
/// 为 TSynParallelProcess 执行过程的线程
TSynParallelProcessThread = class(TSynBackgroundThreadMethodAbstract)
protected
fMethod: TOnSynParallelProcess; // 回调方法
fIndexStart, fIndexStop: integer; // 要处理的索引范围
procedure Start(const Method: TOnSynParallelProcess; // 开始执行过程
IndexStart, IndexStop: integer);
/// 执行 fMethod(fIndexStart,fIndexStop)
procedure Process; override;
public
end;
/// 允许在线程池中并行执行基于索引的过程
// - 将创建自己的线程池，然后将工作分配给每个线程执行
TSynParallelProcess = class(TSynPersistentLock)
protected
fThreadName: RawUtf8; // 线程名称
fPool: array of TSynParallelProcessThread; // 线程池
fThreadPoolCount: integer; // 线程池中的线程数
fParallelRunCount: integer; // 并行运行次数
public
/// 初始化线程池
// - 您可以定义一些回调来嵌套线程执行，例如，分配给 TRestServer.BeginCurrentThread/EndCurrentThread
// - 最多可设置 MaxThreadPoolCount=32 个线程（您可以允许更大的值，但此线程池的目的是使其进程饱和每个 CPU 核心）
// - 如果 ThreadPoolCount 为 0，则不会创建线程，并且过程将在当前线程中执行
constructor Create(ThreadPoolCount: integer; const ThreadName: RawUtf8;
const OnBeforeExecute: TOnNotifyThread = nil; // 执行前通知回调
const OnAfterExecute: TOnNotifyThread = nil;// 执行后通知回调
MaxThreadPoolCount: integer = 32); reintroduce; virtual;
/// 终结线程池
destructor Destroy; override;
/// 并行运行一个方法，并等待执行完成
// - 将 Method 的执行分散到线程中
// - 如果在过程中发生任何异常，则此方法将引发 ESynParallel 异常
// - 如果设置了 OnMainThreadIdle，则当前线程（例如，预期为主 UI 线程）将不会处理任何内容，但在等待后台线程时调用此事件
procedure ParallelRunAndWait(const Method: TOnSynParallelProcess;
MethodCount: integer; const OnMainThreadIdle: TNotifyEvent = nil);
published
/// 已激活的线程数
property ParallelRunCount: integer
read fParallelRunCount;
/// 此实例线程池中当前有多少线程
property ThreadPoolCount: integer
read fThreadPoolCount;
/// 一些文本标识符，用于区分每个拥有的线程
property ThreadName: RawUtf8
read fThreadName;
end;
</code></pre>
<p>后期再整理！</p>
<p>由于 <code>TSynParallelProcess</code>在mORMot 2框架中是一个假定的类（因为标准的mORMot 2库并不直接包含这个类名，但它可能是一个自定义扩展或类似功能的类的代表），我将基于您提供的类定义来编写一个假设的例程代码，这个代码将模拟在Free Pascal中使用这样一个类。</p>
<p>请注意，以下代码将不会直接编译，因为 <code>TSynParallelProcess</code>和 <code>TSynParallelProcessThread</code>的具体实现细节（如构造函数、析构函数和方法的内部逻辑）并未给出。但是，我将提供一个结构化的示例，展示如何使用这样的类（如果它存在的话）。</p>
<pre><code class="language-pascal">program TSynParallelProcessDemo;
{$MODE DELPHI}
uses
SysUtils, Classes; // 引入必要的单元
// 假设TSynParallelProcess和TSynParallelProcessThread已经在某个单元中定义
// 这里我们使用一个占位符单元名YourMormotUnit
// 注意：在实际应用中，您需要替换'YourMormotUnit'为包含这些类的实际单元名
uses YourMormotUnit;
procedure MyParallelTask(IndexStart, IndexStop: integer);
begin
// 这里是您的并行任务逻辑
WriteLn('Executing task with indices from ', IndexStart, ' to ', IndexStop);
// 模拟耗时操作
Sleep(100); // 假设每个任务需要一些时间来完成
end;
var
ParallelProcessor: TSynParallelProcess;
TaskCount: Integer;
begin
try
// 初始化任务计数（这里假设我们有100个任务要并行处理）
// 注意：在实际应用中，您可能需要根据具体情况来确定这个值
TaskCount := 100;
// 创建TSynParallelProcess实例
// 注意：这里我们假设ThreadPoolCount是一个合理的值，例如CPU核心数的两倍
// 并且MaxThreadPoolCount足够大以容纳所需的线程数
// ThreadName是可选的，用于标识线程池中的线程
ParallelProcessor := TSynParallelProcess.Create(
System.SysUtils.GetProcessorCount * 2, // 假设线程池大小为CPU核心数的两倍
'MyParallelTasks', // 线程名称前缀（可选）
nil, // OnBeforeExecute回调（这里不使用）
nil// OnAfterExecute回调（这里不使用）
);
try
// 并行运行任务并等待完成
// 注意：这里的ParallelRunAndWait是假设的方法，它可能不直接存在于TSynParallelProcess中
// 您需要根据实际的方法签名和逻辑来调整以下调用
// 由于我们没有ParallelRunAndWait的具体实现，这里只是一个示意性的调用
// 在实际中，您可能需要调用一个不同的方法，或者ParallelRunAndWait本身就需要您来实现
// 假设ParallelRunAndWait接受一个任务过程和任务总数作为参数
ParallelProcessor.ParallelRunAndWait(
@MyParallelTask, // 指向您的并行任务过程的指针
TaskCount // 要并行处理的任务总数
);
finally
// 销毁TSynParallelProcess实例
ParallelProcessor.Free;
end;
except
on E: Exception do
WriteLn('An error occurred: ', E.Message);
end;
// 保持控制台窗口打开，直到用户按任意键
WriteLn('Press Enter to exit...');
ReadLn;
end.
</code></pre>
<p><strong>重要说明</strong>：</p>
<ol>
<li><strong>类和方法的存在性</strong>：上述代码假设 <code>TSynParallelProcess</code>类及其 <code>ParallelRunAndWait</code>方法存在。在mORMot 2的标准库中，这样的类和方法可能不存在，或者它们的名称和参数可能有所不同。</li>
<li><strong>实现细节</strong>：由于我们没有 <code>TSynParallelProcess</code>和 <code>TSynParallelProcessThread</code>的具体实现，因此上述代码中的 <code>ParallelRunAndWait</code>调用是示意性的。在实际应用中，您需要根据实际可用的方法来实现并行任务的执行。</li>
<li><strong>线程池大小</strong>：在创建 <code>TSynParallelProcess</code>实例时，我使用了 <code>System.SysUtils.GetProcessorCount * 2</code>作为线程池的大小。这只是一个常见的启发式方法，用于确定合理的线程数。然而，最佳线程数取决于您的具体应用程序和工作负载。</li>
<li><strong>错误处理</strong>：代码中包含了基本的错误处理逻辑，用于捕获并打印异常消息。在实际应用中，您可能需要根据需要扩展这种错误处理。</li>
<li><strong>单元引用</strong>：请将 <code>uses YourMormotUnit;</code>中的 <code>YourMormotUnit</code>替换为包含 <code>TSynParallelProcess</code>和 <code>TSynParallelProcessThread</code>定义的实际单元名。如果这些类是您自定义的，那么您需要确保它们已经被正确编译并包含在您的项目中。</li>
</ol><br><br>
来源：https://www.cnblogs.com/hieroly/p/18289982
頁:
[1]