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