From 88eda4c0c73d09dee323d8e0b6a0c9287464beff Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期一, 25 五月 2020 10:33:54 +0800
Subject: [PATCH] 修改productor.c 一个循环判断逻辑
---
test/productor.c | 4 ++--
test/consumer | 0
test/consumer.c | 4 ++--
test/productor | 0
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/test/consumer b/test/consumer
index 2cfb5eb..5474419 100755
--- a/test/consumer
+++ b/test/consumer
Binary files differ
diff --git a/test/consumer.c b/test/consumer.c
index 2ea6051..b755878 100644
--- a/test/consumer.c
+++ b/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)) {
diff --git a/test/productor b/test/productor
index 79cc429..a60f6db 100755
--- a/test/productor
+++ b/test/productor
Binary files differ
diff --git a/test/productor.c b/test/productor.c
index 655dac7..d60f4c8 100644
--- a/test/productor.c
+++ b/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;
--
Gitblit v1.8.0