delphi - 如何监控 OmniThreadLibrary 中的 Pipeline 阶段？

Question

是否可以以某种方式监视管道任务？我尝试像这样向每个任务添加监视器

FPipeline := Parallel.Pipeline()
  .Stage(StageWorker1, Parallel.TaskConfig.MonitorWith(MyMonitor))
     .NumTasks(MaxReadThreadCount)
  .Stage(StageWorker2, Parallel.TaskConfig.MonitorWith(MyMonitor))
  .Run();

但出现异常“任务只能用单个监视器进行监视”(据我了解，发生这种情况是因为已经为管道阶段安装了内部隐藏监视器)。

Answer 1

使用Parallel.TaskConfig.OnMessage并提供通用的消息处理函数。

FPipeline := Parallel.Pipeline()
  .Stage(StageWorker1, Parallel.TaskConfig.OnMessage(MessageProc))
     .NumTasks(MaxReadThreadCount)
  .Stage(StageWorker2, Parallel.TaskConfig.OnMessage(MessageProc))
  .Run();

procedure MessageProc(var msg: TOmniMessage);
begin
  ...
end;

MessageProc 可以是普通过程或方法。