VC++线程通信-白红宇

这是我现在使用的一种线程通信方式的代码片段，两个线程之间通过自定义消息进行通知,

#define MY_MSG WM_USER+100 //线程通信的自定义消息

//消费者

DWORD Consumer::Run()

{//创建线程并启动

DWORD ThreadId;

m_hThread = CreateThread( NULL,0,Routine,0,0,&ThreadId );//创建更新线程

if( NULL == m_hThread )

{

return -1;//启动失败

}

return ThreadId;//线程启动成功

}

DWORD WINAPI Consumer::Routine( LPVOID lParam)

{//线程运行函数

std::cout<<"消费者线程启动\n";

MSG msg;

PeekMessage(&msg, NULL, WM_USER, WM_USER, PM_NOREMOVE);

while(true)

{

if(GetMessage(&msg,0,0,0)) //get msg from message queue

{

switch(msg.message)

{

case MY_MSG:

//do something here

std::cout<<"收到消息"<<std::endl;

break;

}

};

return 0;

}

//生产者

DWORD Producer::Run(LPDEALFUNCTION dealfun,LPVOID lParam)

{

DWORD ThreadId;

m_DealFun = dealfun;

m_DealFunParam = NULL;

m_hThread = CreateThread( NULL,0,Routine,this,0,&ThreadId );//创建监控线程

if( NULL == m_hThread )

{

return -1;

}

return ThreadId;

}

DWORD WINAPI Producer::Routine( LPVOID lParam )

{

Producer& obj = *(Producer*)lParam;//生产者对象

while( !obj.m_bRequestStop )

{//线程就不断运行直到收到用户的退出请求

obj.m_DealFun(obj.m_DealFunParam );

}

return 0;

}

//main.cpp

HANDLE hStartEvent; // thread start event

unsigned nConsumerID,nProducerID;

void __stdcall MyDeal( LPVOID lParam )

{

std::cout<<"开始发送消息.."<<std::endl;

if(!PostThreadMessage(nConsumerID,MY_MSG,NULL,NULL))//post thread msg

{

printf("post message failed,errno:%d\n",::GetLastError());

}

::Sleep(1000);

}

int main()

{

Consumer consumer;

nConsumerID = consumer.Run();//启动更新线程

if(nConsumerID == -1)

{

std::cout<<"start thread failed"<<std::endl;

return -1;

}

Producer pProducer;

nProducerID = pProducer.Run(&MyDeal, 0 );//启动监控线程

if( nProducerID==-1 )

return -1;

return 0;

}

本文转自Phinecos(洞庭散人)博客园博客，原文链接：http://www.cnblogs.com/phinecos/archive/2008/03/14/1106481.html，如需转载请自行联系原作者