devbox
小桥流水78
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

C# VideoCapture 多路视频播放

作者：小桥流水78 | 2024-08-20 06:30:42

赞

踩

C# VideoCapture 多路视频播放

目录

效果

项目 

代码

下载

效果

C#VideoCapture多路视频播放

项目 

代码

using OpenCvSharp;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Diagnostics;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

namespace MultiVideoDemo
{
    public partial class Form4 : Form
    {
        public Form4()
        {
            InitializeComponent();
        }

        CancellationTokenSource ctsShow;
        CancellationTokenSource[] taskCTS = new CancellationTokenSource[6];
        ConcurrentQueue<Mat>[] matQueue = new ConcurrentQueue<Mat>[6];
        int fps = 25;
        string[] rtsp_url = new string[40];
        List<RTSPURLInfo> play_rtsp_url = new List<RTSPURLInfo>();

        /// <summary>
        /// 停止
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button2_Click(object sender, EventArgs e)
        {
            ctsShow.Cancel();

            for (int i = 0; i < 6; i++)
            {
                taskCTS[i].Cancel();
            }
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            //初始化
            for (int i = 0; i < 6; i++)
            {
                taskCTS[i] = new CancellationTokenSource();
                matQueue[i] = new ConcurrentQueue<Mat>();
            }

            for (int i = 0; i < 40; i++)
            {
                rtsp_url[i] = "1.dav";
            }

            //play_rtsp_url
            for (int i = 0; i < 6; i++)
            {
                play_rtsp_url.Add(new RTSPURLInfo((i + 1).ToString(), rtsp_url[i]));
            }
        }

        /// <summary>
        /// 播放
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button1_Click(object sender, EventArgs e)
        {
            ctsShow = new CancellationTokenSource();

            for (int i = 0; i < 6; i++)
            {
                taskCTS[i] = new CancellationTokenSource();
                matQueue[i] = new ConcurrentQueue<Mat>();
            }

            play_rtsp_url.Clear();
            for (int i = 0; i < 6; i++)
            {
                play_rtsp_url.Add(new RTSPURLInfo((i + 1).ToString(), rtsp_url[i]));
            }

            for (int i = 0; i < play_rtsp_url.Count; i++)
            {
                Task.Run(() => DecodeRTSP(play_rtsp_url[i].index, matQueue[i], play_rtsp_url[i].url, taskCTS[i].Token));
                System.Threading.Thread.Sleep(100);
            }

            //显示线程
            Task.Run(() =>
            {
                Mat mat = new Mat();
                string winName = "video";

                Cv2.NamedWindow(winName, WindowFlags.Normal);
                Cv2.ResizeWindow(winName, fullSize);

                int delay = (int)(1000 / fps);
                Stopwatch stopwatch = new Stopwatch();

                while (true)
                {
                    stopwatch.Restart();
                    delay = (int)(1000 / fps);
                    if (ctsShow.IsCancellationRequested) break;

                    Mat frame = CombiningImages();

                    Cv2.ImShow(winName, frame);

                    delay = (int)(delay - stopwatch.ElapsedMilliseconds);
                    if (delay <= 0)
                    {
                        delay = 1;
                    }
                    Console.WriteLine("delay:" + delay.ToString());
                    Cv2.WaitKey(delay);

                    frame.Dispose();
                }
                Cv2.DestroyAllWindows();
            });
        }

        OpenCvSharp.Size fullSize = new OpenCvSharp.Size(1008, 570);
        OpenCvSharp.Size mainSize = new OpenCvSharp.Size(672, 380);
        OpenCvSharp.Size subSize = new OpenCvSharp.Size(336, 190);

        Mat CombiningImages()
        {
            Console.WriteLine(string.Format("matQueue0:{0},matQueue1:{1},matQueue2:{2},matQueue3:{3},matQueue4:{4},matQueue5:{5}"
                , matQueue[0].Count
                , matQueue[1].Count
                , matQueue[2].Count
                , matQueue[3].Count
                , matQueue[4].Count
                , matQueue[5].Count
                ));

            Mat mat = Mat.Zeros(fullSize, MatType.CV_8UC3);

            Mat mat0 = new Mat();
            matQueue[0].TryDequeue(out mat0);
            if (mat0 == null || mat0.Empty())
            {
                mat0 = Mat.Zeros(mainSize, MatType.CV_8UC3);
            }
            Cv2.Resize(mat0, mat0, mainSize);

            Mat mat1 = new Mat();
            matQueue[1].TryDequeue(out mat1);
            if (mat1 == null || mat1.Empty())
            {
                mat1 = Mat.Zeros(subSize, MatType.CV_8UC3);
            }
            Cv2.Resize(mat1, mat1, subSize);

            Mat mat2 = new Mat();
            matQueue[2].TryDequeue(out mat2);
            if (mat2 == null || mat2.Empty())
            {
                mat2 = Mat.Zeros(subSize, MatType.CV_8UC3);
            }
            Cv2.Resize(mat2, mat2, subSize);

            Mat mat3 = new Mat();
            matQueue[3].TryDequeue(out mat3);
            if (mat3 == null || mat3.Empty())
            {
                mat3 = Mat.Zeros(subSize, MatType.CV_8UC3);
            }
            Cv2.Resize(mat3, mat3, subSize);

            Mat mat4 = new Mat();
            matQueue[4].TryDequeue(out mat4);
            if (mat4 == null || mat4.Empty())
            {
                mat4 = Mat.Zeros(subSize, MatType.CV_8UC3);
            }
            Cv2.Resize(mat4, mat4, subSize);

            Mat mat5 = new Mat();
            matQueue[5].TryDequeue(out mat5);
            if (mat5 == null || mat5.Empty())
            {
                mat5 = Mat.Zeros(subSize, MatType.CV_8UC3);
            }
            Cv2.Resize(mat5, mat5, subSize);

            //第一张主图
            Rect roi0 = new Rect(0, 0, 672, 380);
            Mat position0 = new Mat(mat, roi0);
            mat0.CopyTo(position0);

            //第二张图
            Rect roi1 = new Rect(672, 0, 336, 190);
            Mat position1 = new Mat(mat, roi1);
            mat1.CopyTo(position1);

            //第三张图
            Rect roi2 = new Rect(672, 190, 336, 190);
            Mat position2 = new Mat(mat, roi2);
            mat2.CopyTo(position2);

            //第4张图
            Rect roi3 = new Rect(672, 380, 336, 190);
            Mat position3 = new Mat(mat, roi3);
            mat3.CopyTo(position3);

            //第5张图
            Rect roi4 = new Rect(336, 380, 336, 190);
            Mat position4 = new Mat(mat, roi4);
            mat4.CopyTo(position4);

            //第6张图
            Rect roi5 = new Rect(0, 380, 336, 190);
            Mat position5 = new Mat(mat, roi5);
            mat5.CopyTo(position5);

            mat0.Dispose();
            mat1.Dispose();
            mat2.Dispose();
            mat3.Dispose();
            mat4.Dispose();
            mat5.Dispose();

            position0.Dispose();
            position1.Dispose();
            position2.Dispose();
            position3.Dispose();
            position4.Dispose();
            position5.Dispose();

            return mat;

        }

        void DecodeRTSP(string index, ConcurrentQueue<Mat> matQueue, string url, CancellationToken cancellationToken = default)
        {
            VideoCapture vcapture = new VideoCapture(url);
            if (!vcapture.IsOpened())
            {
                Console.WriteLine("打开视频文件失败");
                return;
            }

            // 计算等待时间（毫秒）
            int taskDelay = (int)(1000 / fps);
            Stopwatch stopwatch = new Stopwatch();


            while (true)
            {
                if (cancellationToken.IsCancellationRequested) break;

                stopwatch.Restart();
                Mat frame = new Mat();
                if (!vcapture.Read(frame))
                {
                    Console.WriteLine("读取失败");
                    break;
                }

                taskDelay = (int)(1000 / fps);

                //中间标注数字,模拟路数
                Cv2.PutText(frame, index.ToString(), new OpenCvSharp.Point(frame.Width / 2, frame.Height / 2), HersheyFonts.HersheySimplex, 20, Scalar.Red, 20);

                matQueue.Enqueue(frame);

                taskDelay = (int)(taskDelay - stopwatch.ElapsedMilliseconds);
                if (matQueue.Count > 100)
                {
                    Console.WriteLine("index:" + index + ",后续处理能力不足……");
                }

                if (matQueue.Count < 10)
                {
                    taskDelay = taskDelay - 5;
                }

                if (taskDelay <= 0)
                {
                    taskDelay = 0;
                }
                Console.WriteLine("index:" + index + ",taskDelay:" + taskDelay);
                Task.Delay(taskDelay).Wait();

            }

            vcapture.Release();

        }

        /// <summary>
        /// 取消第一路
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button4_Click(object sender, EventArgs e)
        {
            taskCTS[0].Cancel();
        }

        /// <summary>
        /// 记载第7路
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button3_Click(object sender, EventArgs e)
        {
            for (int i = 0; i < 6; i++)
            {
                taskCTS[i].Cancel();
            }

            for (int i = 0; i < 6; i++)
            {
                taskCTS[i] = new CancellationTokenSource();
            }

            //删除最后一个元素
            play_rtsp_url.RemoveAt(play_rtsp_url.Count - 1);

            //把第7路的地址 放到第一的位置
            play_rtsp_url.Insert(0, new RTSPURLInfo("7", rtsp_url[6]));

            for (int i = 0; i < play_rtsp_url.Count; i++)
            {
                Task.Run(() => DecodeRTSP(play_rtsp_url[i].index, matQueue[i], play_rtsp_url[i].url, taskCTS[i].Token));
                System.Threading.Thread.Sleep(10);
            }
        }

        /// <summary>
        /// 加载第8路
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button5_Click(object sender, EventArgs e)
        {
            for (int i = 0; i < 6; i++)
            {
                taskCTS[i].Cancel();
            }

            for (int i = 0; i < 6; i++)
            {
                taskCTS[i] = new CancellationTokenSource();
            }

            //删除最后一个元素
            play_rtsp_url.RemoveAt(play_rtsp_url.Count - 1);

            //把第8路的地址 放到第一的位置
            play_rtsp_url.Insert(0, new RTSPURLInfo("8", rtsp_url[7]));

            for (int i = 0; i < play_rtsp_url.Count; i++)
            {
                Task.Run(() => DecodeRTSP(play_rtsp_url[i].index, matQueue[i], play_rtsp_url[i].url, taskCTS[i].Token));
                System.Threading.Thread.Sleep(10);
            }


        }
    }

    public class RTSPURLInfo
    {
        public string index;
        public string url;

        public RTSPURLInfo(string index, string url)
        {
            this.index = index;
            this.url = url;
        }
    }

}
 

  1. using OpenCvSharp;
  2. using System;
  3. using System.Collections.Concurrent;
  4. using System.Collections.Generic;
  5. using System.Diagnostics;
  6. using System.Threading;
  7. using System.Threading.Tasks;
  8. using System.Windows.Forms;
  9.  
  10. namespace MultiVideoDemo
  11. {
  12.     public partial class Form4 : Form
  13.     {
  14.         public Form4()
  15.         {
  16.             InitializeComponent();
  17.         }
  18.  
  19.         CancellationTokenSource ctsShow;
  20.         CancellationTokenSource[] taskCTS = new CancellationTokenSource[6];
  21.         ConcurrentQueue<Mat>[] matQueue = new ConcurrentQueue<Mat>[6];
  22.         int fps = 25;
  23.         string[] rtsp_url = new string[40];
  24.         List<RTSPURLInfo> play_rtsp_url = new List<RTSPURLInfo>();
  25.  
  26.         /// <summary>
  27.         /// 停止
  28.         /// </summary>
  29.         /// <param name="sender"></param>
  30.         /// <param name="e"></param>
  31.         private void button2_Click(object sender, EventArgs e)
  32.         {
  33.             ctsShow.Cancel();
  34.  
  35.             for (int i = 0; i < 6; i++)
  36.             {
  37.                 taskCTS[i].Cancel();
  38.             }
  39.         }
  40.  
  41.         private void Form1_Load(object sender, EventArgs e)
  42.         {
  43.             //初始化
  44.             for (int i = 0; i < 6; i++)
  45.             {
  46.                 taskCTS[i] = new CancellationTokenSource();
  47.                 matQueue[i] = new ConcurrentQueue<Mat>();
  48.             }
  49.  
  50.             for (int i = 0; i < 40; i++)
  51.             {
  52.                 rtsp_url[i] = "1.dav";
  53.             }
  54.  
  55.             //play_rtsp_url
  56.             for (int i = 0; i < 6; i++)
  57.             {
  58.                 play_rtsp_url.Add(new RTSPURLInfo((i + 1).ToString(), rtsp_url[i]));
  59.             }
  60.         }
  61.  
  62.         /// <summary>
  63.         /// 播放
  64.         /// </summary>
  65.         /// <param name="sender"></param>
  66.         /// <param name="e"></param>
  67.         private void button1_Click(object sender, EventArgs e)
  68.         {
  69.             ctsShow = new CancellationTokenSource();
  70.  
  71.             for (int i = 0; i < 6; i++)
  72.             {
  73.                 taskCTS[i] = new CancellationTokenSource();
  74.                 matQueue[i] = new ConcurrentQueue<Mat>();
  75.             }
  76.  
  77.             play_rtsp_url.Clear();
  78.             for (int i = 0; i < 6; i++)
  79.             {
  80.                 play_rtsp_url.Add(new RTSPURLInfo((i + 1).ToString(), rtsp_url[i]));
  81.             }
  82.  
  83.             for (int i = 0; i < play_rtsp_url.Count; i++)
  84.             {
  85.                 Task.Run(() => DecodeRTSP(play_rtsp_url[i].index, matQueue[i], play_rtsp_url[i].url, taskCTS[i].Token));
  86.                 System.Threading.Thread.Sleep(100);
  87.             }
  88.  
  89.             //显示线程
  90.             Task.Run(() =>
  91.             {
  92.                 Mat mat = new Mat();
  93.                 string winName = "video";
  94.  
  95.                 Cv2.NamedWindow(winName, WindowFlags.Normal);
  96.                 Cv2.ResizeWindow(winName, fullSize);
  97.  
  98.                 int delay = (int)(1000 / fps);
  99.                 Stopwatch stopwatch = new Stopwatch();
  100.  
  101.                 while (true)
  102.                 {
  103.                     stopwatch.Restart();
  104.                     delay = (int)(1000 / fps);
  105.                     if (ctsShow.IsCancellationRequested) break;
  106.  
  107.                     Mat frame = CombiningImages();
  108.  
  109.                     Cv2.ImShow(winName, frame);
  110.  
  111.                     delay = (int)(delay - stopwatch.ElapsedMilliseconds);
  112.                     if (delay <= 0)
  113.                     {
  114.                         delay = 1;
  115.                     }
  116.                     Console.WriteLine("delay:" + delay.ToString());
  117.                     Cv2.WaitKey(delay);
  118.  
  119.                     frame.Dispose();
  120.                 }
  121.                 Cv2.DestroyAllWindows();
  122.             });
  123.         }
  124.  
  125.         OpenCvSharp.Size fullSize = new OpenCvSharp.Size(1008, 570);
  126.         OpenCvSharp.Size mainSize = new OpenCvSharp.Size(672, 380);
  127.         OpenCvSharp.Size subSize = new OpenCvSharp.Size(336, 190);
  128.  
  129.         Mat CombiningImages()
  130.         {
  131.             Console.WriteLine(string.Format("matQueue0:{0},matQueue1:{1},matQueue2:{2},matQueue3:{3},matQueue4:{4},matQueue5:{5}"
  132.                 , matQueue[0].Count
  133.                 , matQueue[1].Count
  134.                 , matQueue[2].Count
  135.                 , matQueue[3].Count
  136.                 , matQueue[4].Count
  137.                 , matQueue[5].Count
  138.                 ));
  139.  
  140.             Mat mat = Mat.Zeros(fullSize, MatType.CV_8UC3);
  141.  
  142.             Mat mat0 = new Mat();
  143.             matQueue[0].TryDequeue(out mat0);
  144.             if (mat0 == null || mat0.Empty())
  145.             {
  146.                 mat0 = Mat.Zeros(mainSize, MatType.CV_8UC3);
  147.             }
  148.             Cv2.Resize(mat0, mat0, mainSize);
  149.  
  150.             Mat mat1 = new Mat();
  151.             matQueue[1].TryDequeue(out mat1);
  152.             if (mat1 == null || mat1.Empty())
  153.             {
  154.                 mat1 = Mat.Zeros(subSize, MatType.CV_8UC3);
  155.             }
  156.             Cv2.Resize(mat1, mat1, subSize);
  157.  
  158.             Mat mat2 = new Mat();
  159.             matQueue[2].TryDequeue(out mat2);
  160.             if (mat2 == null || mat2.Empty())
  161.             {
  162.                 mat2 = Mat.Zeros(subSize, MatType.CV_8UC3);
  163.             }
  164.             Cv2.Resize(mat2, mat2, subSize);
  165.  
  166.             Mat mat3 = new Mat();
  167.             matQueue[3].TryDequeue(out mat3);
  168.             if (mat3 == null || mat3.Empty())
  169.             {
  170.                 mat3 = Mat.Zeros(subSize, MatType.CV_8UC3);
  171.             }
  172.             Cv2.Resize(mat3, mat3, subSize);
  173.  
  174.             Mat mat4 = new Mat();
  175.             matQueue[4].TryDequeue(out mat4);
  176.             if (mat4 == null || mat4.Empty())
  177.             {
  178.                 mat4 = Mat.Zeros(subSize, MatType.CV_8UC3);
  179.             }
  180.             Cv2.Resize(mat4, mat4, subSize);
  181.  
  182.             Mat mat5 = new Mat();
  183.             matQueue[5].TryDequeue(out mat5);
  184.             if (mat5 == null || mat5.Empty())
  185.             {
  186.                 mat5 = Mat.Zeros(subSize, MatType.CV_8UC3);
  187.             }
  188.             Cv2.Resize(mat5, mat5, subSize);
  189.  
  190.             //第一张主图
  191.             Rect roi0 = new Rect(0, 0, 672, 380);
  192.             Mat position0 = new Mat(mat, roi0);
  193.             mat0.CopyTo(position0);
  194.  
  195.             //第二张图
  196.             Rect roi1 = new Rect(672, 0, 336, 190);
  197.             Mat position1 = new Mat(mat, roi1);
  198.             mat1.CopyTo(position1);
  199.  
  200.             //第三张图
  201.             Rect roi2 = new Rect(672, 190, 336, 190);
  202.             Mat position2 = new Mat(mat, roi2);
  203.             mat2.CopyTo(position2);
  204.  
  205.             //第4张图
  206.             Rect roi3 = new Rect(672, 380, 336, 190);
  207.             Mat position3 = new Mat(mat, roi3);
  208.             mat3.CopyTo(position3);
  209.  
  210.             //第5张图
  211.             Rect roi4 = new Rect(336, 380, 336, 190);
  212.             Mat position4 = new Mat(mat, roi4);
  213.             mat4.CopyTo(position4);
  214.  
  215.             //第6张图
  216.             Rect roi5 = new Rect(0, 380, 336, 190);
  217.             Mat position5 = new Mat(mat, roi5);
  218.             mat5.CopyTo(position5);
  219.  
  220.             mat0.Dispose();
  221.             mat1.Dispose();
  222.             mat2.Dispose();
  223.             mat3.Dispose();
  224.             mat4.Dispose();
  225.             mat5.Dispose();
  226.  
  227.             position0.Dispose();
  228.             position1.Dispose();
  229.             position2.Dispose();
  230.             position3.Dispose();
  231.             position4.Dispose();
  232.             position5.Dispose();
  233.  
  234.             return mat;
  235.  
  236.         }
  237.  
  238.         void DecodeRTSP(string index, ConcurrentQueue<Mat> matQueue, string url, CancellationToken cancellationToken = default)
  239.         {
  240.             VideoCapture vcapture = new VideoCapture(url);
  241.             if (!vcapture.IsOpened())
  242.             {
  243.                 Console.WriteLine("打开视频文件失败");
  244.                 return;
  245.             }
  246.  
  247.             // 计算等待时间（毫秒）
  248.             int taskDelay = (int)(1000 / fps);
  249.             Stopwatch stopwatch = new Stopwatch();
  250.  
  251.  
  252.             while (true)
  253.             {
  254.                 if (cancellationToken.IsCancellationRequested) break;
  255.  
  256.                 stopwatch.Restart();
  257.                 Mat frame = new Mat();
  258.                 if (!vcapture.Read(frame))
  259.                 {
  260.                     Console.WriteLine("读取失败");
  261.                     break;
  262.                 }
  263.  
  264.                 taskDelay = (int)(1000 / fps);
  265.  
  266.                 //中间标注数字,模拟路数
  267.                 Cv2.PutText(frame, index.ToString(), new OpenCvSharp.Point(frame.Width / 2, frame.Height / 2), HersheyFonts.HersheySimplex, 20, Scalar.Red, 20);
  268.  
  269.                 matQueue.Enqueue(frame);
  270.  
  271.                 taskDelay = (int)(taskDelay - stopwatch.ElapsedMilliseconds);
  272.                 if (matQueue.Count > 100)
  273.                 {
  274.                     Console.WriteLine("index:" + index + ",后续处理能力不足……");
  275.                 }
  276.  
  277.                 if (matQueue.Count < 10)
  278.                 {
  279.                     taskDelay = taskDelay - 5;
  280.                 }
  281.  
  282.                 if (taskDelay <= 0)
  283.                 {
  284.                     taskDelay = 0;
  285.                 }
  286.                 Console.WriteLine("index:" + index + ",taskDelay:" + taskDelay);
  287.                 Task.Delay(taskDelay).Wait();
  288.  
  289.             }
  290.  
  291.             vcapture.Release();
  292.  
  293.         }
  294.  
  295.         /// <summary>
  296.         /// 取消第一路
  297.         /// </summary>
  298.         /// <param name="sender"></param>
  299.         /// <param name="e"></param>
  300.         private void button4_Click(object sender, EventArgs e)
  301.         {
  302.             taskCTS[0].Cancel();
  303.         }
  304.  
  305.         /// <summary>
  306.         /// 记载第7路
  307.         /// </summary>
  308.         /// <param name="sender"></param>
  309.         /// <param name="e"></param>
  310.         private void button3_Click(object sender, EventArgs e)
  311.         {
  312.             for (int i = 0; i < 6; i++)
  313.             {
  314.                 taskCTS[i].Cancel();
  315.             }
  316.  
  317.             for (int i = 0; i < 6; i++)
  318.             {
  319.                 taskCTS[i] = new CancellationTokenSource();
  320.             }
  321.  
  322.             //删除最后一个元素
  323.             play_rtsp_url.RemoveAt(play_rtsp_url.Count - 1);
  324.  
  325.             //把第7路的地址 放到第一的位置
  326.             play_rtsp_url.Insert(0, new RTSPURLInfo("7", rtsp_url[6]));
  327.  
  328.             for (int i = 0; i < play_rtsp_url.Count; i++)
  329.             {
  330.                 Task.Run(() => DecodeRTSP(play_rtsp_url[i].index, matQueue[i], play_rtsp_url[i].url, taskCTS[i].Token));
  331.                 System.Threading.Thread.Sleep(10);
  332.             }
  333.         }
  334.  
  335.         /// <summary>
  336.         /// 加载第8路
  337.         /// </summary>
  338.         /// <param name="sender"></param>
  339.         /// <param name="e"></param>
  340.         private void button5_Click(object sender, EventArgs e)
  341.         {
  342.             for (int i = 0; i < 6; i++)
  343.             {
  344.                 taskCTS[i].Cancel();
  345.             }
  346.  
  347.             for (int i = 0; i < 6; i++)
  348.             {
  349.                 taskCTS[i] = new CancellationTokenSource();
  350.             }
  351.  
  352.             //删除最后一个元素
  353.             play_rtsp_url.RemoveAt(play_rtsp_url.Count - 1);
  354.  
  355.             //把第8路的地址 放到第一的位置
  356.             play_rtsp_url.Insert(0, new RTSPURLInfo("8", rtsp_url[7]));
  357.  
  358.             for (int i = 0; i < play_rtsp_url.Count; i++)
  359.             {
  360.                 Task.Run(() => DecodeRTSP(play_rtsp_url[i].index, matQueue[i], play_rtsp_url[i].url, taskCTS[i].Token));
  361.                 System.Threading.Thread.Sleep(10);
  362.             }
  363.  
  364.  
  365.         }
  366.     }
  367.  
  368.     public class RTSPURLInfo
  369.     {
  370.         public string index;
  371.         public string url;
  372.  
  373.         public RTSPURLInfo(string index, string url)
  374.         {
  375.             this.index = index;
  376.             this.url = url;
  377.         }
  378.     }
  379.  
  380. }

下载

源码下载

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小桥流水78/article/detail/1005650
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号