デキューをプロシージャパラメータとして使用すると、TQueueが空になることはありません。

Question

interface 

type 

TMulticastListenerThread = class(TThread) 
strict private 
    ..... 
    _queue: TQueue<string>; 
    FOnReceive: TGetStrProc; 
    procedure DoReceive(); 
    ..... 
public 
    ..... 
    procedure Execute(); override; 
    property OnReceive:TGetStrProc read FOnReceive write FOnReceive; 
    ..... 
end; 

implementation 

procedure TMulticastListenerThread.Execute(); 
var addrlen: Integer; 
    nbytes: Integer; 
    msgbuf: array[1..MSGBUFSIZE] of AnsiChar; 
    msgstr: AnsiString; 
begin 
    inherited; 
    // now just enter a read-print loop 
    while not Terminated do begin 
    try 
     if not _connected then begin 
     Sleep(100); 
     continue; 
     end; 
     addrlen := sizeof(addr); 
     nbytes := recvfrom(fd, msgbuf, MSGBUFSIZE, 0, addr, addrlen); 
     if (nbytes < 0) then begin 
     perror('recvfrom'); 
     end 
     else begin 
     SetLength(msgstr, nbytes); 
     Move(msgbuf, PAnsiChar(msgstr)^, nbytes); 
     _queue.Enqueue(msgstr); 
     Synchronize(DoReceive); 
     end; 
    except 
     on ex: Exception do perror(ex.Message); 
    end; 
    end; 
end; 

すべては同期化されたDoReceiveメソッドです。

それは、このようなコードが含まれている場合：私は自分のアプリケーションを終了した後、それが何度も何度もwhileループを通過

procedure TMulticastListenerThread.DoReceive(); 
begin 
    while _queue.Count > 0 do 
    if Assigned(FOnReceive) then FOnReceive(_queue.Dequeue()); 
end; 

を、_queue.Countは "新しい文字列がをエンキューされていないものの、常に1あり、そしてTMulticastListenerThreadデストラクタは決して呼び出されません。

私は変数中間ローカル文字列によってデキュー：

procedure TMulticastListenerThread.DoReceive(); 
var s: string; 
begin 
    while _queue.Count > 0 do begin 
    s := _queue.Dequeue(); 
    if Assigned(FOnReceive) then FOnReceive(s); 
    end; 
end; 

アプリケーションが正常に終了し、デストラクタが呼び出されています。

これを説明できますか？

Answer 1

_queue.Dequeue()は、FOnReceiveイベントハンドラを割り当てた場合にのみ実行されます。

procedure TMulticastListenerThread.DoReceive(); 
begin 
    while _queue.Count > 0 do 
    if Assigned(FOnReceive) then FOnReceive(_queue.Dequeue()); 
end; 

しかし、このコードは、あなたの割り当てチェックする前に、毎回_queue.Dequeue()呼び出します。

procedure TMulticastListenerThread.DoReceive(); 
var s: string; 
begin 
    while _queue.Count > 0 do begin 
    s := _queue.Dequeue(); 
    if Assigned(FOnReceive) then FOnReceive(s); 
    end; 
end;