我有以下两种多线程代码方法来完成相同的工作。
任务:
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
最佳答案
这是因为您的线程和任务不起作用。
线程数多于处理器数。在使用线程的版本中,您可以为每个任务创建一个线程,尽管处理器被超额订阅,但这并不重要,因为线程正在休眠。
在基于任务的版本中,通常每个处理器有一个线程。因此并非所有任务都可以同时运行。
如果您用 CPU 充分利用的繁忙工作来代替 sleep ,那么您会发现两个版本的性能相似。事实上,我希望基于任务的版本会更好,因为它不会过度订阅处理器。
关于multithreading - TTask 比 TThread 慢,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44448031/