refactor center; add async request no cb.

lichao

2021-04-02 83085f2ce99cca05d40a19482151873a55e6393a

 src/socket.cpp

@@ -49,7 +49,7 @@
   Stop(); //TODO should stop in sub class, incase thread access sub class data.
}

bool ShmSocket::StartRaw(const RecvRawCB &onData, int nworker)
bool ShmSocket::Start(const RecvCB &onData, int nworker)
{
   if (!mq_) {
      return false;
@@ -62,7 +62,12 @@
         try {
            MsgI imsg;
            DEFER1(imsg.Release(shm_));
            if (mq_->Recv(imsg, 100)) { onData(imsg); }
            if (mq_->Recv(imsg, 100)) {
               BHMsg msg;
               if (imsg.Unpack(msg)) {
                  onData(*this, imsg, msg);
               }
            }
         } catch (...) {
         }
      }
@@ -73,11 +78,6 @@
      workers_.emplace_back(RecvProc);
   }
   return true;
}

bool ShmSocket::Start(const RecvCB &onData, int nworker)
{
   return StartRaw([this, onData](MsgI &imsg) { BHMsg m; if (imsg.Unpack(m)) { onData(m); } }, nworker);
}

bool ShmSocket::Stop()