#include "test.h"
using namespace std;

int main () {
	unsigned int i = 0;
	
	int key = 2;

	struct Item item;

	size_t qsize = 16;
  	//LockFreeQueue<struct Item> *queue = QueueFactory::createQueue<struct Item> (key, qsize);
	SHMQueue<struct Item> *queue = new SHMQueue<struct Item>(key, 16);
	// LockFreeQueue<struct Item> 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 = {1, 0};

	i = 0;
	while((queue->pop_timeout(item, &timeout)) ) {
	    cout << i << " pop：" << item.pic << ", " << item.info << endl;
	   // cout <<  item.pic << endl;
	    i++;
	}

	delete queue;
	mm_destroy();

}