【Linux课程学习】：锁封装(Mutex)线程封装(Thread)，this指针

<code class="javascript">namespace MutexModule{    class Mutex    {    private:        Mutex(const Mutex &) = delete;        const Mutex &operator=(const Mutex &) = delete;    public:        Mutex()        {            int n = ::pthread_mutex_init(&_mutex, nullptr);            (void)n;        }        void Lock()        {            int n = ::pthread_mutex_lock(&_mutex);            (void)n;        }        void UnLock()        {            int n = ::pthread_mutex_unlock(&_mutex);            (void)n;        }        pthread_mutex_t *LockPtr()        {            return &_mutex;        }        ~Mutex()        {            int n = ::pthread_mutex_destroy(&_mutex);            (void)n;        }    private:        pthread_mutex_t _mutex;    };    class LockGuard    {    public:        LockGuard(Mutex &mtx) : _mtx(mtx)        {            _mtx.Lock();        }        ~LockGuard()        {            _mtx.UnLock();        }    private:        Mutex &_mtx;    };}</code>

<code class="javascript">#include <iostream>using namespace std;class Solution {public:Solution():_n(1111){}friend static void test(Solution* t);static void func(){}static void a(){//可以访问静态成员方法，访问权限给到了private// 就是没有默认传递this指针而已func();_m = 11;}static void b(Solution* t){//可以访问静态成员方法，访问权限给到了private// 就是没有默认传递this指针而已t->_n = 555;t->_m;t->func();}private:int _n;static int _m;};void test(Solution* t){//能访问是传递了Solution对象，是Solution类的友元//friend static void test(Solution*& t);t->_n = 222;}</code>

<code class="javascript">void EnableDetach(){    //状态变为false，新的线程默认为true    _joinable=false;}void Detach(){    EnableDetach();    //线程分离    pthread_detach(_tid);}</code>

<code class="javascript">Thread(func_t func)       :_pid(getpid())       ,_func(func)       ,_joinable(true)       ,_status(STATUS::NEW){      LockGuard lockguard(_lock);      {       _name="thread-"+std::to_string(num++);        }}</code>

<code class="javascript">static void* Routine(void* args){     Thread* t=static_cast<Thread*>(args);     t->_status=STATUS::RUNNING;     t->_func(t->Name());     return nullptr;}bool Start(){     if(_status!=STATUS::RUNNING)     {           int n=::pthread_create(&_tid,nullptr,Routine,this);           if(n!=0)           {               //线程创建失败               return false;           }           return true;     }     //已经在RUNNING了     return false;}</code>

<code class="javascript">bool Stop(){    //在运行的时候，才能cancle    if(_status==STATUS::RUNNING)    {        _status=STATUS::STOP;        int n=::pthread_cancel(_tid);        if(n!=0)        {            return true;        }    }    return true;}</code>

<code class="javascript">void EnableDetach(){//状态变为false_joinable = false;}bool Join(){//没有被分离才能joinif (_joinable){int n = ::pthread_join(_tid, nullptr);if (n != 0)return false;_status = STATUS::STOP;return true;}return false;}void Detach(){EnableDetach();//线程分离pthread_detach(_tid);}</code>

<code class="javascript">#pragma once #include <iostream>#include <cstdio>#include <string.h>#include <cstring>#include <pthread.h>#include <functional>#include <unistd.h>#include <sys/types.h>#include "Mutex.hpp"namespace ThreadModule{    using namespace MutexModule;    using func_t=std::function<void(std::string name)>;    static int num=1;    enum class STATUS    {        RUNNING=1,        STOP,        NEW     //新的线程的状态    };    class Thread    {    private:        //执行方法，routine惯例        static void* Routine(void* args)        {            Thread* t=static_cast<Thread*>(args);            t->_status=STATUS::RUNNING;            t->_func(t->Name());            return nullptr;        }        void EnableDetach()        {            //状态变为false            _joinable=false;        }    public:        Thread(func_t func)            :_pid(getpid())             ,_func(func)             ,_joinable(true)             ,_status(STATUS::NEW)        {            LockGuard lockguard(_lock);            {                _name="thread-"+std::to_string(num++);              }        }        bool Start()        {            if(_status!=STATUS::RUNNING)            {                int n=::pthread_create(&_tid,nullptr,Routine,this);                if(n!=0)                {                    //线程创建失败                    return false;                }                return true;            }            //已经在RUNNING了            return false;        }        bool Stop()        {            //在运行的时候，才能cancle            if(_status==STATUS::RUNNING)            {                _status=STATUS::STOP;                int n=::pthread_cancel(_tid);                if(n!=0)                {                    return false;                }                return true;            }            return true;        }        bool Join()        {            //没有被分离才能join            if(_joinable)            {                int n=::pthread_join(_tid,nullptr);                if(n!=0)                    return false;                _status=STATUS::STOP;                return true;            }            return false;        }                void Detach()        {            EnableDetach();            //线程分离            pthread_detach(_tid);        }        std::string Name()  {return _name;}        bool JoinAble(){return _joinable;}        ~Thread()        {        }    private:        std::string _name;  //线程名字        pthread_t _tid;     //线程tid        pid_t _pid;         //线程属于哪个进程pid                STATUS _status;     //线程的状态        bool _joinable;     //是否被分离        func_t _func;       //线程执行的方法        Mutex _lock;        //锁进行保护    };}</code>