TLockFreeQueue = class
    private
      FHead: Int64;
      FTail: Int64;
      FSize: int64;
      FItems: array of TPacket;
    public
      function PushObject(AData: TidBytes; ASize: integer): boolean;
      function PopObject(): TPacket;
      constructor Create(const ASize: integer);
      destructor Destroy(); override;
    end;

constructor TLockFreeQueue.Create(const ASize: integer);
var
  i: integer;
begin
  FHead:= 0; //заполняет писатель
  FTail:= 0; //заполняет читатель
  FSize:= ASize;
  SetLength(FItems, ASize);
  for i := Low(FItems) to High(FItems) do
  FItems[i]:= TPacket.Create(UDP_PACKET_SIZE);
end;

destructor TLockFreeQueue.Destroy;
var
  i: integer;
begin
  try
    for i := Low(FItems) to High(FItems) do
    FItems[i].Free;
    FItems:= nil;
  finally
    inherited;
  end;
end;

function TLockFreeQueue.PushObject(AData: TidBytes; ASize: integer): boolean;
var
  Next: integer;
begin

  Next:= TInterlocked.Read(FHead)+1;

  if Next >= FSize then Next:= 0;

  if Next = TInterlocked.Read(FTail) then
  begin
    Result:= False;
    Exit;
  end;

  CopyTIdBytes(AData, 0, FItems[FHead].PackUDP, 0, ASize);
  FItems[FHead].Size:= ASize;

  TInterlocked.Exchange(FHead, Next);
  Result:= True;
end;

function TLockFreeQueue.PopObject(): TPacket;
var
  Next: integer;
begin

  if (TInterlocked.Read(FHead) = TInterlocked.Read(FTail)) then begin
    Result := nil;
    Exit;
  end;

  Next:= TInterlocked.Read(FTail)+1;

  if Next >= FSize then
  Next:= 0;

  Result:= FItems[FTail];
  TInterlocked.Exchange(FTail, Next);
end;