ChatGPT: delphi 实现生产者消费者队列处理多线程示例

uses
  Classes, SyncObjs;

type
  TItem = class
    Data: Integer;
  end;

  TProducer = class(TThread)
  private
    FQueue: TThreadedQueue<TItem>;
  protected
    procedure Execute; override;
  public
    constructor Create(AQueue: TThreadedQueue<TItem>);
  end;

  TConsumer = class(TThread)
  private
    FQueue: TThreadedQueue<TItem>;
  protected
    procedure Execute; override;
  public
    constructor Create(AQueue: TThreadedQueue<TItem>);
  end;

constructor TProducer.Create(AQueue: TThreadedQueue<TItem>);
begin
  inherited Create(False);
  FQueue := AQueue;
end;

procedure TProducer.Execute;
var
  I: Integer;
  Item: TItem;
begin
  for I := 1 to 100 do
  begin
    Item := TItem.Create;
    Item.Data := I;
    FQueue.Enqueue(Item);
    Sleep(10);
  end;
end;

constructor TConsumer.Create(AQueue: TThreadedQueue<TItem>);
begin
  inherited Create(False);
  FQueue := AQueue;
end;

procedure TConsumer.Execute;
var
  Item: TItem;
begin
  while not Terminated do
  begin
    if FQueue.TryDequeue(Item) then
    begin
      WriteLn(Format('Data: %d', [Item.Data]));
      Item.Free;
      Sleep(20);
    end
    else
      Sleep(10);
  end;
end;

var
  Queue: TThreadedQueue<TItem>;
  Producer: TProducer;
  Consumer: TConsumer;
begin
  Queue := TThreadedQueue<TItem>.Create;
  try
    Producer := TProducer.Create(Queue);
    Consumer := TConsumer.Create(Queue);
    try
      Producer.Start;
      Consumer.Start;
      Producer.WaitFor;
      Consumer.Terminate;
      Consumer.WaitFor;
    finally
      Producer.Free;
      Consumer.Free;
    end;
  finally
    Queue.Free;
  end;
end.

这是一个使用线程安全队列 TThreadedQueue 来实现生产者消费者模型的示例。TProducer 线程生成数据并将其添加到队列中，而 TConsumer 线程从队列中获取数据并处理