多线程以rtsp流调用多路海康摄像头的思考

#include <opencv2/opencv.hpp>
#include <opencv2/imgproc.hpp>
#include <opencv2/highgui.hpp>
#include <pthread.h>
#include <windows.h>  
#include <iostream>
#include <stdio.h>  

using namespace cv;


DWORD GetThreadAffinityMask()
{    
    DWORD mask = 1;
     DWORD old = 0;

    // try every CPU one by one until one works or none are left 
    while (mask)
    {
        old = SetThreadAffinityMask(GetCurrentThread(), mask);
        if (old)
        { // this one worked 
            SetThreadAffinityMask(GetCurrentThread(), old); // restore original 
            return old;
        }
        else
        {
            if (GetLastError() != ERROR_INVALID_PARAMETER)
                return 0; // fatal error, might as well throw an exception 
        }
        mask <<= 1;
    }

    return 0;
}

void* video_thread(void* arg)
{
    std::string* str = (std::string*)arg;
    VideoCapture cap;
    cap.open(*str);
    if (!cap.isOpened())
    {
        return NULL;
    }
    while (1)
    {
        clock_t st = clock();
        Mat img;
        cap >> img;
        if (img.empty())
        {
            break;
        }
        std::cout<<*str << " " << GetThreadAffinityMask()<<"time:"<<clock()-st<<std::endl;
        imshow(*str,img);
        cv::waitKey(1);
    }

    return NULL;
}

int main()
{
    pthread_t th1,th2,th3;
    std::string str1("C:\\Users\\lvdon\\Desktop\\other\\lane_video\\1.avi");
    std::string str2("C:\\Users\\lvdon\\Desktop\\other\\lane_video\\2.avi");
    std::string str3("C:\\Users\\lvdon\\Desktop\\other\\lane_video\\3.avi");
    pthread_create(&th1,NULL, video_thread,&str1);
    pthread_create(&th1, NULL, video_thread, &str2);
    pthread_create(&th1, NULL, video_thread, &str3);

    while (1)
    {
        ;
    }
}