libuv地址

https://github.com/libuv/libuv

前言：

libuv提供了高精度定时器实现，当前版本（v1.x）有两种方案定时器实现方案，unix平台代码是基于最小堆，而win平台代码基于rbtree，均具备高效的插入、删除、执行效率。

源码：

初始化

int uv_timer_init(uv_loop_t* loop, uv_timer_t* handle)

插入

int uv_timer_start(uv_timer_t* handle,

uv_timer_cb cb,

uint64_t timeout,

uint64_t repeat)

删除

int uv_timer_stop(uv_timer_t* handle)

执行序列

unix和win实现不一样

src/unix/timer.c

uv_run

uv__update_time

uv__run_timers

void uv__run_timers(uv_loop_t* loop) {
  struct heap_node* heap_node;
  uv_timer_t* handle;

  for (;;) {
    heap_node = heap_min((struct heap*) &loop->timer_heap);
    if (heap_node == NULL)
      break;

    handle = container_of(heap_node, uv_timer_t, heap_node);
    if (handle->timeout > loop->time)
      break;

    uv_timer_stop(handle);
    uv_timer_again(handle);
    handle->timer_cb(handle);
  }
}

从源码可以看出该定时器数据结构是基于heap的，因为不需要完全排序，所以相对于rbtree来讲更高效

win src/win/timer.c

uv_run

uv_update_time

uv_process_timers

void uv_process_timers(uv_loop_t* loop) {
  uv_timer_t* timer;

  /* Call timer callbacks */
  for (timer = RB_MIN(uv_timer_tree_s, &loop->timers);
       timer != NULL && timer->due <= loop->time;
       timer = RB_MIN(uv_timer_tree_s, &loop->timers)) {

    uv_timer_stop(timer);
    uv_timer_again(timer);
    timer->timer_cb((uv_timer_t*) timer);
  }
}

可以看出使用了rbtree。

分析

这两种方案均基于排序树实现，通过uv_run扫描树，扫描时取出最小时间戳的节点，取出，执行回调，循环这个过程，直至取出的最小时间戳大于当前时间戳。

这两种方案实现非常简单，就算不引入libuv，相信您也可以轻松写出来。如果可以使用stl就更方便了。

下面的伪代码，看起来是不是很easy呢

// 伪代码
struct TIMER{
  timer_id
  cb
  first_call_time
  repeat_count
  repeat_interval
  private_data
  ...
}
map<uint64_t , TIMER>  timer_manager
// 轮询逻辑
  for(auto it = timer_manager.begin(); it != map.end(); it = map.begin()){
    if(it.first > cur)break;
    TIMER& timer = it.second;
    timer.cb();
    map.erase(it);
  }