2014-09-22 38 views
1

在使用OmniThread库创建并行任务的程序中,当我尝试访问并行任务中的参数时,参数访问后面的代码未执行,因此显然任务被中止:在OmniThread并行任务中访问参数将中止任务

uses 
    System.SysUtils, System.Classes, 
    Vcl.Controls, Vcl.Forms, Vcl.Dialogs, Vcl.StdCtrls, 

    OtlComm, OtlTask, OtlTaskControl, OtlEventMonitor; 

type 
    TForm1 = class(TForm) 
    btnStartOTLTask: TButton; 
    OTLMonitor: TOmniEventMonitor; 
    procedure btnStartOTLTaskClick(Sender: TObject); 
    procedure OTLMonitorTaskMessage(const task: IOmniTaskControl; const msg: 
     TOmniMessage); 
    private 
    { Private-Deklarationen } 
    FTestTask: IOmniTaskControl; 
    public 
    { Public-Deklarationen } 
    end; 

var 
    Form1: TForm1; 

implementation 

{$R *.dfm} 

{ Place a TOmniEventMonitor component on the form, 
    name it OTLMonitor 
    and implement the OnTaskMessage event-handler: OTLMonitorTaskMessage } 

procedure TestParameters(const ATask: IOmniTask); 
var 
    test: Integer; 
begin 
    ATask.Comm.Send(16); // does execute 
    test := ATask.Param['From']; // ?? <<<=========================== 
    ATask.Comm.Send(17); // does NOT execute! 
end; 

procedure TForm1.btnStartOTLTaskClick(Sender: TObject); 
begin 
    if not Assigned(FTestTask) then // prevent multiple tasks 
    FTestTask := CreateTask(TestParameters, 'TestParameters') 
        .MonitorWith(OTLMonitor) 
        .SetParameters(['From', 0, 'To', 99]) 
        .Run 
    else 
    MessageDlg('Task is already running!', mtInformation, [mbOK], 0); 
end; 

procedure TForm1.OTLMonitorTaskMessage(const task: IOmniTaskControl; const msg: TOmniMessage); 
begin 
    Self.Caption := IntToStr(msg.MsgID); 
end; 

那么访问参数'From'有什么问题?

+1

而不是只需设置标题在OnTaskMessage事件处理程序,消息放入备忘录或类似的调试。调试时,在TestParameters中放置一个断点并遍历所有行。在没有调用FTestTask.Terminate和FTestTask的情况下测试分配的(FTestTask):= nil看起来很奇怪。 – 2014-09-22 21:02:00

+0

@LURD我已经按照你所说的完成了,并且通过了TestParameters:在参数访问行中,我得到了一个'TOmniValueContainer.Getltem:Parameter From does not exist'异常。所以很显然,'SetParameters'有问题,顺便说一句,它遵循OmniThread文档中的解释。 – user1580348 2014-09-22 21:45:28

+0

它似乎只能以这种方式工作:'test:= ATask.Param.ByName('From');'而不是'SetParameters'开放数组使用'.SetParameter('From',1 ).SetParameter('To',99)'等 – user1580348 2014-09-22 21:58:14

回答

2

我已经找到了解决办法:

procedure TestParameters(const ATask: IOmniTask); 
begin 
    // this does work: 
    ATask.Comm.Send(ATask.Param.ByName('From')); 
    ATask.Comm.Send(ATask.Param.ByName('To')); 

    // ALSO this does work: 
    ATask.Comm.Send(ATask.Param['From']); 
    ATask.Comm.Send(ATask.Param['To']); 
end; 

procedure TForm1.btnStartOTLTaskClick(Sender: TObject); 
begin 
    if not Assigned(FTestTask) then // prevent multiple tasks 
    FTestTask := CreateTask(TestParameters, 'TestParameters') 
        .MonitorWith(OTLMonitor) 
        // SetParameters does not work: 
        //.SetParameters(['From', 1, 'To', 99]) 
        // this does work: 
        .SetParameter('From', 1) 
        .SetParameter('To', 99) 
        .Run 
    else 
    MessageDlg('Task is already running!', mtInformation, [mbOK], 0); 
end; 

procedure TForm1.OTLMonitorTaskMessage(const task: IOmniTaskControl; const msg: TOmniMessage); 
begin 
    Memo1.Lines.Add(IntToStr(msg.MsgID)); 
end; 

procedure TForm1.OTLMonitorTaskTerminated(const task: IOmniTaskControl); 
begin 
    FTestTask := nil; 
    Memo1.Lines.Add('Task terminated'); 
end;