C++实现多线程编程

在C++的多线程编程实现里有两种方式,一种是Windows头文件里的CreateProcess,另一种是process.h里的_beginthread,我这里用的是后一种,并且将多线程操作封装成了类似Java里的Thread类。

Thread类包含四种操作(对应线程的几种状态):就绪(start),挂起(suspend)、恢复(resume)以及终止(terminate),另外,还包含了一个可以设置线程超时的操作。


Thread类代码如下(Thread.h):

#ifndef THREAD_H
#define THREAD_H
#include <windows.h>
#include <process.h>
typedef void *HANDLE;
class Thread
{
public:
	Thread();								//构造器

	void		 start();					//线程启动函数
	virtual void run();						//线程运行函数
	int			 suspend();					//线程挂起,返回之前挂起次数
	int			 resume();					//线程恢复,返回之前的挂起次数
	void		 terminate();				//强行终止进程
	void		 setTimeOut(DWORD time);	//设置超时时间,默认为INFINITE
	DWORD		 getTimeOut();				//返回超时时间

private:
	HANDLE m_h;								//当前线程的句柄
	DWORD  m_timeout;						//超时时间
	static void init(void *_h);				//运行当前线程
};


#endif

实现文件(Thread.cpp):


#include <iostream>
using std::cin;
using std::cout;
using std::endl;

#include "Thread.h"

Thread::Thread(){
	m_timeout = INFINITE;				//设置默认的超时,为无穷大
}

void Thread::start()
{
	m_h = (HANDLE)_beginthread(init, 0, (void *)this);		//创建线程

}
void Thread::run()
{
	//线程运行方法
}

void Thread::init(void* _h){
	Thread *t = (Thread*)_h;
	t->run();
	DWORD dw = WaitForSingleObject(t->m_h, t->m_timeout); //等待线程,500ms后超时结束,INFINITE表示不超时
	switch (dw)
	{
	case WAIT_OBJECT_0:
		break;
	case WAIT_TIMEOUT: cout << "Time Out" << endl;
		break;
	case WAIT_FAILED:
		break;
	}
}

//线程挂起,返回之前挂起次数
int Thread::suspend(){
	return SuspendThread(this->m_h);
}

//线程恢复,返回之前的挂起次数
int Thread::resume(){
	DWORD re = ResumeThread(this->m_h);
	return re;
}

//强行终止进程
void Thread::terminate(){
	TerminateThread(this->m_h, EXIT_SUCCESS);
}

//设置超时时间,默认为INFINITE
void Thread::setTimeOut(DWORD time){
	this->m_timeout = time;
}
//返回超时时间
DWORD Thread::getTimeOut(){
	return this->m_timeout;
}


测试文件(TestThread.cpp):

 //测试文件
#include "Thread.h"

#include <windows.h>
#include <process.h>
#include <iostream>
using std::cin;
using std::cout;
using std::endl;
#include <string>
using std::string;

class TestThread : public Thread
{
public:
	TestThread(string _s){
		s = _s;
	}
	string s;
	void run();
};

void TestThread::run()
{
	for (int i = 0; i < 10; i++){
		cout <<s+"\n";
	}
	
}

int main(int argc, char *argv[])
{
	TestThread *dt[10];
	dt[0] = new TestThread("A");		//新建线程A
	dt[1] = new TestThread("B");		//新建线程B
	dt[0]->start();						//开启线程A
	cout<<dt[0]->suspend()<<endl;		//挂起线程A
	dt[1]->setTimeOut(500);
	dt[1]->start();						//开启线程B
	
	Sleep(2000);						//暂停2s,此时线程A仍属于挂起状态,所以不执行
	dt[0]->resume();					//恢复线程A,此时线程A属于恢复状态,继续执行

	getchar();
}


测试结果如图:

转载请注明原文地址 http://www.zgljl2012.com/2016/09/20/c-shi-xian-duo-xian-cheng-bian-cheng/


欢迎大家关注我的微信公众号
![指绘锦绣](http://www.zgljl2012.com/content/images/zh.jpg)
扫描上方的二维码关注“指绘锦绣”