| | |
| | | #include "usg_common.h" |
| | | #include "usg_typedef.h" |
| | | #include "lock_free_queue.h" |
| | | #include "queue_factory.h" |
| | | #include "shm_queue.h" |
| | | #include "shm_allocator.h" |
| | | #include <sstream> |
| | | //#include "queue_factory.h" |
| | | #include <pthread.h> |
| | | |
| | | #include "mm.h" |
| | | |
| | | struct Item |
| | | { |
| | |
| | | |
| | | }; |
| | | |
| | | |
| | | // typedef shmstring item_t; |
| | | typedef int item_t; |
| | | struct Targ { |
| | | int key; |
| | | int start; |
| | |
| | | // //queue->~LockFreeQueue(); |
| | | // delete queue; |
| | | |
| | | QueueFactory::dropQueue<struct Item>(key); |
| | | mm_destroy(); |
| | | //QueueFactory::dropQueue<struct Item>(key); |
| | | // mm_destroy(); |
| | | |
| | | |
| | | } |