Method PrepareWait

phxqueue/producer/batchhelper.cpp:54–57

};

void Task::PrepareWait() {
    if (nullptr != notifier_) return;
    notifier_ = move(comm::NotifierPool::GetInstance()->Get());
}

comm::RetCode Task::Wait() {
    if (nullptr == notifier_) return comm::RetCode::RET_ERR_NOTIFIER_MISS;