| | |
|---|
| | | #include "usg_common.h" |
|---|
| | | #include "usg_typedef.h" |
|---|
| | | #include "SArrayLockFreeQueue.h" |
|---|
| | | #include "lock_free_queue.h" |
|---|
| | | #include "SLinkedLockFreeQueue.h" |
|---|
| | | #include "QFactory.h" |
|---|
| | | #include "queue_factory.h" |
|---|
| | | #include <pthread.h> |
|---|
| | | |
|---|
| | | #define NTHREADS 3 |
|---|
| | |
|---|
| | | // 销毁共享内存和信号 |
|---|
| | | void destroy() { |
|---|
| | | |
|---|
| | | SLinkedLockFreeQueue<struct Item> *queue = QFactory::createLinkedLockFreeQueue<struct Item> (1, 10); |
|---|
| | | queue->~SLinkedLockFreeQueue(); |
|---|
| | | LockFreeQueue<struct Item> *queue = QueueFactory::createQueue<struct Item> (1, 16); |
|---|
| | | //queue->~LockFreeQueue(); |
|---|
| | | delete queue; |
|---|
| | | mm_deinit(); |
|---|
| | | |
|---|
| | | |
|---|
