refactor atomic queue.

lichao

2021-05-06 9eb924f64a56918536d310dd89698aa7e148c727

 utest/api_test.cpp

@@ -118,6 +118,8 @@

   printf("maxsec: %ld\n", CountSeconds(max_time));

   // BHCleanup();
   // return;
   bool reg = false;
   for (int i = 0; i < 3 && !reg; ++i) {
      ProcInfo proc;
@@ -149,7 +151,7 @@
      bool r = BHRegisterTopics(s.data(), s.size(), &reply, &reply_len, 1000);
      BHFree(reply, reply_len);
      // printf("register topic : %s\n", r ? "ok" : "failed");
      Sleep(1s);
      // Sleep(1s);
   }

   { // Subscribe