From 5854093bd0622c03576e7a29205d68bbdc264f62 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期四, 09 七月 2020 16:10:20 +0800
Subject: [PATCH] void queue wrapper
---
test2/test_queue_wrapper.c | 9 ++++-----
1 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/test2/test_queue_wrapper.c b/test2/test_queue_wrapper.c
index ae242a4..a5020a7 100644
--- a/test2/test_queue_wrapper.c
+++ b/test2/test_queue_wrapper.c
@@ -13,14 +13,13 @@
int key = 2;
size_t qsize = 16;
- shmqueue_t queue;
- shmqueue_init(&queue, key, qsize, sizeof(message_t));
+ void * queue = shmqueue_init( key, qsize, sizeof(message_t));
message_t item;
// LockFreeQueue<struct Item> queue(16);
for(i = 0; i < qsize; i++) {
sprintf(item.method, "hello");
item.code = i ;
- if(shmqueue_push(&queue, (void *)&item)) {
+ if(shmqueue_push(queue, (void *)&item)) {
printf("push:%d %s\n", item.code, item.method );
}
}
@@ -28,14 +27,14 @@
struct timespec timeout = {1, 0};
i = 0;
- while((shmqueue_pop_timeout(&queue, (void *)&item, &timeout)) ) {
+ while((shmqueue_pop_timeout(queue, (void *)&item, &timeout)) ) {
printf("pop:%d %s\n", item.code, item.method );
// cout << item.pic << endl;
i++;
}
//閿�姣侀槦鍒�
- shmqueue_destroy(&queue);
+ shmqueue_destroy(queue);
}
--
Gitblit v1.8.0