在 TThread.Execute 中调用 TDataModule 方法

Question

一般来说，在 TThread.Execute 过程中是否可能 调用 TDataModule 方法，其中不涉及视觉活动？

谢谢大家，马西莫。

Answer 1

最简单的方法是使用 TThread.Synchronize 调用数据模块中的方法。

但是，如果您不希望这样做，即使不涉及任何视觉活动，您也应该确定是否需要添加 关键部分来保护您。

对任何标准或第三方 VCL 组件的任何访问，无论是可视的（TButton）还是非可视的（数据集）都应被视为不安全。对本地数据对象（如私有字段或全局变量）的任何访问也必须受到临界区的保护。

这是从后台线程到数据模块的直接调用：

    if Assigned(MyDataModule) then MyDataModule.DoSomething(a,b,c);

这是数据模块中的代码，我向您展示了一段示例代码，以确保我们是现在唯一接触 FList 的线程

/// DoSomething: Note this method must be thread-safe!
procedure TMyDataModule.DoSomething(a:TMyObject1;b:TMyObject2;c:TMyObject3);
begin
   FCriticalSection.Enter;
   try
     if not FList.Contains(a) then
       FList.Add(a); 
     ...
   finally
   FCriticalSection.Leave;
   end;
end;

/// elsewhere in the same data module, wherever anybody modifies or checks the state 
/// (content) of FList, wrap the method with a critical section like this:
function TMyDataModule.HasItem(a:TMyObject1):Boolean;
begin
   FCriticalSection.Enter;
   try
     result := FList.Contains(a); 
   finally
     FCriticalSection.Leave;
   end;
end;

： Delphi 多线程编程，简而言之就是：

• 不要做任何可能创建竞争条件的事情。
• 每当您访问类（数据模块）或任何全局变量中的任何数据字段时，不要忘记使用关键部分、互斥锁等同步原语来防止并发问题（包括竞争条件）。如果使用不当，就会在问题列表中添加死锁。所以这不是一个搞乱的好地方。
• 如果您必须以任何方式访问 VCL 组件或对象，请通过 PostMessage、TThread.Synchronize 或其他一些线程安全的等效方式来间接执行此操作，以向主线程发出您需要完成某些操作的信号。
  • 想想当你关机时会发生什么。也许您可以在调用其方法之前检查您的数据模块是否存在，因为它可能已经消失。

Answer 2

简短回答：是

详细回答：Windows 的问题是所有 GUI 活动都应该在单个线程中完成。 （嗯，上面的陈述可以扩展、修改、增强等，但对于我们的讨论来说就足够了）。因此，如果您确定 TDataModule 方法中不涉及任何“GUI 事物”（请注意，这甚至可能是 ShowMessage 调用），那么请继续。

更新：当然，有一些技术可以从辅助线程更新 GUI，但这意味着某种准备（消息传递、同步等）。这不是很难，只是你不能“盲目地”从另一个线程调用改变 GUI 的方法。

Answer 3

当被问及任何问题时，要使用我们行业最喜欢的答案：这取决于。

如果您的数据模块上有一个完全独立的方法（即可以是静态方法），那么您应该不会有任何问题。

示例

TMyDataModule = class(TDataModule)
public
  function AddOne(const Value: Integer): Integer;
end;

function TMyDataModule.AddOne(const Value: Integer): Integer;
begin
  Result := Value + 1;
end;

---

另一方面，如果该方法使用任何全局状态，则从多个线程调用它时可能会遇到麻烦。

示例

TMyDataModule = class(TDataModule)
private
  FNumber: Integer
public
  function AddOne(const Value: Integer): Integer;
end;

function TMyDataModule.AddOne(const Value: Integer): Integer;
begin
  FNumber := Value
  //***** A context switch here will mess up the result of (at least) one thread.
  Result := FNumber + 1;
end;

全局状态应该被解释得非常广泛。 TQuery、TTable、刷新 GUI、使用任何全局变量……都是全局状态，并且不是线程安全的。

Answer 4

是的，我的问题很模糊。

我的程序是一个图形统计应用程序，它必须通过TChart显示甘特图，描述一台或多台机床的状态、警报或加工订单。
在主管 PC 上的服务器（配备 TIdTcpServer 和一些 DB 组件）
正在局域网上监听我的应用程序。

主窗体客户端允许最终用户选择日期范围（期间）和
查询服务器的单位（机器）。之后，用户按下一个按钮（有
3 功能）：创建一个新表单（和数据模块）来显示结果。

收集数据的工作由线程完成，因为：

1）它可能是一项很长的工作，因此可能会冻结 GUI；

2) 用户可以启动多个表单来查看各种结果。

我有一个基本的数据模块（带有一个带有多个收集数据功能的 TIdTcpClient），
一个基本形式（从未实例化，具有许多所有数据形式所共有的特征，以及工作线程的定义）。

unit dtmPDoxClientU;

  TdtmPDoxClient = class(TDataModule)
    IdTCPClient: TIdTCPClient;
    ...
    function GetData(...): boolean; 
    ...
  end;

---

unit frmChartBaseFormU;

  TfrmChartBaseForm = class(TForm)
    ...
    TheThread: TThreadClient;
    procedure WMThreadComm(var Message: TMessage); message WM_THREADCOMM;
    procedure ListenThreadEvents(var Message: TMessage); virtual;
    procedure ExecuteInThread(AThread: TThreadClient); virtual;
  end;

  TThreadClient = class(TThread)
  private
  public
    Task: integer;
    Module: TfrmChartBaseForm;
    procedure Execute; override;
    property Terminated;
  end;

procedure TfrmChartBaseForm.FormCreate(Sender: TObject);
  ...
  TheThread := TThreadClient.Create(true);
  with TheThread do begin
    Module := self;
    FreeOnTerminate := true;
  end;//with
end;//FormCreate

procedure TfrmChartBaseForm.WMThreadComm(var Message: TMessage);
begin
  ListenThreadEvents(Message);
end;//WMThreadComm

procedure TfrmChartBaseForm.ListenThreadEvents(var Message: TMessage);
begin
// do override in derived classes
end;//ListenThreadEvents

procedure TfrmChartBaseForm.ExecuteInThread(AThread: TThreadClient);
begin
// do override in derived classes
end;//ExecuteInThread

procedure TThreadClient.Execute;
begin
  with Module do begin
    ExecuteInThread(self);
  end;//with
end;//Execute

此外，使用 VFI，我还有两个单元：

unit dtmPDoxClientDataOIU;

  TdtmPDoxClientDataOI = class(TdtmPDoxClient)
    cdsClient_IS: TClientDataSet;
    ...
    dsr_I: TDataSource;
    ...
  private
  public
  end;

---

unit frmPDoxClientDataOIU;

  TfrmPDoxClientDataOI = class(TfrmChartBaseForm)
    ChartOI: TChart;
    ...
    procedure FormCreate(Sender: TObject);
  public
    { Public declarations }
    dtmPDoxClientDataOI: TdtmPDoxClientDataOI;
    procedure ListenThreadEvents(var Message: TMessage); override;
    procedure ExecuteInThread(AThread: TThreadClient); override;
  end;

procedure TfrmPDoxClientDataOI.FormCreate(Sender: TObject);
begin
  inherited;
  dtmPDoxClientDataOI := TdtmPDoxClientDataOI.Create(self);
  TheThread.Task := 1;
  TheThread.Resume;
end;//FormCreate

procedure TfrmPDoxClientDataOI.ListenThreadEvents(var Message: TMessage);
begin
  if (Message.WParam = 1) then begin
    case Message.LParam of
      //GUI tasks, using ClientDataset already compiled and not re-used
    end;//case
  end;//if
end;//ListenThreadEvents

procedure TfrmPDoxClientDataOI.ExecuteInThread(AThread: TThreadClient);
begin
  while not AThread.Terminated and (AThread.Task <> 0) do begin
    case AThread.Task of
      1: begin
        if dtmPDoxClientDataOI.GetData(...) then
          if not AThread.Terminated then begin
            PostMessage(Handle,WM_THREADCOMM,1,1);
            AThread.Task := 2;
          end //if
          else
            AThread.Task := 0;
      end;//1
      ... etc...
    end;//case
  end;//while
end;//ExecuteInThread

因此，当最终用户按下按钮时，一个新表单及其自己的数据模块和
线程被创建；线程通过 ExecuteInThread 使用自己的数据模块
功能。数据准备好后，将向表单发送一条 PostMessage，该表单会更新
图表。

Answer 5

正如利文所写，这取决于情况。

如果数据模块上有数据库组件，则必须知道它们是否是线程安全的，或者使它们成为线程安全的。
某些数据库组件需要每个线程有一个单独的会话对象。

Answer 6

在线程中使用数据模块时存在问题：
如果您在窗体的 OnDestroy 事件中终止线程并等待它 (WaitFor) - 您将遇到死锁。
主 UI 线程设置锁定

procedure TCustomForm.BeforeDestruction;
begin
  GlobalNameSpace.BeginWrite;

，您的线程将在其数据模块析构函数中无限等待，因此

destructor TDataModule.Destroy;
begin
  if not (csDestroying in ComponentState) then GlobalNameSpace.BeginWrite;

，如果您想在关闭 MainForm 时等待线程，请在 OnClose 事件或项目的主文件中执行操作，

或者您可以在 Synchronize 中销毁它