Indy10 文件传输导致 100% CPU 使用率

Question

我设法通过断开连接修复了一些错误，现在每当文件传输时 CPU 使用率变为 100%，我不知道我做错了什么：S.....

const
 MaxBufferSize = 1024;

type
 TClient = class(TObject)
 public
  AContext: TIdContext;
  FileSize: Integer;
  Canceled: Boolean;
  Transfered: Integer;
  procedure ReceiveData;
  procedure Update;
 end;

procedure TForm1.IdTCPServer1Execute(AContext: TIdContext);
var
 Data: string;
 Client: TClient;
 Item: TListItem;
begin
 Data := AContext.Connection.IOHandler.ReadLn;

 //Data := 'SEND|785548' = Command + | + FileSize
 if Copy(Data, 1, 4) = 'SEND' then
 begin
  Delete(Data, 1, 5);
  Client := TClient.Create;
  Client.FileSize := StrToInt(Data);
  Client.AContext := AContext;
  Item := ListView1.Items.Add;
  Item.Caption := AContext.Connection.Socket.Binding.PeerIP;
  Item.Data := Client;
  Client.ReceiveData;
 end;
end;

procedure TClient.ReceiveData;
var
 currRead : Integer;
 FS: TFileStream;
begin
 Canceled := False;
 FS := TFileStream.Create('C:\Test.dat', fmCreate or fmOpenReadWrite);
 FS.Size := 0;
 Transfered := 0;
 try
  while (FS.Position < FileSize) and (Athread.Connection.Connected) and (not Canceled) do
  begin
   Application.ProcessMessages;
   if (FileSize - FS.Position) >= MaxBufferSize then currRead := MaxBufferSize
   else currRead := (FileSize - FS.Position);
   AThread.Connection.IOHandler.ReadStream(FS, CurrRead);
   Transfered := FS.Position;
   Notify.NotifyMethod(Update);
   Application.ProcessMessages;
  end;
 finally
  FS.Free;
  AThread.Connection.IOHandler.InputBuffer.Clear;
  AThread.Connection.Disconnect;
  AThread.RemoveFromList;
  Notify.NotifyMethod(Update);
  Application.ProcessMessages;
 end;
end;

procedure TClient.Update;
begin
 //Code to Display Progress bar and stuff (Simplified for now)
 Form1.Label1.Caption := 'Transfered Data : ' + IntToStr(Transfered);
end;

Answer 1

摆脱 Application.ProcessMessages;它不能在主线程以外的线程下调用

Answer 2

您在接收循环中调用 Application.ProcessMessages，大概是为了防止您的应用程序的其余部分看起来被冻结。 100% 的 CPU 使用率是一个副作用。

您最好使用 IdAntiFreeze 组件（仍然是一种 hack）或将 ReceiveData 功能放在线程中。

更新：

哎呀。乍一看，我以为这是在主线程中运行的客户端传输，但实际上它是在单独的 IdTcpServer 线程中调用的。在这种情况下，APZ28 的建议是正确的；不要在线程中调用 Application.ProcessMessages。

Answer 3

我对 Indy 一无所知（我使用自己的单元，它比 Indy 更轻/更快，用于所有 TCP/IP 客户端/服务器的东西 - 请参阅 http://synopse.info），但我猜你的 IdTCPServer1Execute 方法应该运行一个后台线程，这里不是这样。

所以：

1. 摆脱所有那些 Application.ProcessMessages 等；
2. 使用计时器来同步您的 UI（一秒刷新读取传输的字节数就足够了），而不是 Notify() 或 Synchronize() 方法；
3. 确保您的 IdTCPServer1 组件在单独的线程中运行（应该有一些属性可以做到这一点）；
4. 另一种可能性（非常不可能）是不必像这样调用 ReadStream 方法，也不必以 CPU 友好的方式等待数据；如果是这种情况，Indy 应该提供一些方法来等待待处理的数据，而不会阻塞。
5. 使用分析器（周围有一些免费的 - 例如http://delphitools.info）来猜测您的 CPU 烧毁的位置。
6. 在 IDE 之外运行 - 行为是否相同？

Answer 4

您不断循环，一个简单的技巧是在您的Application.ProcessMessages 之后添加一个Sleep(1)。

但也许您可以重新排序代码以阻塞 ReadStream 函数，并且仅在接收到合理数量的数据或超时时运行。

Answer 5

你和我在Embarcadero forums (cached on CodeNewsFast) 中讨论了这个话题。