Method notify

src/system/executor.h:30–30

wake up the processing thread

  // wake up the processing thread
  void notify() { Lock l(recved_msg_mu_); dag_cond_.notify_one(); }

  // mark this message as finshed in executor
  void finish(const MessagePtr& msg);