TTask 比 TThread 慢

Question

我有以下两种多线程代码方法来完成同样的工作。

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 is extremely slower than the TThread class？有没有办法加快速度以获得类似的结果？

Answer 1

这是因为你的线程和任务没有工作。

您的线程数多于处理器数。在使用线程的版本中，您可以为每个任务创建一个线程，尽管处理器超额订阅，但这并不重要，因为线程正在休眠。

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

如果您用忙碌的工作代替睡眠运行在充分利用 CPU 时，您会发现两个版本的性能相似。事实上，我希望基于任务的版本会更好，因为它不会超额订阅处理器。

Answer 2

每个任务并不一定意味着1个线程。 delphi 任务系统节省资源，甚至监控CPU 使用情况以决定是否创建更多线程。特别是我还发现任务很慢，为了避免这种缓慢，当我需要使用任务时，我只是为每个任务创建一个线程池，所以它与简单的 TThread 具有相同的性能，因为这样你将确保每个任务都会运行在自己的线程上。

您可以尝试这样的操作：

TTask.Run(
  procedure()
  begin
  end, TThreadPool.Create);

TTask 比 TThread 慢

TTask slower than TThread

delphi

multithreading

delphi-10.2-tokyo