wangzhengquan
2020-07-20 af100db4697a85522893ebbffbf2de2741988265
test/single_productor.c
@@ -10,7 +10,9 @@
}
int main(int argc, char *argv[])
{
{
  string line;
  signal(SIGINT,  sigint_handler);
  int qsize = 16;
@@ -25,6 +27,8 @@
    start = atoi(argv[1]);
    end = atoi(argv[2]);
  }
  mm_init(512);
  //LockFreeQueue<item_t> *queue = QueueFactory::createQueue<item_t> (key, qsize);
  SHMQueue<item_t> *queue = new SHMQueue<item_t>(key, qsize);
  
@@ -47,8 +51,9 @@
      //cout << "入队:" << item << endl;
       LoggerFactory::getLogger().error("%d", i);
      // err_msg(0, "%d", i);
    else
    else {
      break;
    }
   // cout <<  item.pic << endl;
    i++;