update

wangzhengquan

2020-07-06 302ae4427b04a25e4f1ee8acadbb05bf902f47f7

 test/test_queue.c

@@ -1,39 +1,38 @@
#include "test.h"
using namespace std;

int main () {
   unsigned int i = 0;
   struct Item
   {
      int pic;
      int info;
   };
	
    

   struct Item item;

   size_t qsize = 10;
     SArrayLockFreeQueue<struct Item> *queue = QFactory::createArrayLockFreeQueue<struct Item> (1, qsize);
   size_t qsize = 1;
     LockFreeQueue<struct Item> *queue = QueueFactory::createQueue<struct Item> (2, qsize);

	
   // LockFreeQueue<struct Item> queue(16);
   for(i = 0; i < qsize; i++) {

      queue->add({i, i});
      if(queue->push({i, i})) {
          cout << i << " push：" << i << endl;
      }
   }

   for(i = 0; i < qsize; i++) {
   // for(i = 0; i < qsize; i++) {
      
      //queue->dequeue(item);
   //    //queue.dequeue(item);
      
      item = (*queue)[i];
      cout << "i=" << i << " item " << item.pic << "," << item.info << endl;
   }
   //    item = (*queue)[i];
   //    cout << "i=" << i << " item " << item.pic << "," << item.info << endl;
   // }


    
   struct timespec timeout = {5, 0};

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