C++学习之路： 线程封装（基于对象编程）

引言：

此次我们重新封装线程， 采用基于对象编程的方式，不用于面向对象编程中重定义虚函数的方式，这里我们用回调函数的方式。

Thread.h

#ifndef THREAD_H_
#define THREAD_H_

#include <boost/noncopyable.hpp>
#include <functional>
#include <pthread.h>

class Thread : boost::noncopyable
{
public:
    typedef std::function<void ()> ThreadCallback;

    Thread(ThreadCallback callback);
    ~Thread();

    void start();
    void join();

    static void *runInThread(void *);

private:
    pthread_t threadId_;
    bool isRunning_;
    ThreadCallback callback_; //回调函数
};



#endif //THREAD_H_

可以看到没有重定义虚函数， 而是设置了一个函数适配器， 用于保存我们想要的业务逻辑。

直接用 静态函数 runInThread 调用 callback_即可。

Thread.cpp

#include "Thread.h"

Thread::Thread(ThreadCallback callback)
: threadId_(0),
  isRunning_(false),
  callback_(std::move(callback))
{

}
    
Thread::~Thread()
{
    if(isRunning_)
    {
        //detach
        pthread_detach(threadId_);
    }
}

void Thread::start()
{
    pthread_create(&threadId_, NULL, runInThread, this);
    isRunning_ = true;
}
void Thread::join()
{
    pthread_join(threadId_, NULL);
    isRunning_ = false;
}

void *Thread::runInThread(void *arg)
{
    Thread *pt = static_cast<Thread*>(arg);
    pt->callback_(); //调用回调函数

    return NULL;
}

以上 有几点经验处理， Google推荐 当Thread 这个类析构时，如果线程还没有执行完， 那么就detach。

并设置一个标志位 bool isRunning 标志线程是否启动。

测试代码

#include "Thread.h"
#include <stdio.h>
#include <unistd.h>
using namespace std;

void foo()
{
    while(1)
    {
        printf("foo
");
        sleep(1);
    }
}



int main(int argc, char const *argv[])
{
    Thread t(&foo);

    t.start();
    t.join();

    return 0;
}

可以看到， 当用基于对象编程时， 不需要在定义用户自己的类了， 只需在主函数传入一个函数适配器即可。 具体函数类型可以用bind来实现。

测试代码2

#include "Thread.h"
#include <stdio.h>
#include <unistd.h>
using namespace std;

class Foo
{
public:
    void foo(int i)
    {
        while(1)
        {
            printf("foo %d
", i++);
            sleep(1);
        }
    }
};



int main(int argc, char const *argv[])
{
    Foo f;
    int i = 34;
    Thread t(bind(&Foo::foo, &f, i));

    t.start();
    t.join();

    return 0;
}

对于 类的成员函数 同理使用 大杀器bind