来讨论一个小问题，异步编程是否都需要加超时判断呢

yulihua49

cokeboL 发表于 2017-07-25 22:16
回复 8# wlmqgzm

定时器用小堆+epoll之类的wait的超时时间来做，性能是最优的nginx，还有高版本的libev ...

小堆是啥？怎么弄，介绍下。

lxyscls

回复 11# yulihua49

min heap，你被方言给糊弄了

cokeboL

回复 11# yulihua49

对对对，min heap, 你被我的方言糊弄了

yulihua49

cokeboL 发表于 2017-07-26 10:13
回复 11# yulihua49

对对对，min heap, 你被我的方言糊弄了

介绍下，如何做超时。

cokeboL

回复 14# yulihua49

1. while (worker->running)
   
2. {
   
3.         n = epoll_wait(epfd, events, MAX_EVENTS_PER_EOLL_LOOP, waitTime);
   
4.         for (i = 0; i < n; i++)
   
5.         {
   
6.                 handle io event
   
7.                 worker->reset_conn_alive_timer()
   
8.         }
   
9.         worker->check_timers(); //我通常喜欢把心跳的timer和普通的timer分开，这里包括了检查这两种tiemr，取最小超时时间
   
10.         waitTime = worker->next_timeout();
    
11. }

复制代码

cokeboL

回复 14# yulihua49

我喜欢偷懒，用multimap搞的玩具

1. Timer.Timers是这个 std::multimap<uint64_t, TimerData> Timers;
   
2. 
   
3. 
   
4. uint64_t Time::Now() {
   
5.         struct timeval tv;
   
6.         gettimeofday(&tv, 0);
   
7.         return uint64_t(tv.tv_sec) * 1000 + uint64_t(tv.tv_usec / 1000);
   
8. }
   
9. 
   
10. uint64_t Time::After(uint64_t now, uint64_t after) {
    
11.         assert(after > 0);
    
12.         if (!now) {
    
13.                 return Time::Now() + after;
    
14.         }
    
15.         return now + after;
    
16. }
    
17. 
    
18. 
    
19. TimerID Timer::NewTimer(uint64_t timeout, TimerCallback callback, void *data, uint64_t now) {
    
20.         TimerData timerdata(callback, data);
    
21.         uint64_t expire = Time::After(now, timeout);
    
22.         TimerID timerid = this->Timers.insert(std::make_pair(expire, timerdata));
    
23.         return timerid;
    
24. }
    
25. 
    
26. void Timer::DeleteTimer(TimerID timerid) {
    
27.         this->Timers.erase(timerid);
    
28.         
    
29. }
    
30. 
    
31. uint64_t Timer::NextTimeout(uint64_t now) {
    
32.         
    
33.         if (this->Timers.empty()) {
    
34.                 return WAIT_FOREVER;
    
35.         }
    
36.         if (!now) {
    
37.                 now = Time::Now();
    
38.         }
    
39. 
    
40.         if (this->Timers.begin()->first <= now){
    
41.                 return 0;
    
42.         }
    
43.         return this->Timers.begin()->first - now;
    
44. }
    
45. 
    
46. void Timer::CheckTimers(uint64_t now) {
    
47.         if (!now) {
    
48.                 now = Time::Now();
    
49.         }
    
50.         for (TimerID it = this->Timers.begin(); it != this->Timers.end(); ) {
    
51.                 if (it->first <= now) {
    
52.                         TimerCallback callback = it->second.Callback;
    
53.                         void *data = it->second.Data;
    
54.                         it++;
    
55.                         //this->Timers.erase(it++);
    
56.                         callback(data);
    
57.                 }
    
58.                 else {
    
59.                         break;
    
60.                 }
    
61.         }
    
62. 
    
63.         for (TimerID it = this->Timers.begin(); it != this->Timers.end();) {
    
64.                 if (it->first <= now) {
    
65.                         this->Timers.erase(it++);
    
66.                 }
    
67.                 else {
    
68.                         break;
    
69.                 }
    
70.         }
    
71. 
    
72.         size_t n = this->Timers.size();
    
73. }
    
74. 
    
75. void Timer::Clear() {
    
76.         this->Timers.clear();
    
77. }
    

复制代码

cokeboL

回复 14# yulihua49

换成小堆的性能会更好点，不过multimap也足够了，增删性能 百万次/s 以上

cokeboL

回复 14# yulihua49

golang里最爽了，golang里我最早用小堆实现了timer，后来发现golang标准库里，time.AfterFunc就搞定了，而且会自动判断回调里是否阻塞、循环之类的，从而底层只是执行一次或者单开一个协程，完全不需要自己再浪费
体力