From f75a37444e7a97fb58439077eea4d1b3c576bfe3 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期一, 20 七月 2020 11:17:33 +0800 Subject: [PATCH] update --- test/test.h | 26 ++++++++++++++++---------- 1 files changed, 16 insertions(+), 10 deletions(-) diff --git a/test/test.h b/test/test.h index b5e0a01..25a3215 100644 --- a/test/test.h +++ b/test/test.h @@ -1,11 +1,11 @@ #include "usg_common.h" #include "usg_typedef.h" -#include "SArrayLockFreeQueue.h" -#include "SLinkedLockFreeQueue.h" -#include "QFactory.h" - #include <pthread.h> - -#define NTHREADS 3 +#include "shm_queue.h" +#include "shm_allocator.h" +#include <sstream> +//#include "queue_factory.h" +#include <pthread.h> +#include "mm.h" struct Item { @@ -14,6 +14,9 @@ }; + +// typedef shmstring item_t; +typedef int item_t; struct Targ { int key; int start; @@ -21,11 +24,14 @@ }; // 閿�姣佸叡浜唴瀛樺拰淇″彿 -void destroy() { +void destroy(int key) { - SLinkedLockFreeQueue<struct Item> *queue = QFactory::createLinkedLockFreeQueue<struct Item> (1, 10); - queue->~SLinkedLockFreeQueue(); - mm_deinit(); + // LockFreeQueue<struct Item> *queue = QueueFactory::createQueue<struct Item> (1, 16); + // //queue->~LockFreeQueue(); + // delete queue; + + //QueueFactory::dropQueue<struct Item>(key); + // mm_destroy(); } -- Gitblit v1.8.0