• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

delphi线程TTask

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

http://docwiki.embarcadero.com/Libraries/Seattle/en/System.Threading.TTask

http://docwiki.embarcadero.com/Libraries/Seattle/en/System.Threading.TTaskStatus

The Parallel Programming Library (PPL) provides a TTask class to run one task or multiple tasks in parallel. A Task is a unit of work you need to get done. The PPL does the association between the task and the thread that performs the task so you can run several tasks in parallel without having to create your own custom threads and managing them.

TTask creates and manages interaction with instances of ITask. ITask is an interface that provides a range of methods and properties to Start, Wait, Cancel and also a property for Status (Created, WaitingToRun, Running, Completed, WaitingForChildren, Canceled, Exception).

TTask provides WaitForAll and WaitForAny to wait for the completion of all or any tasks. WaitForAll returns when all of the tasks are completed, whereas WaitForAny tells you the first one that is completed. For example, if you have two tasks A and B which take 3 and 5 seconds respectively, the time for you to get a result is:

The following example uses the WaitForAll method:

Delphi:

procedure TFormThreading.MyButtonClick(Sender: TObject);
var 
 tasks: array of ITask; 
 value: Integer; 
begin 
 Setlength (tasks ,2); 
 value := 0; 
 
 tasks[0] := TTask.Create (procedure () 
   begin 
   sleep (3000); // 3 seconds 
   TInterlocked.Add (value, 3000); 
  end); 
 tasks[0].Start; 
 
 tasks[1] := TTask.Create (procedure () 
   begin 
   sleep (5000); // 5 seconds 
   TInterlocked.Add (value, 5000);
 end); 
 tasks[1].Start; 
 
 TTask.WaitForAll(tasks); 
 ShowMessage ('All done: ' + value.ToString); 
end;

C++:

void __fastcall TFormThreading::MyButtonClick(TObject *Sender)
{
   _di_ITask tasks[2];
 
   tasks[0] = TTask::Create(_di_TProc(new TCppTask(lvalue, 3000, Label1)));
   tasks[0]->Start());
 
   tasks[1] = TTask::Create(_di_TProc(new TCppTask(lvalue, 5000, Label1)));
   tasks[1]->Start());
 
   TTask::WaitForAll(tasks,(sizeof(tasks)/sizeof(tasks[0])-1));
   ShowMessage("All done! "+IntToStr(lvalue));
}

Another functionality of TTask is to prevent the user interface locking up if you want to start something in the background. The following code example shows how to run a single task and start it:

Delphi:

 
procedure TFormThreading.Button1Click(Sender: TObject);
var
 aTask: ITask;
begin
 aTask := TTask.Create (procedure ()
   begin
     sleep (3000); // 3 seconds
     ShowMessage ('Hello');
   end);
 aTask.Start;
end;

C++:

void __fastcall TFormThreading::Button1Click(TObject *Sender)
{
  Label1->Caption = "--";
  lvalue = 0;
  _di_ITask aTask = TTask::Create(_di_TProc(new TCppTask(lvalue,3000,Label1)));
  aTask-> Start();
  Label1->Caption =InToStr(lvalue);
}

aITask.Status
GetStatus


 

   TTaskStatus = (Created, WaitingToRun, Running, Completed, WaitingForChildren, Canceled, Exception);

listTask: TList<ITask>;

for
i := listTask.Count - 1 downto 0 do begin if (listTask.Items[i].Status = TTaskStatus.Completed) then begin listTask.Delete(i); end; end; listTask.Add(TTask.Create(self.mythread)); listTask.Items[listTask.Count - 1].Start;

 

  for i := listTask.Count - 1 downto 0 do
  begin
    if listTask.Items[i].Status in [TTaskStatus.Running, TTaskStatus.Created, TTaskStatus.WaitingToRun] then
    begin
      while not(listTask.Items[i].Status in [TTaskStatus.Completed, TTaskStatus.Canceled, TTaskStatus.Exception]) do
      begin
        Sleep(500);
        Application.ProcessMessages;
      end;
    end;
  end;
  Label1.Text:='disConnect OK!!'

 

  for i := listTask.Count - 1 downto 0 do
  begin
     listTask.Items[i].wait(5000);

  end;

鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
DelphiTListView刷新闪烁问题发布时间:2022-07-18
下一篇:
最简单的多重窗体的应用(Delphi)发布时间:2022-07-18
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap