ffmpeg работа в несколькими rtsp потоками в одной программе

//   https://web-answers.ru/c/opencv-zapisat-vyvod-veb-kamery-v-fajl-avi.html
#include "stdafx.h"
#include "opencv2/opencv.hpp"
#include <iostream>
            #include <string>
              #include <sstream>
#include <time.h>// Вывод системного времяни на кадр
//------------------
#include <vector>
#include <thread>
//------------------
#include <ctime>// Высокоточный отсчёт времяни
#include <ratio>
#include <chrono>
//------------------
#include <windows.h>
#include <conio.h>
 
#include <mmsystem.h>// Звук PlaySound
#pragma comment(lib, "winmm")// Звук
 
using namespace std;
using namespace cv;
using namespace std::chrono;
 
#define AREA_MIN_SIXE 1800
#define AREA_MAX_SIZE 100000000
//---------------
#define KEYDOWN(vk_code)\
    ((GetAsyncKeyState(vk_code) & 0x8000) ? 1 : 0)
#define KEYUP(vk_code) \
    ((GetAsyncKeyState(vk_code) & 0x8000) ? 0 : 1)
 
char put_time[10];// <---- Вывод на экран часов
 
int trashHold(22), trashHold1(22), trashHold2(22);// < ------------ Чувствительность 22
//bool writeDiff = false;//<----------- Не понял зачем
 
/*=======================================
Программа делает столько потоков, обрабатывающих камеры,
сколько USB камер воткнуто в компьютер.
На каждую камеру пишет отдельный файл на диске <D:>
При обнаруженном движении перед камерой.
======================================= */
void myTrackbarCallback(int pos){
    trashHold = pos;//    Только меняет значение переменной порога intruderAlarm
}
void myTrackbarCallback1(int pos){
    trashHold1 = pos;//    Только меняет значение переменной порога intruderAlarm
}
void myTrackbarCallback2(int pos){
    trashHold2 = pos;//    Только меняет значение переменной порога intruderAlarm
}
//=======================================
//=======================================
void fork(VideoCapture cap, int number){
 
    int _frames = 15;
    //-------------------------------------------------------800/600 - 15 frames
 
    std::string str_num(""); std::stringstream ss; ss << number; str_num = "(" + ss.str() + ")";
    
        std::string name_wind = "MyVideo" + str_num;
                                  namedWindow(name_wind, CV_WINDOW_AUTOSIZE); //create a window called "MyVideo"
    double dWidth = cap.get(CV_CAP_PROP_FRAME_WIDTH); //get the width of frames of the video
    double dHeight = cap.get(CV_CAP_PROP_FRAME_HEIGHT); //get the height of frames of the video
 
    cout << "Camera <" << number << "> Frame Size = " << dWidth << "x" << dHeight << endl;
 
    Size frameSize(static_cast<int>(dWidth), static_cast<int>(dHeight));
            //initialize the VideoWriter object
    VideoWriter oVideoWriter("D:\\" + name_wind + ".avi", CV_FOURCC('D', 'I', 'V', 'X'), _frames, frameSize, true);
    //  ----  Вот эта штука пишет в консоль данные видеопотока (который будет писать)
    if (!oVideoWriter.isOpened()) //if not initialize the VideoWriter successfully, exit the program
    {
        cout << "ERROR: Failed to VideoWriter" << endl;
        Sleep(700); return;
    }
 
 
 
 
 
    // **************************************************   
        
if (old.data)// --- Первый проход мимо... в old нет данных
        {
if (trashHold < 14 && number == 0){ cvSetTrackbarPos("Sensit", name_wind.c_str(), 14); trashHold = 14; }// ================== Движок ограничить
if (trashHold1 < 14 && number == 1){ cvSetTrackbarPos("Sensit", name_wind.c_str(), 14); trashHold1 = 14; }// ================== Движок ограничить       
if (trashHold2 < 14 && number == 2){ cvSetTrackbarPos("Sensit", name_wind.c_str(), 14); trashHold2 = 14; }// ================== Движок ограничить
    
    //============================================================== Конец определения движения
            t2 = high_resolution_clock::now();
            time_span = duration_cast<duration<double>>(t2 - t1);// Отрезки точного времени
            seconde = floor(time_span.count());//Счёт секунд записи     
            //-----------------------------
            if (seconde <= 10)
            {
                cv::Mat out_frame = frame.clone();
            // Переменная put_time ОБЬЯВЛЕНА ГЛОБАЛЬНО... Если здесь... то вешало при выходе из потока
                
                putText(out_frame, put_time, Point(30, 54), 2, 1.6// размер в дублях
                    , Scalar(28, 242, 52), 2); // Толщина int  
                oVideoWriter.write(out_frame); //writer the frame into the file 
                if (seconde == 10){
                    putText(out_frame, " PAUSE", Point(30, 158), 2, 2.6// размер в дублях
                        , Scalar(28, 28, 170), 2);
                } // Толщина int   Audio_playing_time -
                imshow(name_wind, out_frame); //show the frame in "MyVideo" window
            }
            waitKey(30);
            if (one){// ----------- Один раз поставить движок, после вывода картинки
                int currentPosition(22), currentPosition1(22), currentPosition2(22);//---------------------(чувств.)
                if (number == 0)cvCreateTrackbar("Sensit", name_wind.c_str(), &currentPosition, 100, myTrackbarCallback);
                if (number == 1)cvCreateTrackbar("Sensit", name_wind.c_str(), &currentPosition1, 100, myTrackbarCallback1);
                if (number == 2)cvCreateTrackbar("Sensit", name_wind.c_str(), &currentPosition2, 100, myTrackbarCallback2);
                            one = false;
                    }
                }// if (old.data)
if (counter % 3 == 0) old = frame.clone();// в old данные    
    if (KEYDOWN(VK_ESCAPE)){
            cvDestroyWindow(name_wind.c_str());
            break;
             }  //<====================================
             }          }
 
 
//=======================================
//=======================================
int main(int argc, char** argv)
{   
    //-------------------------------------------------------
    HANDLE out_handle = GetStdHandle(STD_OUTPUT_HANDLE);
    COORD crd = { 56, 6 }; // <--- Сделаем окошко маленькое
    SMALL_RECT src = { 0, 0, crd.X - 1, crd.Y - 1 };
    SetConsoleWindowInfo(out_handle, true, &src);
    SetConsoleScreenBufferSize(out_handle, crd);
 
    // -------------      Меняем режимы камеры
    CvCapture *capture = cvCreateCameraCapture(0);// Если по дефолту 640/ 480 то 30 фреймов
    cvSetCaptureProperty(capture, CV_CAP_PROP_FRAME_WIDTH, 800);// Изменение параметров камеры 1280 - 10 frames
    cvSetCaptureProperty(capture, CV_CAP_PROP_FRAME_HEIGHT, 600); // (разрешения)               720
    cvSetCaptureProperty(capture, CV_CAP_PROP_SATURATION, 40);
    //  CV_CAP_PROP_BRIGHTNESS
    //  CV_CAP_PROP_CONTRAST
//      capture = nullptr;//< ----------- Сначала nullptr
//  delete capture;// ------------ Потом delete
    
//========================================= 
    std::vector <std::thread> th_vec;
    int n(0);
    while (true){
    VideoCapture cap(n); // open the video camera no. 0
        if (cap.isOpened())  // if not success, exit program
            th_vec.push_back(std::thread(fork, cap, n));// Передача параметров через запятую, после fork 
        else { cout << "ERROR:  camera <"<< n <<"> not found" << endl; break; }// Если камер нет n останеться нулём
                Sleep(2000); ++n;
             }
    // while (1){ if (KEYDOWN(VK_ESCAPE))break; Sleep(50); }
    for (int i = 0; i < n; ++i){// при выходе из нулевого потока, подвешивает по очереди остальные
        th_vec.at(i).join();
            }
    //if(!th_vec.empty())   th_vec.at(0).join();
        Sleep(500);
    return 0;
}