TThread.Queue和TThread.Synchronize的區別


TThread.Queue和TThread.Synchronize的區別

效果上:二者的作用都是讓業務代碼在主線程中執行,差別: Synchronize是阻塞,Queue是非阻塞

代碼上 兩個方法最終都是調用的 class procedure TThread.Synchronize(ASyncRec: PSynchronizeRecord; QueueEvent: Boolean = False)類方法,
差別
Synchronize則是使用了Thread對象中的FSynchronize對象變量,然后QueueEvent為False來調用TThread.Synchronize類方法, 
內部在執行FSynchronize時,創建了事件對象,通過WaitForSingleObject來阻塞執行。 
Queue調用是自己創建了一個PSynchronizeRecord, 然后QueueEvent為True來調用TThread.Synchronize類方法,內部則把PSynchronizeRecord放入SyncList列表中,然后退回,並不直接執行PSynchronizeRecord, 那問題來了,在那里執行呢?Delphi在TApplication.Idle方法中執行(最終調用了CheckSynchronize)
procedure TForm1.OnReceived(Sender: TObject; AConnection: ICrossConnection; ABuf: Pointer; ALen: Integer);
begin
  TThread.Queue(nil,
    procedure
    begin
      var ms: tstream := TMemoryStream.Create;
      ms.Size := ALen;
      ms.Write(ABuf^, ALen);
      ms.Position := 0;
      var ms2: tstream := TMemoryStream.Create;
      tzip.UnZipStream(ms, ms2);    //unzip
      ms.Free;
      ms2.Position := 0;
      var pack: tmsgpack := TMsgPack.Create;
      pack.DecodeFromStream(ms2);
      case pack.Force('cmd').AsInteger of
        cmd_query:
          begin
            form1.ClientDataSet1.Data := pack.Force('dataset1').AsVariant;
            form1.ClientDataSet2.Data := pack.Force('dataset2').AsVariant;
          end;
      end;
      pack.Free;
    end);
end;

  


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM