C++ Builder 参考手册 ➙ System::Classes ➙ TThread ➙ Queue
头文件:#include <System.Classes.hpp>
命名空间:System::Classes
类:TThread
访问权限:public: / protected:
函数原型:
public:
static void __fastcall Queue(TThread* const AThread, TThreadMethod AMethod);
static void __fastcall Queue(TThread* const AThread, _di_TThreadProcedure AThreadProc);
protected:
void __fastcall Queue(TThreadMethod AMethod);
void __fastcall Queue(_di_TThreadProcedure AThreadProc);
Queue 是 TThread 的成员函数,把一个函数加入异步执行队列。
参数:
AThread:要进行异步执行的函数所在的线程对象,如果不需要在主线程调用那里访问线程对象,这个参数可以为 NULL;
AMethod:需要在主线程异步执行的方法;
AThreadProc:需要在主线程异步执行的匿名函数。
返回值:
无。
- Queue 把一个函数加入异步执行队列,这个函数将在主线程里面执行,但是不要在主线程里面调用 Queue。
- ForceQueue 把一个函数加入异步执行队列,可以在主线程里面调用这个方法;
- Queue 和 ForceQueue 不等待放入队列的函数的执行,函数放入执行队列之后立即返回,继续执行线程的其他代码,如果要让一个函数在主线程里面执行,并且等待这个函数执行完成,需要用 Synchronize 方法;
- AThreadProc 参数在 C++ 里面需要继承 TCppInterfacedObject<TThreadProcedure> 并且重载 Invoke 方法,把 new 出来的对象传递给 AThreadProc 参数,这个 Invoke 方法就是异步执行的函数,这个对象在异步执行函数结束之后自动销毁;
- 线程结束时会取消异步执行队列的执行,如果还没等队列里面的函数执行时,线程已经结束了,就不会执行加入队列里面的函数,本文后面的例子也会说明这一点。
例1:使用 TThreadMethod AMethod 参数的 Queue 方法,即成员函数指针参数:
class TTestThread : public System::Classes::TThread
{
public:
TTestThread()
: System::Classes::TThread(true)
{
FreeOnTerminate = true;
}
private:
void __fastcall Function1(void)
{
UnicodeString s;
DWORD dwThreadID = ::GetCurrentThreadId();
ShowMessage(s.sprintf(L"Queued Function1, ThreadID=%ld", dwThreadID));
}
void __fastcall Function2(void)
{
UnicodeString s;
DWORD dwThreadID = ::GetCurrentThreadId();
ShowMessage(s.sprintf(L"Synchronized Function2, ThreadID=%ld", dwThreadID));
}
protected:
void __fastcall Execute(void)
{
Queue(Function1);
Synchronize(Function2);
}
};
//---------------------------------------------------------------------------
void __fastcall TForm1::Button1Click(TObject *Sender)
{
UnicodeString s;
DWORD dwThreadID = ::GetCurrentThreadId();
ShowMessage(s.sprintf(L"Main thread: ThreadID=%ld", dwThreadID));
(new TTestThread)->Start();
}
运行结果:
- 通过运行结果可以看到,在 Button1 里面获取的主线程ID、Queue 调用的 Function1 里面,Synchronize 调用的 Function2 里面的线程ID都是相同的,说明 Function1 和 Function2 都运行在主线程里面;
- 如果去掉 TTestThread::Execute 里面的 Synchronize(Function2); 会发现 Function1 也没有被执行,原因是还没等 Function1 执行,线程已经结束了,线程结束时会取消异步队列的执行。如果把 Synchronize 那个位置换成一个延时,Function1 也会执行,只要 Function1 执行之前线程没有结束就可以。
例2:使用 _di_TThreadProcedure AThreadProc 参数的 Queue 方法
class TQueuedFunc : public TCppInterfacedObject<TThreadProcedure>
{
public:
void __fastcall Invoke(void)
{
UnicodeString s;
DWORD dwThreadID = ::GetCurrentThreadId();
ShowMessage(s.sprintf(L"TQueuedFunc::Invoke: ThreadID=%ld", dwThreadID));
}
};
class TTestThread : public System::Classes::TThread
{
public:
TTestThread()
: System::Classes::TThread(true)
{
FreeOnTerminate = true;
}
protected:
void __fastcall Execute(void)
{
Queue(new TQueuedFunc);
for(int i=0; i<100; i++)
{
Sleep(1);
}
}
};
void __fastcall TForm1::Button1Click(TObject *Sender)
{
UnicodeString s;
DWORD dwThreadID = ::GetCurrentThreadId();
ShowMessage(s.sprintf(L"Main thread: ThreadID=%ld", dwThreadID));
(new TTestThread)->Start();
}
运行结果:
- 通过运行结果可以看到,在 Button1 里面获取的主线程ID 和 Queue 调用的 TQueuedFunc::Invoke 里面的线程ID都是相同的,说明 TQueuedFunc::Invoke 运行在主线程里面;
- 如果去掉 TTestThread::Execute 里面的循环延时,TQueuedFunc::Invoke 不会执行,new 出来的 TQueuedFunc 对象直接被销毁了,因为还没等执行 TQueuedFunc::Invoke 线程已经结束了,线程结束时会取消这个线程异步执行队列的执行。
相关:
- System::TCppInterfacedObject
- System::Classes::TThreadProcedure
- System::Classes::_di_TThreadProcedure
- System::Classes::TThread::ForceQueue
- System::Classes::TThread::Synchronize
- System::Classes::TThread::RemoveQueuedEvents
- System::Classes::TThread::CreateAnonymousThread
- System::Classes::TThread
- System::Classes::TComponent::BeginInvoke
- System::Classes::TComponent::EndInvoke
- System::Classes::TComponent::EndFunctionInvoke
- System::TObject
- VCL 类继承关系
C++ Builder 参考手册 ➙ System::Classes ➙ TThread ➙ Queue