如何監視OmniThreadLibrary中的管道階段？

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可以是一個正常的程序或方法。