MvvmScaffoldFrame48/MvvmScaffoldFrame48.DLL/ThreadManager/ThreadManager.cs

using MvCameraControl;
using MvvmScaffoldFrame48.DLL.CameraTools;
using MvvmScaffoldFrame48.Model.ResultModel;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;

namespace MvvmScaffoldFrame48.DLL.ThreadManager
{
    public class ThreadManager
    {
        private readonly CameraGroup[] _cameraGroups = new CameraGroup[1];
        private readonly CommunicationThread _communicationThread;

        public ThreadManager()
        {
            HikVision.GetCameraList(out List<IDeviceInfo> cameraInfoList);
            // 初始化四个相机组
            for (int i = 0; i < _cameraGroups.Count(); i++)
            {
                _cameraGroups[i] = new CameraGroup
                {
                    CameraId = i,
                    ImageQueue = new ConcurrentQueue<IImage>(),
                    QueueSemaphore = new SemaphoreSlim(0),
                    Camera = new HikCamera(cameraInfoList[i])
                };

                _cameraGroups[i].ImageProcessor = new ProcessingAlgorithm();
                // 订阅处理结果事件
                _cameraGroups[i].ProcessResultAvailable += OnProcessResultAvailable;
            }

            // 初始化通信和显示线程
            _communicationThread = new CommunicationThread();
        }

        /// <summary>
        /// 处理相机处理结果
        /// </summary>
        private void OnProcessResultAvailable(object sender, CameraProcessEventArgsResultModel e)
        {
            // 将处理结果发送到通信线程
            _communicationThread.SendData(e);

            // 可以在这里添加其他处理逻辑，如更新显示等
            Console.WriteLine($"收到相机{e.CameraId}的处理结果");
        }

        /// <summary>
        /// 启动指定相机组
        /// </summary>
        public void StartCameraGroup(int cameraId)
        {
            if (cameraId >= 0 && cameraId < _cameraGroups.Count())
            {
                _cameraGroups[cameraId].Start();
            }
        }

        /// <summary>
        /// 停止指定相机组
        /// </summary>
        public void StopCameraGroup(int cameraId)
        {
            if (cameraId >= 0 && cameraId < 4)
            {
                _cameraGroups[cameraId].Stop();
            }
        }

        /// <summary>
        /// 启动通信线程
        /// </summary>
        public void StartCommunication()
        {
            _communicationThread.Start();
        }

        /// <summary>
        /// 停止通信线程
        /// </summary>
        public void StopCommunication()
        {
            _communicationThread.Stop();
        }

        /// <summary>
        /// 启动所有线程
        /// </summary>
        public void StartAll()
        {
            for (int i = 0; i < 4; i++)
            {
                StartCameraGroup(i);
            }
            StartCommunication();
        }

        /// <summary>
        /// 停止所有线程
        /// </summary>
        public void StopAll()
        {
            for (int i = 0; i < 4; i++)
            {
                StopCameraGroup(i);
            }
            StopCommunication();
        }

        /// <summary>
        /// 获取相机组运行状态
        /// </summary>
        public bool IsCameraGroupRunning(int cameraId)
        {
            return cameraId >= 0 && cameraId < 4 && _cameraGroups[cameraId].IsRunning;
        }

        /// <summary>
        /// 获取通信线程运行状态
        /// </summary>
        public bool IsCommunicationRunning => _communicationThread.IsRunning;
    }
}