update

wangzhengquan

2020-07-20 af100db4697a85522893ebbffbf2de2741988265

 test/single_productor.c

@@ -10,10 +10,13 @@
}

int main(int argc, char *argv[])
{ 
{


  string line;
  signal(SIGINT,  sigint_handler);
  int qsize = 16;
 
 
  /* Create set containing two semaphores; initialize so that
     writer has first access to shared memory. */
@@ -24,30 +27,41 @@
    start = atoi(argv[1]);
    end = atoi(argv[2]);
  }
  //LockFreeQueue<struct Item> *queue = QueueFactory::createQueue<struct Item> (key, qsize);
  SHMQueue<struct Item> *queue = new SHMQueue<struct Item>(key, qsize);

  mm_init(512);
  //LockFreeQueue<item_t> *queue = QueueFactory::createQueue<item_t> (key, qsize);
  SHMQueue<item_t> *queue = new SHMQueue<item_t>(key, qsize);
  

  /* Transfer blocks of data from stdin to shared memory */
  struct Item item;
  struct timespec timeout = {5, 0};
  //item_t item;
  //char item[1024];
  item_t item;
  struct timespec timeout = {10, 0};
  int i = start;
  item.pic = i;
  item.info = i;
  //while((end == -1 || (i < end) ) && (queue->add(item)) ) {
  while(!stop && (queue->push(item)) ) {
    item.pic = i;
    item.info = i;

    cout << "入队：" << item.pic << ", " << item.info << endl;
  // item.pic = i;
  // item.info = i;
  while(!stop && (end == -1 || (i < end) ) ) {
  //while(!stop ) {
    // item.pic = i;
    // item.info = i;
    //item = i + " aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa";
    //sprintf(item, "(%d)aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa", i);
    if(queue->push(i))
      //cout << "入队：" << item << endl;
       LoggerFactory::getLogger().error("%d", i);
      // err_msg(0, "%d", i);
    else {
      break;
    }
   // cout <<  item.pic << endl;

    i++;
    
  }

  delete queue;
  mm_destroy();
  cerr << "productor quit" << endl;
  //delete queue;
  //mm_destroy();
  err_msg(0, "productor quit");
  exit(EXIT_SUCCESS);
}