Cplusplus_Thread_Lib/TestThread.cpp at master · wyh267/Cplusplus_Thread_Lib · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54


#include"TestThread.h"
#include"COperatingSystemFactory.h"

#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
#include<assert.h>


TestThread::TestThread(constchar *m_name):
CThread(m_name)
{

//add your code here


}


TestThread::~TestThread()
{

}

voidTestThread::mainLoop()
{
unsignedint code;
void *p_msg;
while(1)
 {

 p_msg_rev->recvMsg(code, p_msg);
printf("<<<<<<<%s is Running....recv data from message queue: code is : [%d] data is : [%s] \n",p_thread_name,code,(char *)p_msg);

 }


}


voidTestThread::setMsgQueue(CMsgQueue *q)
{
	p_msg_rev=q;
}