最近在Linux 下用C++做的东西,原来是使用“多进程”方式实现,现在随着工程的增大,“多进程”的“变量共享”问题已经十分突出了,虽然可以使“内存共享”等方式实现,但大量的“内存共享”会导致代码混乱。。
所以决心将整个工程重新写,使用“多线程”方式实现,这样可以大大较少“内存共享”的使用次数。
下面是我写的基类,把代码保存在名为 Thread.h 的头文件中。
====================================传说中的分割线=================================
/*
* File: Thread.h
* Author: Null
* Blog:
* Created on 2008年7月30日, 上午10:13
*/
/*
* 在编译的时候记得加上参数:-lpthread
*
*/
#ifndef _THREAD_H
#define _THREAD_H
#include <pthread.h>
#include <unistd.h>
class Thread
{
private:
//当前线程的线程ID
pthread_t tid;
//线程的状态
int threadStatus;
//获取执行方法的指针
static void* run0(void* pVoid);
//内部执行方法
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);
};
void* Thread::run0(void* pVoid)
{
Thread* p = (Thread*) pVoid;
p->run1();
return p;
}
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()
{
return pthread_create(&tid, NULL, run0, 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::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++;
}
}
}
#endif /* _THREAD_H */
====================================传说中的分割线=================================用法简单类似于 Java 的 Thread,继承 Thread 类,然后重写 void run() 方法,然后用 bool start () 方法开始运行。这样完全屏蔽掉了线程的具体操作。使用简单方便。
具体看下面的示例代码。
====================================传说中的分割线=================================
/*
* File: newmain.cc
* Author: Null
* Blog:
* Created on 2008年7月30日, 上午11:49
*/
#include "Thread.h"
#include <iostream.h>
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);
}
}
};
int main(int argc, char** argv)
{
bool ret;
MultiThread *mt;
mt = new MultiThread();
ret = mt->start();
mt->join(6000);
return (EXIT_SUCCESS);
}====================================传说中的分割线=================================
上面的代码,由于 join 设置超时为 6 秒,所以没能完全打印出10条记录就已经退出了。
上面的代码还有些不足:
1,没有线程属性的设置,这个当初也考虑过,但是有些麻��,也很少用。如果哪位大侠实现了比较完成的 Thread 类,麻烦发个给我。
2,线程的控制有待完善,这个阿,暂时没有时间研究。
关于Linux 系统下 C++ 的多线程基类
内容版权声明:除非注明,否则皆为本站原创文章。