Tars框架线程TC_Thread的使用

灰太狼 2022-03-17 20:07 230阅读 0赞

开源库Tars，本文参考官方示例对封装的线程TC\_Thread进行实践。

封装类 TestThread  
头文件：

#pragma once
    #include "../../tars/util/include/util/tc_thread.h"
    
    using namespace tars;
    
    namespace lesliefishtest
    {
        class TestThread : public TC_Thread, public TC_ThreadLock
        {
        public:
            explicit TestThread();
            
        private:
            // 终止线程
            void terminate();
            // 执行实际任务
            void runTask();
    
        protected:
        	// 实现父类的这个纯虚函数
            virtual void run();
    
        private:
            bool m_hasTerminate; // 是否终止
    
        // test part
        public:
            static void test();
        };
    }

cpp文件：

#include "test_thread.h"
    #include <thread>
    
    namespace lesliefishtest
    {
        TestThread::TestThread()
            : m_hasTerminate(false)
        {
    
        }
    
        void TestThread::terminate()
        {
            m_hasTerminate = true;
            {
                TC_ThreadLock::Lock sync(*this);
                notifyAll();
            }
        }
    
        /****************************************!
         * @brief  实际执行的任务
         * @return void  
         ****************************************/ 
        void TestThread::runTask()
        {
            std::cout << "run the task" << endl;
    
            // 休眠三秒后结束线程
            std::this_thread::sleep_for(std::chrono::seconds(3));
    
            // 执调用终止结束线程执行
            std::cout << "end the task" << endl;
            terminate();
        }
    
        /****************************************!
         * @brief  实现run纯虚函数
         * @return void  
         ****************************************/ 
        void TestThread::run()
        {
            while (!m_hasTerminate)
            {
                runTask(); // 执行任务
    
                {
                    TC_ThreadLock::Lock sync(*this);
                    timedWait(500);
                }
            }
        }
    
        /****************************************!
         * @brief  静态测试函数
         * @return void  
         ****************************************/ 
        void TestThread::test()
        {
            try
            {
                TestThread testThread;
                testThread.start();		// 启动线程
    
                cout << "thread id : " << testThread.getThreadControl().id() << endl; // 线程id
    
                testThread.getThreadControl().join(); // 并入主线程
            }
            catch (const std::exception& ex)
            {
                cout << ex.what() << endl;
            }
        }
    
    }

--------------------

测试函数：

#include <cstdio>
    #include <thread>
    #include <iostream>
    #include "test/utiltest/test_thread.h"
    
    using namespace std;
    using namespace tars;
    
    int main()
    {
        lesliefishtest::TestThread::test();
    
        return 0;
    }

执行结果:

yu@ubuntu:~$ cd /home/yu/projects/FishTars/bin/x64/Debug/
    yu@ubuntu:~/projects/FishTars/bin/x64/Debug$ ./FishTars.out
    thread id : 140188137690880
    run the task
    end the task
    yu@ubuntu:~/projects/FishTars/bin/x64/Debug$

--------------------

实践环境：vs2017+ubuntu14.04  
代码路径：  
[https://github.com/lesliefish/FishTars/blob/master/code/FishTars/test/utiltest/test\_thread.cpp][https_github.com_lesliefish_FishTars_blob_master_code_FishTars_test_utiltest_test_thread.cpp]

[https_github.com_lesliefish_FishTars_blob_master_code_FishTars_test_utiltest_test_thread.cpp]: https://github.com/lesliefish/FishTars/blob/master/code/FishTars/test/utiltest/test_thread.cpp