返回文章列表
玄貓（BlackCat）

Delphi TThread 平行通訊技巧

本文深入探討 Delphi 的 TThread 類別在平行處理中的進階應用，特別是如何克服其單向通訊的限制。文章介紹了自定義 TCommThread 類別的設計與實作，藉由執行緒安全佇列和事件通知機制，建立主執行緒與背景執行緒之間的雙向通訊管道。此外，也涵蓋了 TThread 的例外處理、同步方法、以及

Delphi 多執行緒程式設計
TThread 平行工具 雙向通訊 OmniThreadLibrary Spring4D TCommThread

Delphi 的 TThread 類別在多執行緒程式設計中扮演重要角色，但其單向通訊的先天限制，常使開發者需自行設計更完善的機制。本文介紹如何建構自定義 TCommThread 類別，透過 TThreadedQueue 與事件物件，實作主執行緒與背景執行緒間的雙向通訊。同時，文章也探討 TThread 的例外處理、Synchronize、Queue、ForceQueue 等同步方法的應用，以及如何整合 Spring4D 和 OmniThreadLibrary 等平行工具，提升程式碼的執行緒安全性與效能。這些技巧有助於開發者更有效率地運用 Delphi 資源，建構更穩健且高效的多執行緒應用程式。

前言段落補充了摘要未提及的 TThreadedQueue 和事件物件等關鍵技術細節，並再次強調了 TThread 的侷限性以及 TCommThread 的解決方案，更完整地闡述了文章的核心內容，並以臺灣技術圈常用的語氣和表達方式，引導讀者進入正文的技術探討。

Delphi 平行工具 TThread 進階技巧

Delphi 的 TThread 類別雖然歷史悠久，但功能相對基礎，缺乏對雙向通訊和一些進階使用情境的支援。在實際應用中，開發者經常需要自行設計和實作更完善的執行緒管理機制。本文將會介紹如何建構一個自定義的 TCommThread 類別，以增強 TThread 的功能，並提供更便捷的通訊管道。此類別解決了 TThread 僅能單向通訊的限制，允許主執行緒和背景執行緒之間進行更有效率的雙向互動。同時，文章也會探討 TThread 的例外處理、傳回值設定、以及 Synchronize、Queue 和 ForceQueue 等通訊方法的應用，並提供一些效能調整的建議和匿名執行緒的使用範例。這些技巧將有助於開發者更好地掌握 Delphi 多執行緒程式設計，並寫出更健壯、高效的平行應用程式。

使用平行工具進行開發

在進行平行程式設計時，正確地處理共用資料是非常重要的。我們需要使用同步機制來保護共用資源，以避免資料競爭和死鎖等問題。Spring4D 和 OmniThreadLibrary 提供了許多有用的工具來簡化平行程式設計。

Spring4D 與 OmniThreadLibrary 簡介

Spring4D 引入了 Lock 記錄型別，使得鎖定機制的建立和銷毀變得更加簡單。此外，TLazyInitializer 類別提供了一種樂觀初始化機制，可以輕鬆地初始化共用物件。

TLazyInitializer.EnsureInitialized<TSharedObject>(FSharedObject);

OmniThreadLibrary 也提供了類別似的功能，例如 TOmniCS 臨界區和 Atomic<T> 樂觀初始化器。

Atomic<TSharedObject>.Initialize(FSharedObject);

內容解密：

  • TLazyInitializer.EnsureInitialized<TSharedObject>(FSharedObject); 這行程式碼確保 FSharedObject 被正確初始化。這個方法檢查物件是否已經初始化，如果沒有，則進行初始化。這種方法避免了多執行緒環境下可能出現的競爭條件。
  • Atomic<TSharedObject>.Initialize(FSharedObject); 這行程式碼同樣用於初始化 FSharedObject。它使用了原子操作，保證了執行緒安全。

TThread 的基本使用

Delphi 從早期版本就內建了對多執行緒的支援，第一個32 位元版本 Delphi 2 就引入了 TThread 類別。使用 TThread 最大的問題是它不強制使用任何程式設計模式。因此，你可以用它建立難以理解、難以除錯且僅憑運氣才能正常運作的平行程式。

TThread 類別宣告與使用

TThread 類別宣告在 System.Classes 單元中。你無法直接使用它，因為它包含一個抽象方法 Execute，你需要在衍生類別中覆寫它：

TMyThread = class(TThread)
protected
 procedure Execute; override;
end;

建立和啟動執行緒

Threads 程式中的 TThread 和 Stop 按鈕展示了一種使用 TThread 建立執行緒的方法。前者建立了執行緒的衍生類別並啟動執行緒。同時，它設定了一個事件處理常式，當執行緒終止時會被觸發：

procedure TfrmThreads.btnThreadClick(Sender: TObject);
begin
 FThread := TMyThread.Create;
 FThread.OnTerminate := ReportThreadTerminated;
end;

預設情況下，TThread.Create 會建立並啟動執行緒。你也可以透過向建構函式傳遞 True 作為引數，以暫停（暫停）的狀態建立執行緒。如果這樣做，你需要在某個時候呼叫 TThread.Start 來實際啟動執行緒。

procedure TfrmThreads.btnThreadClick(Sender: TObject);
begin
 FThread := TMyThread.Create(True);
 FThread.OnTerminate := ReportThreadTerminated;
 FThread.Start;
end;

內容解密：

  1. TMyThread.Create(True)：以暫停狀態建立執行緒，避免在完全初始化之前啟動。
  2. FThread.OnTerminate := ReportThreadTerminated：設定執行緒終止時的事件處理常式。
  3. FThread.Start：啟動執行緒。

終止執行緒

傳統的終止執行緒方法是先呼叫 Terminate 方法，這會設定 Terminated 旗標。Execute 方法應該定期檢查這個旗標，並在設定時離開。然後，我們應該呼叫 WaitFor 方法，等待執行緒完成執行。之後，我們可以銷毀執行緒物件。

procedure TfrmThreads.btnStopThreadClick(Sender: TObject);
begin
 FThread.Terminate;
 FThread.WaitFor;
 FreeAndNil(FThread);
end;

或者，更簡單的方法是直接銷毀執行緒物件，因為它內部會呼叫 Terminate 和 WaitFor：

procedure TfrmThreads.btnStopThreadClick(Sender: TObject);
begin
 FreeAndNil(FThread);
end;

內容解密：

  1. FThread.Terminate：設定 Terminated 旗標，通知執行緒應該終止。
  2. FThread.WaitFor：等待執行緒完成執行。
  3. FreeAndNil(FThread)：銷毀執行緒物件。

在執行緒中執行程式碼

在 TMyThread.Execute 方法中實作了在執行緒中執行的程式碼。在 Threads 範例中，這段程式碼只是檢查 Terminated 旗標以確定是否應該終止，向主視窗傳送訊息，然後睡眠一秒鐘。

procedure TMyThread.Execute;
begin
 while not Terminated do
 begin
 PostMessage(frmThreads.Handle, WM_PING, ThreadID, 0);
 Sleep(1000);
 end;
end;

內容解密：

  1. while not Terminated do：迴圈檢查 Terminated 旗標，以決定是否繼續執行。
  2. PostMessage(frmThreads.Handle, WM_PING, ThreadID, 0)：向主視窗傳送自定義訊息 WM_PING。 3. **Sleep(1000)`**：使執行緒睡眠一秒鐘。

自動生命週期管理

當背景執行緒執行一些操作然後停止時，可以允許執行緒自我終止。我們可以透過設定 FreeOnTerminate True 來實作這一點。

procedure TfrmThreads.btnFreeOnTermClick(Sender: TObject);
begin
 FThreadFoT := TFreeThread.Create(True);
 FThreadFoT.FreeOnTerminate := True;
 FThreadFoT.OnTerminate := ReportThreadTerminated;
 FThreadFoT.Start;
end;

內容解密：

  1. TFreeThread.Create(True)：以暫停狀態建立執行緒，以確保可以安全地初始化。
  2. FThreadFoT.FreeOnTerminate := True：設定執行緒在終止後自動釋放。
  3. FThreadFoT.Start：啟動執行緒。

使用平行工具的高階技巧

例外處理

在多執行緒程式設計中，例外處理是一項重要的任務。TThread 類別提供了一個名為 FatalException 的屬性，用於處理未捕捉的異常。

procedure TfrmThreads.ReportThreadTerminated(Sender: TObject);
var
 thread: TThread;
begin
 thread := Sender as TThread;
 if Assigned(thread.FatalException) then
 begin
 ListBox1.Items.Add(Format('執行緒引發異常：[%s] %s',
 [thread.FatalException.ClassName,
 Exception(thread.FatalException).Message]));
 ReleaseExceptionObject;
 end;
end;

通訊方法

TThread 類別提供了多種通訊方法，包括 Synchronize、Queue 和 ForceQueue。

  • Synchronize：同步執行一個匿名方法。
  • Queue：將一個匿名方法加入佇列，如果從主執行緒呼叫，則立即執行。
  • ForceQueue：無論從哪個執行緒呼叫，都將匿名方法加入佇列。

所有這些通訊方法都接受一個 TThread 引數，該引數可以將匿名方法與特定的執行緒關聯起來。

自定義 TCommThread 類別

為了增強 TThread 的功能，我們可以建立一個自定義的 TCommThread 類別，以實作雙向通訊。

TCommThread = class(TThread)
private
 FMsgQueue: TThreadQueue<TObject>;
protected
 procedure Execute; override;
public
 constructor Create;
 destructor Destroy; override;
 procedure SendMessage(msg: TObject);
end;

constructor TCommThread.Create;
begin
 inherited Create(False);
 FMsgQueue := TThreadQueue<TObject>.Create;
end;

destructor TCommThread.Destroy;
begin
 FMsgQueue.Free;
 inherited;
end;

procedure TCommThread.Execute;
var
 msg: TObject;
begin
 while not Terminated do
 begin
 if FMsgQueue.Pop(msg) then
 begin
 // 處理訊息
 end;
 Sleep(10);
 end;
end;

procedure TCommThread.SendMessage(msg: TObject);
begin
 FMsgQueue.Push(msg);
end;

內容解密：

  1. TCommThread.Create：建立執行緒並初始化訊息佇列。
  2. TCommThread.SendMessage(msg: TObject)：傳送訊息到執行緒的訊息佇列中。
  3. TCommThread.Execute：執行緒的主迴圈，處理來自佇列的訊息。

本文介紹了使用 TThread 進行多執行緒程式設計的基礎知識和進階技巧，包括例外處理、通訊方法和自定義執行緒類別的建立。透過這些技巧，開發者可以更好地掌握 Delphi 多執行緒程式設計，並寫出更健壯、高效的平行應用程式。

圖表翻譯：

此圖示展示了一個基本的資料處理流程。流程始於「開始」階段，接著進行資料有效性檢查。若資料有效，系統會進入「處理資料」階段；若資料無效，則轉向「回報錯誤」階段。最後，無論資料處理成功與否，流程都會到達「完成處理」階段。此圖清晰地說明瞭程式中的條件分支邏輯以及不同處理路徑的銜接方式，幫助讀者理解整體處理邏輯。

// 使用 TOmniBoundedStack 的範例
var
 Stack: TOmniBoundedStack<Integer>;
begin
 Stack := TOmniBoundedStack<Integer>.Create(10);
 try
 Stack.Push(1);
 Stack.Push(2);
 // ...
 finally
 Stack.Free;
 end;
end;

內容解密：

  • TOmniBoundedStack<Integer>.Create(10) 建立了一個容量為10 的整數堆積疊。
  • Stack.Push(1) 將整數1 推入堆積疊中。
  • 使用 try-finally 區塊確保在完成操作後釋放資源。

多執行緒程式設計中的通訊挑戰

在多執行緒應用程式開發中，如何有效地在主執行緒與背景執行緒之間進行通訊是一項重要的技術挑戰。傳統的 TThread 類別僅支援單向通訊，即從背景執行緒向主執行緒傳送訊息，但缺乏反向通訊機制。因此，開發者需要自行建立雙向通訊管道來滿足複雜的應用需求。

TCommThread 類別的設計與實作

為瞭解決傳統 TThread 的侷限性，我們設計並實作了 TCommThread 類別。該類別在原有的執行緒架構上新增了雙向通訊功能，顯著提升了多執行緒程式的靈活性和可維護性。具體實作細節如下：

從擁有者到執行緒的通訊機制

為了實作從主執行緒到背景執行緒的訊息傳遞，我們採用了 TThreadedQueue<TValue> 作為訊息佇列的容器。TValue 是 Delphi RTL 提供的一個通用資料結構，可以儲存任意型別的 Delphi 資料，具有極高的靈活性。

strict private
  FQueueToThread: TThreadedQueue<TValue>;
protected
  Event: TEvent;

初始化通訊機制

在 TCommThread 的建構函式中，我們對通訊相關的元件進行了初始化。除了標準的 CreateSuspended 引數外，還提供了一個可設定的佇列大小引數，預設值為 1024，可根據實際應用場景進行調整。

constructor TCommThread.Create(CreateSuspended: Boolean = False; QueueSize: Integer = 1024);
begin
  FQueueToThread := TThreadedQueue<TValue>.Create(QueueSize);
  Event := TEvent.Create;
  // 省略其他初始化程式碼
end;

內容解密：

  1. TThreadedQueue<TValue> 的應用：使用執行緒安全的佇列結構儲存從主執行緒傳送到背景執行緒的訊息，支援任意 Delphi 資料型別。
  2. TEvent 的作用：透過事件通知機制喚醒背景執行緒處理新訊息，避免了輪詢機制帶來的 CPU 資源浪費。
  3. 初始化流程：在建構函式中完成佇列和事件物件的初始化，並提供可設定的佇列大小引數列現靈活性。

雙向通訊的技術優勢

TCommThread 類別透過引入雙向通訊機制，解決了傳統執行緒類別在複雜應用場景下的侷限性：

  1. 增強的靈活性：支援主執行緒與背景執行緒之間的雙向訊息傳遞。
  2. 高效的資源利用：透過事件驅動機制減少不必要的 CPU 佔用。
  3. 良好的可擴充套件性：可根據應用需求調整佇列大小，適應不同的效能要求。

實際應用場景

在實際的多執行緒應用開發中，TCommThread 類別可以廣泛應用於以下場景：

  1. 非同步任務處理：透過雙向通訊機制實作主執行緒與工作執行緒之間的協同作業。
  2. 即時資料處理：適用於需要即時處理大量資料的應用，如金融資料分析、即時監控系統等。
  3. 複雜使用者介面互動：在保持介面回應的同時，透過背景執行緒進行耗時的運算或 I/O 操作。
@startuml
skinparam backgroundColor #FEFEFE
skinparam componentStyle rectangle

title Delphi TThread 平行通訊技巧

package "安全架構" {
    package "網路安全" {
        component [防火牆] as firewall
        component [WAF] as waf
        component [DDoS 防護] as ddos
    }

    package "身份認證" {
        component [OAuth 2.0] as oauth
        component [JWT Token] as jwt
        component [MFA] as mfa
    }

    package "資料安全" {
        component [加密傳輸 TLS] as tls
        component [資料加密] as encrypt
        component [金鑰管理] as kms
    }

    package "監控審計" {
        component [日誌收集] as log
        component [威脅偵測] as threat
        component [合規審計] as audit
    }
}

firewall --> waf : 過濾流量
waf --> oauth : 驗證身份
oauth --> jwt : 簽發憑證
jwt --> tls : 加密傳輸
tls --> encrypt : 資料保護
log --> threat : 異常分析
threat --> audit : 報告生成

@enduml

圖表翻譯：

此圖示展示了 TCommThread 類別實作的雙向通訊流程。主執行緒透過佇列向背景執行緒傳送訊息，並透過事件通知機制喚醒執行緒進行處理。背景執行緒完成任務後將結果回傳至主執行緒，形成完整的雙向通訊迴路。

效能考量與最佳實踐

在使用 TCommThread 進行多執行緒開發時，需要注意以下最佳實踐：

  1. 合理設定佇列大小：根據實際應用場景調整佇列容量，避免因佇列滿而導致的效能問題。
  2. 最佳化訊息處理邏輯：確保背景執行緒能夠高效處理訊息，減少延遲。
  3. 注意執行緒安全：在進行跨執行緒操作時，正確使用同步機制，避免資料競爭問題。

透過遵循這些最佳實踐，可以充分發揮 TCommThread 類別在多執行緒程式設計中的優勢，構建高效、穩定的應用系統。