Linux下c++使用pthread庫


  pthread 庫是純c庫,沒有類指針的概念,當想phread_create中傳遞類成員函數時,就會報錯,這里針對這種情況,對線程創建做了必要封裝,較為簡單,繼承類,實現run接口,然后使用start啟動線程即可,有點像Qt中線程的用法

  

/*
 * ThreadBase.h
 *
 *  Created on: Oct 25, 2016
 *      Author: tla001
 */

#ifndef THREADBASE_H_
#define THREADBASE_H_

extern "C"{
#include <pthread.h>
#include <stdio.h>
}

class ThreadBase {
public:
    ThreadBase();
    virtual ~ThreadBase();

    int start();
    int stop();//只有stopFlag內嵌如run()才有效
    int isStop();
    int isStart();
    int join();
    virtual void run()=0;
private:
    static void *thread_proxy_func(void *args);
    int stopFlag;//1停止
    int startFlag;//1開始
    pthread_t tid;
};

#endif /* THREADBASE_H_ */
/*
 * ThreadBase.cpp
 *
 *  Created on: Oct 25, 2016
 *      Author: tla001
 */

#include "ThreadBase.h"

ThreadBase::ThreadBase() {
    // TODO Auto-generated constructor stub
    tid=-1;
    stopFlag=0;
    startFlag=0;
}

ThreadBase::~ThreadBase() {
    // TODO Auto-generated destructor stub

}

int ThreadBase::start(){
    int ret=pthread_create(&tid,NULL,thread_proxy_func,this);
    if(ret==0){
        startFlag=1;
//        printf("startFlag= %d\n",startFlag);
    }
    return ret;
}
int ThreadBase::stop(){
    stopFlag=1;
    return pthread_join(tid,NULL);
}
int ThreadBase::join(){
    return pthread_join(tid,NULL);
}
int ThreadBase::isStop(){
    return stopFlag;
}
int ThreadBase::isStart(){
    return startFlag;
}
void *ThreadBase::thread_proxy_func(void *args){
    ThreadBase *pThread=static_cast<ThreadBase*>(args);
//    printf("thread run\n");
    pThread->run();
    if(pThread->stopFlag==1)
        delete pThread;
    return NULL;
}

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM