LoopThread()

: loop_(uv_loop_new()) {}

virtual ~LoopThread() { uv_loop_delete(loop_); }

void run() { uv_thread_create(&thread_, on_run_internal, this); }

void join() { uv_thread_join(&thread_); }

uv_loop_t* loop() { return loop_; }

virtual void on_run() {}

virtual void on_after_run() {}

void static on_run_internal(void* data) {

LoopThread* thread = static_cast<LoopThread*>(data);

thread->on_run();

uv_run(thread->loop_, UV_RUN_DEFAULT);

thread->on_after_run();

}

uv_loop_t* loop_;

uv_thread_t thread_;