{

m_hThread = nullptr;

m_bRunning = false;

m_bDirectOutput = false;

//回调函数地址指针

m_fnOnRespone = nullptr;

{

ResponeItem* pItem = nullptr;

//清空队列

while (m_queue.try_dequeue(pItem))

{

if (pItem->bNeedDelete)

{

delete[] pItem->ptr1;

delete[] pItem->ptr2;

delete[] pItem->ptr3;

}

delete pItem;

}

{

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;

{

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;

}

{

if(nullptr == m_hThread)

{

m_bRunning = true;

m_hThread = new thread(ProcessThread,this);

}

{

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;

}

{

while (m_bRunning)

{

if (Process())

{

}

else

{

// 空闲时等1ms,如果立即有事件过来就晚了1ms

//this_thread::sleep_for(chrono::milliseconds(1));

// 空闲时过来等1ms,没等到就回去再试

// 如过正好等到了，就立即去试，应当会快一点吧?

unique_lock<mutex> lck(m_mtx);

m_cv.wait_for(lck, std::chrono::seconds(1), [this]{return m_bRunning == false; });

}

}

// 清理线程

m_hThread = nullptr;

m_bRunning = false;