delphi 多线程 读取队列中的二进制数据，并写入文件中

可以使用 Delphi 的 TThread 对象来实现多线程读取队列中的二进制数据，并写入文件中。具体步骤如下：

1. 定义一个队列对象，用于存储二进制数据。

var
  Queue: TThreadedQueue<TBytes>;

2. 定义一个继承自 TThread 的子类，用于读取队列中的二进制数据，并写入文件中。

type
  TFileWriterThread = class(TThread)
  private
    FQueue: TThreadedQueue<TBytes>;
    FFileName: string;
  public
    constructor Create(const Queue: TThreadedQueue<TBytes>; const FileName: string);
    procedure Execute; override;
  end;

constructor TFileWriterThread.Create(const Queue: TThreadedQueue<TBytes>; const FileName: string);
begin
  inherited Create(True);
  FQueue := Queue;
  FFileName := FileName;
end;

procedure TFileWriterThread.Execute;
var
  FileStream: TFileStream;
  Data: TBytes;
begin
  try
    // 打开文件流，用于写入数据
    FileStream := TFileStream.Create(FFileName, fmCreate);
    try
      while not Terminated do
      begin
        // 从队列中读取二进制数据
        if FQueue.PopItem(Data) = wrSignaled then
        begin
          // 写入数据到文件中
          FileStream.WriteBuffer(Data[0], Length(Data));
        end;
      end;
    finally
      FileStream.Free;
    end;
  except
    // 异常处理
  end;
end;

3. 创建多个 TFileWriterThread 对象，启动多个线程进行读取队列和写入文件操作。

var
  FileWriterThreads: array of TFileWriterThread;
  ThreadCount: Integer;
  I: Integer;
begin
  // 设置线程数量
  ThreadCount := 4;

  // 创建多个线程对象
  SetLength(FileWriterThreads, ThreadCount);
  for I := 0 to ThreadCount - 1 do
  begin
    FileWriterThreads[I] := TFileWriterThread.Create(Queue, 'output.bin');
    FileWriterThreads[I].Start;
  end;

  // 将二进制数据添加到队列中
  Queue.PushItem(BytesOf('Hello, world!'));

  // 等待所有线程退出
  for I := 0 to ThreadCount - 1 do
  begin
    FileWriterThreads[I].Terminate;
    FileWriterThreads[I].WaitFor;
    FileWriterThreads[I].Free;
  end;
end;

在上面的示例中，我们创建了 4 个 TFileWriterThread 对象，将它们启动后，将一些二进制数据添加到队列中。每个线程会从队列中读取数据，并写入到文件中。最后，我们等待所有线程退出，释放资源。