multithreading - TTask比TThread慢

我下面有两种执行相同工作的多线程代码方法。

T任务:

const
  MaxThreadCount = 80;

procedure TWorkerTask.Update;
var
  aTasks  : array of ITask;
  I: Integer;
begin
  Stopwatch := TStopwatch.StartNew;
  SetLength(aTasks, MaxThreadCount);
  for I := Low(aTasks) to High(aTasks) do begin
    aTasks[I] := TTask.Create( procedure
    begin
      Writeln('Thread ', TTask.CurrentTask.Id, ' Stared');
      Sleep(5000);
      Writeln('Thread ', TTask.CurrentTask.Id, ' Finshed');
    end);
    aTasks[I].Start;
  end;
  TTask.WaitForAll(aTasks);
  Elapsed := Stopwatch.Elapsed;
  Writeln('Done in ', Round(Elapsed.TotalSeconds));
end;

输出例如Done in 29
T线程:

const
  MaxThreadCount = 80;

procedure TWorker.Execute;
begin
  Writeln('Thread ', ThreadID, ' Stared');
  Sleep(5000);
  Writeln('Thread ', ThreadID, ' Finshed');
end;

....

var
  Workers   : array of TWorker;
  I         : Integer;
  Stopwatch : TStopwatch;
  Elapsed   : TTimeSpan;
begin
  SetLength(Workers, MaxThreadCount);
  for I := Low(Workers) to High(Workers) do begin
    Workers[I] := TWorker.Create;
    Workers[I].Start;
  end;
  for I := Low(Workers) to High(Workers) do
    Workers[I].WaitFor;
  Elapsed := Stopwatch.Elapsed;
  Writeln('Done ', Round(Elapsed.TotalSeconds));

输出例如Done 8
问:在上述方法中，为什么TTask比TThread类极其慢？有没有一种方法可以加快速度以获得相似的结果？

最佳答案

这是因为您的线程和任务无效。

您拥有的线程多于处理器。在使用线程的版本中，您可以为每个任务创建一个线程，尽管处理器被超额订购，但这没关系，因为线程正在休眠。

在基于任务的版本中，每个处理器通常只有一个线程。因此，并非所有任务都可以同时运行。

如果您用忙碌的工作来充分利用CPU来代替 sleep ，那么您会看到两个版本的执行情况相似。实际上，我希望基于任务的版本会更好，因为它不会超额预定处理器。