mirrors/TarsCloud_TarsCpp
1
0
Fork 0
mirror of https://gitee.com/TarsCloud/TarsCpp.git synced 2024-12-22 22:16:38 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

epoll server queue, tc_cas_queue change to tc_thread_queue

Browse Source
This commit is contained in:
ruanshudong 2020-04-06 21:48:02 +08:00
parent fbc66a2ad9
commit dab2708f93
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
util/include/util/tc_cas_queue.h
View File

@ -42,7 +42,7 @@ public:
T front();
/**
* @brief 从头部获取数据, 没有数据则等待.
* @brief 从头部获取数据
*
* @param t
* @return bool: true, 获取了数据, false, 无数据
@ -50,7 +50,7 @@ public:
bool pop_front(T& t);
/**
* @brief 从头部获取数据, 没有数据则等待.
* @brief 从头部获取数据
*
* @return bool: true, 获取了数据, false, 无数据
*/

6
util/include/util/tc_epoll_server.h
View File

@ -168,8 +168,10 @@ public:
int64_t _recvTimeStamp; /**接收到数据的时间*/
};
typedef TC_CasQueue<shared_ptr<RecvContext>> recv_queue;
typedef TC_CasQueue<shared_ptr<SendContext>> send_queue;
// typedef TC_CasQueue<shared_ptr<RecvContext>> recv_queue;
typedef TC_ThreadQueue<shared_ptr<RecvContext>> recv_queue;
// typedef TC_CasQueue<shared_ptr<SendContext>> send_queue;
typedef TC_ThreadQueue<shared_ptr<SendContext>> send_queue;
typedef recv_queue::queue_type recv_queue_type;
////////////////////////////////////////////////////////////////////////////