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);