From 302ae4427b04a25e4f1ee8acadbb05bf902f47f7 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期一, 06 七月 2020 19:09:58 +0800
Subject: [PATCH] update
---
test/test_queue.c | 29 ++++++++++++++---------------
1 files changed, 14 insertions(+), 15 deletions(-)
diff --git a/test/test_queue.c b/test/test_queue.c
index 26c4dfa..6046902 100644
--- a/test/test_queue.c
+++ b/test/test_queue.c
@@ -1,39 +1,38 @@
#include "test.h"
using namespace std;
+
int main () {
unsigned int i = 0;
- struct Item
- {
- int pic;
- int info;
- };
+
struct Item item;
- size_t qsize = 10;
- SArrayLockFreeQueue<struct Item> *queue = QFactory::createArrayLockFreeQueue<struct Item> (1, qsize);
+ size_t qsize = 1;
+ LockFreeQueue<struct Item> *queue = QueueFactory::createQueue<struct Item> (2, qsize);
-
+ // LockFreeQueue<struct Item> queue(16);
for(i = 0; i < qsize; i++) {
- queue->add({i, i});
+ if(queue->push({i, i})) {
+ cout << i << " push锛�" << i << endl;
+ }
}
- 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;
+ // }
struct timespec timeout = {5, 0};
i = 0;
- while((queue->remove_timeout(item, &timeout)) ) {
+ while((queue->pop(item)) ) {
cout << i << " 鍑洪槦锛�" << item.pic << ", " << item.info << endl;
// cout << item.pic << endl;
--
Gitblit v1.8.0