1.封裝遇到的問題

將pthread執行緒封裝為抽象類，這樣使用者在使用執行緒時，只需要繼承一下這個抽象類，並實現相應的介面就可以了。這樣做的好處是使用者可以將注意力集中線上程所要執行的邏輯上，而不需要關注建立執行緒、銷燬執行緒等細節問題上。

我們抽象類的名稱為Thread，其中有一個成員函式run，該函式為的宣告形式為：

void run() = 0;

即將該成員函式宣告為純虛擬函式，使用者繼承此類必須要實現此成員函式。Thread中還有另外一個成員函式start，該函式的宣告形式為：

void start();

使用者在子類中呼叫start方法，將啟動執行緒，並在執行緒中執行run函式。

最常想到的方法就是在start方法中使用pthread_create建立一個執行緒，並呼叫run函式。如下面這樣的實現：

void start() 
{ 
	int status;
 
	status = pthread_create(_pThread,NULL,Thread::run,NULL); 
	if(status != 0) 
 		err_abort(“creating thread failure”,status); 
 
 } 

這樣編譯肯定是不能通過的，這是因為pthread_create要求的執行緒例程的介面形式為：

void *(*thread_routin)(void *args);

而上面程式碼中提供的執行緒例程的介面形式為：

void Thread::run()

顯然不符合要求的介面。

為了能夠在start中呼叫run函式，我們不得不採用一種迂迴的方式。下面提供兩種方法：一種是使用靜態成員函式，另外一種是使用友元函式。

       靜態成員函式的作用域是全域性的，而不僅僅侷限於某個函式中。靜態成員函式的實現方法和C語言中的普通函式類似，因此靜態函式沒有this指標，靜態函式只能操作靜態成員變數。之所以將靜態函式封裝到類中，在很大程度上也只是為了滿足面向物件的特性之一-----封裝性。

2.使用靜態函式

       需要特別注意的是mian函式中使用pthread_create

#ifndef THREAD_H
#define THREAD_H
#include <iostream>
#include <pthread.h>

using namespace std;

class Thread
{
private:
    //當前執行緒的執行緒ID
    pthread_t tid;
    //執行緒的狀態
    int threadStatus;
    //獲取執行方法的指標
    static void * thread_proxy_func(void * args);
    //內部執行方法
    void* run1();
public:
    //執行緒的狀態－新建
    static const int THREAD_STATUS_NEW = 0;
    //執行緒的狀態－正在執行
    static const int THREAD_STATUS_RUNNING = 1;
    //執行緒的狀態－執行結束
    static const int THREAD_STATUS_EXIT = -1;
    //建構函式
    Thread();
    //執行緒的執行實體
    virtual void run()=0;
    //開始執行執行緒
    bool start();
    //獲取執行緒ID
    pthread_t getThreadID();
    //獲取執行緒狀態
    int getState();
    //等待執行緒直至退出
    void join();
    //等待執行緒退出或者超時
    void join(unsigned long millisTime);
};

class MultiThread : public Thread
{
public:
    void run()
    {
        int number = 0;
        for (int i = 0; i < 10; i++)
        {
            cout << "Current number is " << number++;
            cout << " PID is " << getpid() << " TID is " << getThreadID() << endl;
            sleep(1);
        }
    }
};

#endif

#include "thread.h"


void* Thread::run1()
{
    threadStatus = THREAD_STATUS_RUNNING;
    tid = pthread_self();
    run();
    threadStatus = THREAD_STATUS_EXIT;
    tid = 0;
    pthread_exit(NULL);
}

Thread::Thread()
{
    tid = 0;
    threadStatus = THREAD_STATUS_NEW;
}

bool Thread::start()
{
		int iRet = 0;
    pthread_create(&tid, NULL, thread_proxy_func, this) == 0;
}

pthread_t Thread::getThreadID()
{
    return tid;
}

int Thread::getState()
{
    return threadStatus;
}

void Thread::join()
{
    if (tid > 0)
    {
        pthread_join(tid, NULL);
    }
}
void * Thread::thread_proxy_func(void * args)
{
 		Thread * pThread = static_cast<Thread *>(args); 
 
		pThread->run(); 
 		
 		return NULL; 
}

void Thread::join(unsigned long millisTime)
{
    if (tid == 0)
    {
        return;
    }
    if (millisTime == 0)
    {
        join();
    }else
    {
        unsigned long k = 0;
        while (threadStatus != THREAD_STATUS_EXIT && k <= millisTime)
        {
            usleep(100);
            k++;
        }
    }
}

#include <iostream>
#include <pthread.h>
#include "thread.h"

using namespace std;

int main(int argv,char *argc)
{
	MultiThread tt;
	tt.start();
	tt.join();
	return 0;
}

3.使用友元函式

       友元函式的作用和靜態函式相同，都起到一個代理的作用。需要將物件的指標作為引數傳遞給這個友元函式，然後在友元函式中呼叫run函式。程式碼如下，

由三個檔案構成：Thread.h（類的宣告檔案），Thread.cpp（類的實現檔案），main.cpp（測試檔案）：

#ifndef THREAD_H
#define THREAD_H
#include <iostream>
#include <pthread.h>

using namespace std;

class Thread
{
private:
    //當前執行緒的執行緒ID
    pthread_t tid;
    //執行緒的狀態
    int threadStatus;
    //獲取執行方法的指標
    //static void * thread_proxy_func(void * args);
    friend void * thread_proxy_func(void * args);
    //內部執行方法
    void* run1();
public:
    //執行緒的狀態－新建
    static const int THREAD_STATUS_NEW = 0;
    //執行緒的狀態－正在執行
    static const int THREAD_STATUS_RUNNING = 1;
    //執行緒的狀態－執行結束
    static const int THREAD_STATUS_EXIT = -1;
    //建構函式
    Thread();
    //執行緒的執行實體
    virtual void run()=0;
    //開始執行執行緒
    bool start();
    //獲取執行緒ID
    pthread_t getThreadID();
    //獲取執行緒狀態
    int getState();
    //等待執行緒直至退出
    void join();
    //等待執行緒退出或者超時
    void join(unsigned long millisTime);
};

class MultiThread : public Thread
{
public:
    void run()
    {
        int number = 0;
        for (int i = 0; i < 10; i++)
        {
            cout << "Current number is " << number++;
            cout << " PID is " << getpid() << " TID is " << getThreadID() << endl;
            sleep(1);
        }
    }
};

#endif

#include "thread.h"


void* Thread::run1()
{
    threadStatus = THREAD_STATUS_RUNNING;
    tid = pthread_self();
    run();
    threadStatus = THREAD_STATUS_EXIT;
    tid = 0;
    pthread_exit(NULL);
}

Thread::Thread()
{
    tid = 0;
    threadStatus = THREAD_STATUS_NEW;
}

bool Thread::start()
{
		int iRet = 0;
    pthread_create(&tid, NULL, thread_proxy_func, this) == 0;
}

pthread_t Thread::getThreadID()
{
    return tid;
}

int Thread::getState()
{
    return threadStatus;
}

void Thread::join()
{
    if (tid > 0)
    {
        pthread_join(tid, NULL);
    }
}
void * thread_proxy_func(void * args)
{
 		Thread * pThread = static_cast<Thread *>(args); 
 
		pThread->run(); 
 		
 		return NULL; 
}

void Thread::join(unsigned long millisTime)
{
    if (tid == 0)
    {
        return;
    }
    if (millisTime == 0)
    {
        join();
    }else
    {
        unsigned long k = 0;
        while (threadStatus != THREAD_STATUS_EXIT && k <= millisTime)
        {
            usleep(100);
            k++;
        }
    }
}

#include <iostream>
#include "thread.h"

using namespace std;

int main(int argv,char *argc)
{
	MultiThread tt;
	tt.start();
	tt.join();
	return 0;
}

makefile參考

ANAME=server
CC=g++
TMP_PROGS = main.cpp thread.cpp
PROGS = $(TMP_PROGS)
OBJS = $(PROGS:.cpp=.o)
INCDIR=./

all: $(ANAME)

$(ANAME): $(OBJS)
	@echo "--------------- .o to ELT "
	$(CC) -g $(TMP_PROGS) -o [email protected] -lpthread 
.cpp.o:
	@echo "--------------- CPP to .o "
	$(CC) -g $(CFLAGS) -I$(INCDIR) -c  $< -o [email protected]  -lpthread 

clean:
	$(RM) $(ANAME)
	$(RM) *.o