修改productor.c 一个循环判断逻辑

wangzhengquan

2020-05-25 88eda4c0c73d09dee323d8e0b6a0c9287464beff

修改productor.c 一个循环判断逻辑

 test/consumer

Binary files differ

 test/consumer.c

@@ -20,12 +20,12 @@
  int first = mm_init(sizeof(SQueue<struct Item>), &shmp);
  
  if (first == 1)
    queue = new(shmp) SQueue<struct Item>;
    queue = new(shmp) SQueue<struct Item>(1);
  else
    queue = (SQueue<struct Item> *) shmp;
  /* Transfer blocks of data from shared memory to stdout */
   
  struct timespec timeout = {5, 0};
  struct timespec timeout = {10, 0};
  struct Item item;
  while(queue->dequeue_timeout(item, &timeout)) {
    

 test/productor

Binary files differ

 test/productor.c

@@ -31,7 +31,7 @@
  int first = mm_init(sizeof(SQueue<struct Item>), &shmp);
  
  if (first == 1)
    queue = new(shmp) SQueue<struct Item>(20);
    queue = new(shmp) SQueue<struct Item>(1);
  else
    queue = (SQueue<struct Item> *) shmp;

@@ -41,7 +41,7 @@
  int i = start;
  item.pic = i;
  item.info = i;
  while((end != -1) && (i < end) && (queue->enqueue_timeout(item, &timeout)) ) {
  while((end == -1 || (i < end) ) && (queue->enqueue_timeout(item, &timeout)) ) {
    item.pic = i;
    item.info = i;