C++ Builder：为不同线程编组的接口

Question

为了使用线程中的 COM 对象，我将 CoInitialize(NULL) 插入到线程 Execute 函数中，并将 CoUninitialize() 插入到 Terminate 函数中。

一切正常，除非用户通过从调用表单调用 Terminate 函数来中止线程。

一个表单调用的 Terminate 函数似乎被视为另一个线程（错误消息：'应用程序调用了一个为不同线程编组的接口'）。

另一方面，我无法将代码放入特定函数中以使用 Synchronize 进行调用。这样程序就会一直静止，直到被调用函数的COM进程结束。

我知道存在重新寻址 COM 编组的函数。但不知道具体要做什么。我也没有在 C++ 中找到示例。

在寻求帮助之前，我尝试了各种方法来解决这个问题。不幸的是我在这里。

这是我的代码：

class TThreadCamera : public TThread
{
private:
  Variant Camera;

protected:
  void __fastcall Execute();

public:
  void __fastcall Terminate(TObject *Sender);

public:
  __fastcall TThreadCamera();

};

-

__fastcall TThreadCamera::TThreadCamera()
  : TThread(false)
{
}
//---------------------------------------------------------------------------

void __fastcall TThreadCamera::Execute()
{
  FreeOnTerminate = true;
  OnTerminate = &Terminate;
  CoInitialize(NULL);
  Camera = Variant::CreateObject("ASCOM.Simulator.Camera");
  Camera.OlePropertySet("Connected", true);
  Camera.OleProcedure("StartExposure", 60, true);
  while ((! (bool) Camera.OlePropertyGet("ImageReady")))
    Sleep 100;
}
//---------------------------------------------------------------------------

void __fastcall TThreadCamera::Terminate(TObject *Sender)
{
  if (Camera.OlePropertyGet("CameraState") == 2) // Exposure currently in progress
    Camera.OleProcedure("AbortExposure");
  CoUninitialize();
}
//---------------------------------------------------------------------------

Answer 1

您需要在同一个线程上调用CoInitialize 和CoUninitialize，因为它们作用于调用线程。 OnTerminate 事件总是在主线程上执行。

因此，删除您的 OnTerminate 事件处理程序，将该代码移动到线程中，然后从线程中调用 CoUninitialize：

void __fastcall TThreadCamera::Execute()
{
  FreeOnTerminate = true;
  CoInitialize(NULL);

  Camera = Variant::CreateObject("ASCOM.Simulator.Camera");
  // code to operate on the camera goes here

  CoUninitialize();
}

在 finally 块中保护未初始化可能是谨慎的。

Answer 2

在 Delphi 中，如果需要在线程上下文中调用线程终止代码，则应覆盖受保护的 TThread.DoTerminate 方法，而不是编写 OnTerminate 事件处理程序。

Answer 3

TThread.OnTerminate 事件在主 UI 线程的上下文中调用。工作线程在Execute()退出后调用的虚拟TThread.DoSynchronize()方法使用TThread.Synchronize()调用OnTerminate。 DoTerminate() 总是被调用，即使 Execute() 由于未捕获的异常而退出，所以覆盖 DoTerminate() 是执行特定线程清理的好方法。

CoInitialize() 和 CoUninitialize() 必须在同一个线程中调用。因此，您必须在Execute() 内部调用CoUninitialize()，或覆盖DoTerminate()。我更喜欢后者，因为它减少了在Execute() 中使用try/catch 或try/__finally 块的需要（RAII 解决方案，例如utilscls.h 中的TInitOle，甚至更好）。

只能在创建它的线程的上下文中访问单元线程 COM 对象。所以你必须在Execute()中调用相机的CameraStateproperty和AbortExposure()过程，或者覆盖DoTerminate()。

TThread.Terminate() 方法只是将TThread.Terminated 属性设置为 true，它什么也不做。 Execute() 有责任定期检查Terminated 属性并尽快退出。等待相机的 ImageReady 属性为 true 的 while 可以而且应该检查线程的 Terminated 属性，以便它可以在请求时停止等待。

试试这样的：

class TThreadCamera : public TThread
{
private:
  bool init;

protected:
  void __fastcall Execute();
  void __fastcall DoTerminate();

public:
  __fastcall TThreadCamera();
};

__fastcall TThreadCamera::TThreadCamera()
  : TThread(false)
{
  FreeOnTerminate = true;
}

void __fastcall TThreadCamera::Execute()
{
  init = SUCCEEDED(CoInitialize(NULL));
  if (!init) return;
  Variant Camera = Variant::CreateObject("ASCOM.Simulator.Camera");
  Camera.OlePropertySet("Connected", true);
  Camera.OleProcedure("StartExposure", 60, true);
  while (!Terminated)
  {
    if ((bool) Camera.OlePropertyGet("ImageReady"))
      return;
    Sleep(100);
  }
  if (Camera.OlePropertyGet("CameraState") == 2) // Exposure currently in progress
    Camera.OleProcedure("AbortExposure");
}

void __fastcall TThreadCamera::DoTerminate()
{
  if (init) CoUninitialize();
  TThread::DoTerminated();
}

或者：

class TThreadCamera : public TThread
{
protected:
  void __fastcall Execute();

public:
  __fastcall TThreadCamera();
};

#include <utilcls.h>

__fastcall TThreadCamera::TThreadCamera()
  : TThread(false)
{
  FreeOnTerminate = true;
}

void __fastcall TThreadCamera::Execute()
{
  TInitOle oleInit;
  Variant Camera = Variant::CreateObject("ASCOM.Simulator.Camera");
  Camera.OlePropertySet("Connected", true);
  Camera.OleProcedure("StartExposure", 60, true);
  while (!Terminated)
  {
    if ((bool) Camera.OlePropertyGet("ImageReady"))
      return;
    Sleep(100);
  }
  if (Camera.OlePropertyGet("CameraState") == 2) // Exposure currently in progress
    Camera.OleProcedure("AbortExposure");
}