美文网首页
TThread::Queue - C++ Builder

TThread::Queue - C++ Builder

作者: 玄坴 | 来源:发表于2020-06-14 16:04 被阅读0次

    C++ Builder 参考手册 ➙ System::Classes ➙ TThreadQueue


    头文件:#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

    相关:


    C++ Builder 参考手册 ➙ System::Classes ➙ TThreadQueue

    相关文章

      网友评论

          本文标题:TThread::Queue - C++ Builder

          本文链接:https://www.haomeiwen.com/subject/bxrlohtx.html