我正在使用 XE8 并尝试构建我的真实应用程序示例。
我需要在主“服务线程”和 OTL 线程池之间进行通信。 这些例子都是用表单和监视器设置的。我不需要那些,但我想不出一种方法来编写干净的代码。到目前为止,这就是我所做的:
TProcessWorker = Class( TOmniWorker )
strict private
FTaskID : int64;
FIndex : Integer;
FFolder : String;
protected
function Initialize: Boolean; override;
public
procedure WriteTask( var msg : TMessage); message _AM_WriteTask;
End;
{ TProcessWorker }
function TProcessWorker.Initialize: Boolean;
begin
FTaskID := Task.UniqueID;
FIndex := 0;
result := True;
FFolder := Format('%s/%d', [Task.Param['Folder'].AsString, FTaskID]);
ForceDirectories(FFolder);
end;
实现为:
procedure TProcessWorker.WriteTask(var msg: TMessage);
var
ps : PString;
L : TStringStream;
begin
Ps:= PString(msg.LParam);
L := TStringStream.Create( ps^ );
try
L.SaveToFile( format('%s\%d.txt',[FFolder, fIndex]) );
finally
l.Free;
inc(FIndex);
end;
end;
在主线程中,为了创建池,我调用:
FThreadPool := CreateThreadPool('Thread pool test');
和
var
lFolder : String;
Process : IOmniWorker;
begin
lFOlder := ExtractFilePath(ParamStr(0));
Process := TProcessWorker.Create;
CreateTask( Process, 'Task test').Unobserved.SetParameter('Folder',lFolder).Schedule(FThreadPool);
我不知道如何正确调用我的工作线程。在我的实际应用程序中,将触发多个线程,我需要确保正确使用线程池。
1) 通过像我一样调用 CreateTask,我如何正确使用线程池?为我需要的每个进程调用 CreateTask 对我来说似乎很奇怪。
2) 永远不会触发工作线程。我应该如何让我的工作线程工作! :)
问候, 克莱门特
最佳答案
OmniThreadLibrary 测试 08_RegisterComm
展示了如何在两个线程之间直接通信。
基本上,您必须创建 IOmniTwoWayChannel
的实例并在工作人员的 Initialize
中注册其端点使用 Task.RegisterComm(<channel>)
的方法.
然后您可以使用 <channel>.Send(<message>, <data>)
以“正常”方式发送消息如果您以 Delphi 方式装饰它,它们将被分派(dispatch)到其他任务的消息方法:
procedure MessageHandler(var msg: TOmniMessage); message <message>;
关于multithreading - Delphi - OTL - ThreadPool 和 Worker 线程之间的通信,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30470815/