2

德尔福使用: 2007

大家好,

我有一个ViewStyle设置为vsReport. 当我点击一个按钮时,我会启动大约 50 个线程。每个线程都有一个TListItem组件。每个TListItem都有SubItem一个计时器。它从 250 开始,一直下降到 0。用户可以在 TListView 中看到每个计时器递减。

我写了以下代码:

procedure TThreadWorker.DeleteTickets;
begin
 ListItem.Delete;
end;

procedure TThreadWorker.UpdateTimer;
begin
 ListItem.SubItems[1] := IntToStr(Timer);
end;

procedure TThreadWorker.TimerCounter;
begin
 Timer := 300;
 repeat
  Sleep(1000);
  Dec(Timer);
  Synchronize(UpdateTimer);
 until (Timer = 0);
 Synchronize(DeleteTickets);
end;

而且......它的工作原理!但事情是这样的:所有这些同步似乎都不必要地使 CPU 过载。显然,当我启动更多线程(100、200 或 300)或使用较弱的计算机时,这是一个更大的问题。起初,我不确定是同步。但如果我停用它们,CPU 就不会再过载了。

坦率地说,这不是什么大问题。但是,我觉得递减计时器不应该导致任何形式的 CPU 过载:我的代码可能不正确。我尝试减少调用UpdateTimer频率,虽然它减轻了 CPU 过载,但最终并没有解决它。此外,我希望用户看到计时器每秒更新一次。计时器还需要尽可能精确。

谢谢你。

4

3 回答 3

3

我想你已经把车放在马前面了。让所有线程同步到主线程,每个线程都有自己的计时器和消息队列,这会给系统带来沉重的负担。更重要的是,很多时候您不希望通过运行消息循环来增加线程的负担。

在我看来,更好的方法是在主线程中放置一个计时器。当它滴答作响时,让它从它需要报告的每个线程或任务中检索进度。您需要序列化对该进度的访问,但这并不昂贵。

于 2013-03-17T13:42:13.110 回答
1

我认为线程对 CPU 来说比你想象的要贵。据我记得,CPU 有开销来交换每个线程进出缓存。随着 CPU 换出 50 个不同的线程,我对它的超载并不感到惊讶

一种解决方案可能是扩展 TTimer 组件,然后动态创建其中的 50 个而不是 50 个线程。TTimer 使用 windows api 而不是线程。(下面的代码未经测试,但至少应该给你的想法)

TMyTimer = class(TTimer)
begin
  public
    Timer: integer;
    ListItem: TListItem;
end;
...
procedure ButtonClick(Sender: TObject)
begin
  for i := 0 to 50 do
  begin
     ltimer = TMyTimer.Create;
     ltimer.Timer := 300;
     ltimer.ListItem := TListItem.Create;
     //initialize list item here
     ltimer.OnTimer := DecTimer;
  end;
end;

procedure DecTimer(Sender: TObject)
begin
  dec(TMytimer(Sender).Timer);
  TMyTimer(Sender).ListItem.SubItem[1] := StrToInt(TMytimer(Sender).Timer)
end;

如果所有线程都同时启动,请尝试使用一个线程控制最多 25 个计时器。即对于 50 个计时器,您只有两个线程。然后计时器事件将循环遍历它的 25 个计数器并递减它们。您仍然需要为此使用同步。

这个问题的答案可能很有趣: 线程有多贵?

于 2013-03-17T05:05:33.187 回答
1

这是使用TThread.Queueand aTSimpleEvent代替 a 来计时计数器的示例Sleep()

Type
  TThreadWorker = Class(TThread)
  private
    FTimer : Integer;
    FListItem : TListItem;
    procedure Execute; override;
    procedure UpdateTimer;
    procedure DeleteTicket;
  public
    constructor Create( aListItem : TListItem);
  End;

constructor TThreadWorker.Create(aListItem : TListItem);
begin
  Inherited Create(false);
  FListItem := aListItem;
  Self.FreeOnTerminate := true;
end;

procedure TThreadWorker.Execute;
var
  anEvent : TSimpleEvent;
begin
  anEvent := TSimpleEvent.Create(nil,true,false,'');
  try
    FTimer := 300;
    repeat
      anEvent.WaitFor(1000);
      Queue(UpdateTimer);
      Dec(FTimer);
    until (FTimer = 0);
    Self.Synchronize( DeleteTicket); // <-- Do not Queue this !
  finally
    anEvent.Free;
  end;
end;

procedure TThreadWorker.UpdateTimer;
begin
  FListItem.SubItems[1] := IntToStr(FTimer);
end;

procedure TThreadWorker.DeleteTicket;
begin
  FListItem.Delete;
end;

请注意,DeleteTicket必须同步。执行完成后线程终止,队列中的任何内容都将悬空。

于 2013-03-17T13:20:10.597 回答