在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/