c++多线程队列

多线程中，使用队列不需要锁也能运行，取得时候先判断一下长度，长度为0线Sleep(3)。

  

   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      struct RevData{
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      int size;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      char data[1000];
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      } recv_data;
     
    
   

    

     

    
    

     

       
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #include <iostream>
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #include <queue>
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #include<map>
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #include <string>
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #include <mutex>
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      //#include <Windows.h>
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

       
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      using namespace std;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      queue<RevData*> queue1;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      queue<RevData*>* queue2;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      //queue2 = (queue<RevData*>*)malloc(sizeof(queue<RevData*>));
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

       
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      for (int i = 0; i < 10; i++) {
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      RevData recvD;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      recvD.size = i;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      strcpy(recvD.data, "hello");
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      RevData* recvp = (RevData*)malloc(sizeof(RevData));
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      memcpy(recvp, &recvD, sizeof(RevData));
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      queue1.push(recvp);// recvp);
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      //queue1.push(&recvD);
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      }
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

       
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      queue2 = &queue1;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      for (int i = 0; i < 10; i++) {
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      RevData* recv = queue2->front();
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      cout << (*recv).data << endl;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

       
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      int lenga = queue2->size();
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      queue2->pop();
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      int lenga2 = queue2->size();
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      cout << (*recv).size << endl;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      }
     
    
  
 

例子：

struct RevData {

    int cam_id;

    cv::Mat  image;

} recv_data;

线程调用：

thread video_thread1(bind(&play_url, v_url));
    thread video_thread2(bind(&detect_thread));

    video_thread1.join();

int play_url(char* url){

}

get队列：

  

   

    

     

    
    

     

      while (1) {
     
    
   

    

     

    
    

     

      		cv::Mat origin_image;//定义一个变量把视频源一帧一帧显示
     
    
   

    

     

    
    

     
		//capture >> origin_image;
     
    
   

    

     

    
    

     
		//if (origin_image.empty())
     
    
   

    

     

    
    

     
		//{
     
    
   

    

     

    
    

     
		// std::cout << "no video frame" << std::endl;
     
    
   

    

     

    
    

     
		// break;
     
    
   

    

     

    
    

     
		//}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
		bool is_get = FALSE;
     
    
   

    

     

    
    

     
		//EnterCriticalSection(&g_cs);
     
    
   

    

     

    
    

     
		if (queue1.size() > 0) {
     
    
   

    

     

    
    

     

      			RevData recv = queue1.front();
     
    
   

    

     

    
    

     

      			queue1.pop();
     
    
   

    

     

    
    

     

      			is_get = TRUE;
     
    
   

    

     

    
    

     

      			origin_image = (recv).image;
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     
		else {
     
    
   

    

     

    
    

     
			//Sleep(3);
     
    
   

    

     

    
    

     
			continue;
     
    
   

    

     

    
    

     

      		}
     
    
  
 

c++ 入队列：

  

   

    

     

    
    

     

      	start_time = GetTickCount();
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

       sws_scale(img_convert_ctx, pFrameYUV->data, pFrameYUV->linesize, 0, avCodecCtx->height, pFrameRGB->data, pFrameRGB->linesize);
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 cv::Mat mat(avCodecCtx->height, avCodecCtx->width, CV_8UC3, pFrameRGB->data[0], pFrameRGB->linesize[0]);
     
    
   

    

     

    
    

     

       cv::imshow("", mat);//图像显示
     
    
   

    

     

    
    

     

       cv::waitKey(1);
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

       RevData recvD;
     
    
   

    

     

    
    

     

       frame_index++;
     
    
   

    

     

    
    

     

       recvD.cam_id = i;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

       recvD.image = mat.clone();
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 //RevData* recvp = (RevData*)malloc(sizeof(RevData));
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 //memcpy(recvp, &mat, sizeof(RevData));
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 //EnterCriticalSection(&g_cs);
     
    
   

    

     

    
    

     
 if (frame_index%2==0) {
     
    
   

    

     

    
    

     

       queue1.push(recvD);
     
    
   

    

     

    
    

     

       }
     
    
  
 

文章来源: blog.csdn.net，作者：网奇，版权归原作者所有，如需转载，请联系作者。

原文链接：blog.csdn.net/jacke121/article/details/89893403