TThread::Queue - C++ Builder

2020-06-14 本文已影响0人玄坴

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 执行之前线程没有结束就可以。

运行结果：在按钮点击事件里面的线程ID

运行结果：在 Queue 调用的 Function1 里面的线程ID

运行结果：在 Synchronize 调用的 Function2 里面的线程ID

例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 线程已经结束了，线程结束时会取消这个线程异步执行队列的执行。

运行结果：在按钮点击事件里面的线程ID

运行结果：在 Queue 调用的 TQueuedFunc::Invoke 里面的线程ID

TThread::Queue - C++ Builder

猜你喜欢

热点阅读