#include "test.h" using namespace std; int main () { unsigned int i = 0; int key = 2; struct Item item; size_t qsize = 16; LockFreeQueue *queue = QueueFactory::createQueue (key, qsize); // LockFreeQueue queue(16); for(i = 0; i < qsize; i++) { if(queue->push({i, i})) { cout << i << " push:" << i << endl; } } // for(i = 0; i < qsize; i++) { // //queue.dequeue(item); // item = (*queue)[i]; // cout << "i=" << i << " item " << item.pic << "," << item.info << endl; // } struct timespec timeout = {5, 0}; i = 0; while((queue->pop(item)) ) { cout << i << " pop:" << item.pic << ", " << item.info << endl; // cout << item.pic << endl; i++; } destroy(key); }