From e1e97f1f98baf82efcd5825d7c7a7b4b1b2f2e40 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期一, 13 七月 2020 19:03:21 +0800
Subject: [PATCH] udpate
---
test/test_queue.c | 49 ++++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 42 insertions(+), 7 deletions(-)
diff --git a/test/test_queue.c b/test/test_queue.c
index cb6ade7..3ae812a 100644
--- a/test/test_queue.c
+++ b/test/test_queue.c
@@ -20,13 +20,13 @@
}
}
- for(i = 0; i < qsize; i++) {
+ // for(i = 0; i < qsize; i++) {
- //queue.dequeue(item);
+ // //queue.dequeue(item);
- item = (*queue)[i];
- cout << "i=" << i << " item " << item.pic << "," << item.info << endl;
- }
+ // item = (*queue)[i];
+ // cout << "i=" << i << " item " << item.pic << "," << item.info << endl;
+ // }
@@ -84,9 +84,44 @@
}
-int main () {
- testString();
+// void testArr(unsigned size) {
+// unsigned int i = 0;
+// int key = 2;
+// char item[size];
+
+// size_t qsize = 16;
+// //LockFreeQueue<struct Item> *queue = QueueFactory::createQueue<struct Item> (key, qsize);
+// SHMQueue<char[size]> *queue = new SHMQueue<char[size]>(key, 16);
+// // LockFreeQueue<struct Item> queue(16);
+// for(i = 0; i < qsize; i++) {
+// sprintf(item, "%d hello", i);
+// if(queue->push(item)) {
+// cout << i << " push锛�" << item << endl;
+// }
+// }
+
+
+
+
+
+// struct timespec timeout = {1, 0};
+
+// i = 0;
+// while((queue->pop_timeout(item, &timeout)) ) {
+// cout << i << " pop锛�" << item << endl;
+// // cout << item.pic << endl;
+// i++;
+// }
+
+// delete queue;
+// }
+
+
+int main () {
+ mm_init(512);
+ // testArr(12);
+ testStruct();
mm_destroy();
return 0;
--
Gitblit v1.8.0