C SOCKET通訊模型（七）非同步epoll

不得不說為這非同步epoll模型還真是傷了神。。。主要問題就是在libaio的核心通知上，因為這東西實在太低階了，用起來還比較麻煩。我為了不再多開執行緒，實現和iocp基本相同的原理，在proc內部又用了次epoll，使其核心通知和使用者通知都能在乙個執行緒中得到相同處理。並且用map對映eventfd與收發型別的關係，使其能夠在收到event的時候，通過eventfd能直接判斷出接下來的操作。還有就是由於libaio需要將fd設定為o_direct，所以無論收發都得用自己的緩衝區，不然會導致效率大大降低。這份**有興趣自己研究，具體的不多說了，寫出來還沒測試，不知道應用於實際專案中效果如何，大牛可以自己測下

yum install libaio-devel

-lpthread -std=c++11

#include #include#include#include#include#include #include#include#include#include#include #include#include#include#include#include#define recv_events 1024
#define send_events 1024
#define proc_events 1024
#define buf_send_len 1024
#define buf_recv_len 1024
#define recv_len 128
#define send_len 128
using namespace std;
typedef unsigned long long ull;
struct client
;void* createserv(void* args);
void* proc(void* args);
using namespace std;
const int _thread_count = 8;
int _epfd;
int socksrv;
int id = 0;
epoll_event _events[recv_events] = ;
epoll_event ev[_thread_count];
mutex m;
deque_deque;
map_sockmap;
list_removelist;
mutex lock4cv2;
condition_variable cv2;
int _thread_unfinish;
int _eventfd4send[_thread_count];
int _eventfd4recv[_thread_count];
int _proc_epfd[_thread_count];
map_eventfd_type_map;
enum
;int main()
pthread_create(&tid, 0, createserv, 0);
for (int i = 0; i < _thread_count; i++)
cin.get();
cin.get();
return 0;
}bool _isfinish()
void release(int fd)
}	close(fd);
}static void recv_callback(io_context_t ctx, struct iocb *iocb, long res, long res2)
void* proc(void* args)
epoll_event* e = _deque.front();
_deque.pop_front();
m.unlock();
if (e->data.fd == -1)
if (e->data.fd == socksrv)
else if (e->events == epollin)
else
}io_submit(ioctx, i, io_submit_arr);
//此處一定要加鎖。當wait還未準備好，但_isfinish剛剛檢測完時_thread_unfinish -= 1;cv2.notify_all();這兩句恰巧在之後執行，那就gg了，兩邊進入互相等待的狀態
lock4cv2.lock();
_thread_unfinish -= 1;
cv2.notify_all();
lock4cv2.unlock();
}else
io_submit(ioctx4write, i, io_submit_arr2);
}num -= r;}}
}threadevents[i].events = 0;
}	}}void* createserv(void* args) 
_epfd = epoll_create(recv_events);
ev[0].data.fd = socksrv;
ev[0].events = epollin | epollet;
epoll_ctl(_epfd, epoll_ctl_add, socksrv, &ev[0]);
//accept loop
while (true) 
while (true) 
fcntl(s, f_setfl, o_nonblock | o_direct);
client* c = new client;
posix_memalign((void**)&c->recvbuf, getpagesize(), buf_recv_len);
posix_memalign((void**)&c->sendbuf, getpagesize(), buf_send_len);
c->id = id;
c->fd = s;
id += 1;
_sockmap.insert(pair(s, c));
ev[0].data.fd = s;
ev[0].events = epollin | epollet;
epoll_ctl(_epfd, epoll_ctl_add, s, &ev[0]);
}		_thread_unfinish = _thread_count;
for (int i = 0; il(lock4cv2);
cv2.wait(l, _isfinish);
for (auto iter = _removelist.begin(); iter != _removelist.end(); ++iter)
_removelist.clear();
}}

C SOCKET通訊模型（七）非同步epoll

高效通訊模型之非同步通訊模型

C SOCKET通訊模型（一）select

C SOCKET通訊模型（四）IOCP

C SOCKET通訊模型（七）非同步epoll

高效通訊模型之 非同步通訊模型

C SOCKET通訊模型（一）select

C SOCKET通訊模型（四）IOCP

相關推薦

高效通訊模型之非同步通訊模型