forked from jasonweiyi/XAPI2
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathMsgQueue.cpp
More file actions
132 lines (118 loc) · 2.54 KB
/
Copy pathMsgQueue.cpp
File metadata and controls
132 lines (118 loc) · 2.54 KB
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
#include "stdafx.h"
#include "MsgQueue.h"
CMsgQueue::CMsgQueue()//:m_queue(1024)
{
m_hThread = nullptr;
m_bRunning = false;
m_bDirectOutput = false;
//回调函数地址指针
m_fnOnRespone = nullptr;
}
void CMsgQueue::Clear()
{
ResponeItem* pItem = nullptr;
//清空队列
while (m_queue.try_dequeue(pItem))
{
if (pItem->bNeedDelete)
{
delete[] pItem->ptr1;
delete[] pItem->ptr2;
delete[] pItem->ptr3;
}
delete pItem;
}
}
bool CMsgQueue::Process()
{
try
{
ResponeItem* pItem = nullptr;
if (m_queue.try_dequeue(pItem))
{
Output(pItem);
if (pItem->bNeedDelete)
{
// 删除的是数组，目前是自己模块创建的自己删
delete[] pItem->ptr1;
delete[] pItem->ptr2;
delete[] pItem->ptr3;
}
delete pItem;
return true;
}
return false;
}
catch (...)
{
return false;
}
}
void CMsgQueue::Output(ResponeItem* pItem)
{
try
{
if (m_fnOnRespone)
(*m_fnOnRespone)(pItem->type, pItem->pApi1, pItem->pApi2, pItem->double1, pItem->double2, pItem->ptr1, pItem->size1, pItem->ptr2, pItem->size2, pItem->ptr3, pItem->size3);
}
catch (...)
{
m_fnOnRespone = nullptr;
}
}
void CMsgQueue::StartThread()
{
if(nullptr == m_hThread)
{
m_bRunning = true;
m_hThread = new thread(ProcessThread,this);
}
}
void CMsgQueue::StopThread()
{
m_bRunning = false;
this_thread::sleep_for(chrono::milliseconds(1));
m_cv.notify_all();
this_thread::sleep_for(chrono::milliseconds(1));
lock_guard<mutex> cl(m_mtx_del);
if(m_hThread)
{
//m_cv.notify_all();
m_hThread->join();
delete m_hThread;
m_hThread = nullptr;
}
}
void CMsgQueue::RunInThread()
{
try
{
while (m_bRunning)
{
if (Process())
{
}
else
{
// 空闲时等1ms,如果立即有事件过来就晚了1ms
//this_thread::sleep_for(chrono::milliseconds(1));
// 空闲时过来等1ms,没等到就回去再试
// 如过正好等到了，就立即去试，应当会快一点吧?
// wait_for的效果为何不是遇到事件后就立即返回？而是一定要等满时间？太奇怪了，这个地方可以改成seconds(10)就知道效果了
unique_lock<mutex> lck(m_mtx);
//m_cv.wait_for(lck, std::chrono::seconds(10), [this]{return m_bRunning == false; }); //这种写法会导致收到事件立即处理的功能失效
m_cv.wait_for(lck, std::chrono::seconds(2));
}
}
}
catch (...)
{
}
// 清理线程
m_hThread = nullptr;
m_bRunning = false;
}
ConfigInfoField* CMsgQueue::Config(ConfigInfoField* pConfigInfo)
{
return nullptr;
}