c_cpp 多线程

Posted 2021-05-14

#include "pch.h"
#include "fps_stats.hpp"
#include <opencv2/opencv.hpp>
#include <string>
#include <list>
#include <thread>


std::list<cv::Mat> frames;
cv::VideoCapture cap;
bool isRun;

// thread function for video getting and show
void StreamThread(bool &isRun)
{
	cv::Mat image;
	while (isRun) {
		cap >> image;
		frames.push_back(image.clone());
	}
}


int main(int, char)
{
	cap.open(0);

	//open check
	if (!cap.isOpened()) {
		std::cerr << "Stream open failed : " << std::endl;
		return 1;
	}

	isRun = true;
	// thread run
	std::thread t1(&StreamThread, std::ref(isRun));

	fps_stats fps{ "Video" };

	//Mat draw only in the main function.
	while (isRun) {

		if (frames.size() > 1) {

			cv::Mat image = frames.front();
			cv::imshow("test", image);
			frames.pop_front();

			if (cv::waitKey(30) >= 0)
				break;
			fps.tick();
		}
	}

	if (t1.joinable()) {
		isRun = false;
		t1.join();
	}

	return 0;
}