分类：
2008-10-13 16:51:07
一个简单的线程管理机制
张家旺 2005-04-24
周末，总是有点那么的无聊。闲来没事，想想每次自己要进行多线程编程时的痛苦，也并借机考虑设计了一个简单的线程管理方式。
没什么好说的，首先想想线程的创建，每次都要CreateThread，传递一堆的参数，还得没事查查MSDN，唉，效率低啊。反正，对于我来说，线程基本都是缺省优先级、缺省安全的。不如把这些一起封装了。
不多说，C++不用对象机制用什么？顺便借鉴一下java。来个实际线程就是run，启动采用start。
class thread
{
public:
thread( void );
virtual ~thread( void );
virtual void run() = 0;
void start();
};
这个也就是最基本的，基于对象的线程基类了。子类只需要实现run作为线程，调用start，就可以启动线程了。线程的所需参数，很简单，基于对象，有需要的，做为扩展类的成员变量——成员资源来访问。
就这么简单？线程访问最大的问题——资源共享。那好，很容易想到互斥量。还有java的关键字synchronized，我们也就加一个锁的概念。
class thread
{
public:
thread( void );
virtual ~thread( void );
virtual void run() = 0;
void start();
static void syncLock( void *res,bool lock );
};
这样，在最基本的线程资源——HANDLE，就可以被管理了，资源的访问也可以通过lock和unlock来保护了。
实际中，很多时候，我们希望能限制或知道有多少线程在运行，那么再加一个运行线程记数功能。大多时候，往往是采用线程池，而且会根据CPU数目，决定运行的线程数目。我们干脆，再提供一个功能，限制对象上可以允许同时运行的线程数目。那好，改为(同时加上一些保护和注解)：
typedef unsigned int U32;
/**
* 线程对象
* 提供基于对象的线程处理接口
*/
class thread
{
public:
/**
* 线程基于对象的构造
* para max 允许最多同时运行线程数
*/
explicit thread( U32 max = -1 );
virtual ~thread( void );
/**
* 启动一个线程
* @return 启动成功否
*/
bool start( void );
/**
* 对象上启动的线程数
* @return 线程数
*/
U32 count( void );
/**
* 线程执行函数
* @return 无
*/
virtual void run( void ) = 0;
/**
* 为对象加解锁
* @return 无
* @para res 要加解锁的资源对象
* @para lock 加锁还是解锁
*/
static void syncLock( void *res,bool lock );
private:
thread( const thread &t );
thread &operator=( const thread &t );
void *m_datas;
};
至于实现，我想不难。别忘了，对象销毁时要等待所有线程结束，并释放HANDLE资源哦。否则，线程会访问错误的内存，还有线程HANDLE被泄漏的。（千万别死锁了，自己实现时就因为资源锁来锁去，锁死了。）
哈哈，就这么简单，一个简单的线程创建、管理就实现了。至于void *，你可以根据自己的实现去定义数据结构。
东西简单，也就不贴出cpp源码了，关键是个想到、做到的问题。
头文件和lib，放在rar包吧，给大家一个实现后的参考。如果，发现有什么问题，可以随时和我联系。或者，您有更好的想法，并且愿意和我分享，那真是举目明月，尽展抒怀。假如，您对有些语法，比如explicit不明，那么，建议您先看看有关C++的语法或者找您周围的高手，让他们洗脑一番。：}
谢谢阅读，就此打住。
