轮胎外观检测添加思谋语义分割模型检测工具
C3204
8 天以前 d1444a09d4a4811a9ea7b86cb264d753ef14088c
LB_VisionProcesses/Cameras/HRCameras/HRCamera.cs
@@ -2,7 +2,10 @@
using LB_SmartVisionCommon;
using LB_VisionProcesses.Cameras.LBCameras;
using MVSDK_Net;
using Sunny.UI;
using System;
using System.Collections;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Diagnostics;
using System.Drawing.Imaging;
@@ -231,20 +234,26 @@
                    AsyncLogHelper.Warn(SN + "帧转换为Bitmap失败,跳过处理");
                    return;
                }
                // 3. 线程安全地将Bitmap添加到CollectedImages字典
                lock (_collectedImagesLock)
                // 3. 获取/创建线程安全队列
                var queue = CollectedImages.GetOrAdd(SN, new ConcurrentQueue<Bitmap>());
                AsyncLogHelper.Info(SN + $"图像已加入缓存,当前缓存数量:{CollectedImages[SN].Count}");
                // 4. 队列限流,防止内存溢出
                if (queue.Count >= MAX_QUEUE_CAPACITY)
                {
                    // 确保当前相机SN对应的列表存在
                    if (!CollectedImages.ContainsKey(SN))
                    if (queue.TryDequeue(out Bitmap old))
                    {
                        CollectedImages[SN] = new List<Bitmap>();
                        old.Dispose(); // 丢弃最旧帧,释放内存
                        AsyncLogHelper.Warn($"HRCamera[{SN}]: 队列已满,自动丢弃最旧帧");
                    }
                    CollectedImages[SN].Add(bitmap);
                    AsyncLogHelper.Info(SN + $"图像已加入缓存,当前缓存数量:{CollectedImages[SN].Count}");
                }
                // 4. 处理CollectedImages中的图像:遍历消费列表第一个元素直到为空
                ProcessCollectedImages();
                // 5. 入队
                queue.Enqueue(bitmap);
                AsyncLogHelper.Info($"LBCamera[{SN}]: 图像入队,当前队列:{queue.Count}");
                // 6. 启动队列(单例,避免多线程重复)
                StartConsumeQueue();
                //Task.Factory.StartNew(() =>
                //{
                //    CallBackImg = (Bitmap)bitmap.Clone();
@@ -265,87 +274,65 @@
        }
        /// <summary>
        /// 启动队列(保证单线程)
        /// </summary>
        private void StartConsumeQueue()
        {
            // 使用轻量级判断,避免重复启动消费任务
            if (CollectedImages.TryGetValue(SN, out var queue) && !queue.IsEmpty)
            {
                Task.Factory.StartNew(ProcessImageQueue, TaskCreationOptions.LongRunning);
            }
        }
        /// <summary>
        /// 处理CollectedImages中的缓存图像
        /// 核心逻辑:遍历取第一个图像 -> 赋值给CallBackImg -> 触发事件 -> 释放并移除
        /// </summary>
        private void ProcessCollectedImages()
        private void ProcessImageQueue()
        {
            Task.Factory.StartNew(() =>
            try
            {
                // 加锁保证线程安全,防止多线程同时操作列表
                lock (_collectedImagesLock)
                if (!CollectedImages.TryGetValue(SN, out var queue) || queue.IsEmpty)
                    return;
                // 短锁:仅出队,不阻塞生产
                while (queue.TryDequeue(out Bitmap bitmap))
                {
                    // 校验当前相机的图像列表是否存在且有数据
                    if (!CollectedImages.ContainsKey(SN) || CollectedImages[SN].Count == 0)
                    {
                        AsyncLogHelper.Info(SN + "当前无缓存图像,跳过处理");
                        return;
                    }
                    // 循环处理:直到列表为空
                    while (CollectedImages[SN].Count > 0)
                    using (bitmap) // 自动释放:using 是最安全的方式
                    {
                        try
                        {
                            // 1 取列表第一个索引的图像赋值给CallBackImg
                            Bitmap firstBitmap = CollectedImages[SN][0];
                            ImageGrabbed?.Invoke(this, new LBCameraEventArgs(SN, firstBitmap, true));
                            CallBackImg = (Bitmap)firstBitmap.Clone(); // 克隆避免原对象被释放后引用失效
                            // 关键:事件传递克隆对象,绝对安全,不传递原资源
                            using (Bitmap clone = (Bitmap)bitmap.Clone())
                            {
                                // 触发图像事件
                                ImageGrabbed?.Invoke(this, new LBCameraEventArgs(SN, clone, true));
                                CallBackImg = (Bitmap)clone.Clone();
                            }
                            // 2 获取触发模式并判断是否触发运行事件
                            // 触发模式判断
                            if (GetTriggerMode(out TriggerMode mode, out TriggerSource source))
                            {
                                // 硬触发模式下触发运行事件
                                if (mode == TriggerMode.On && source != TriggerSource.Software)
                                {
                                    AsyncLogHelper.Info(SN + $"触发硬触发事件,触发源:{source}");
                                    TriggerRunMessageReceived?.Invoke(SN, source.ToString());
                                    AsyncLogHelper.Info($"LBCamera[{SN}]: 硬触发事件 - {source}");
                                }
                            }
                            else
                            {
                                AsyncLogHelper.Warn(SN + "获取触发模式失败,跳过事件触发");
                            }
                            // 3 释放第一个图像资源并从列表移除
                            // 先释放Bitmap内存,再移除列表元素
                            firstBitmap.Dispose();
                            CollectedImages[SN].RemoveAt(0);
                            AsyncLogHelper.Info(SN + $"已消费缓存图像,剩余缓存数量:{CollectedImages[SN].Count}");
                        }
                        catch (Exception ex)
                        {
                            AsyncLogHelper.Error(SN + $"处理缓存图像异常:{ex.Message}", ex);
                            // 单个图像处理失败时,移除该图像避免阻塞后续处理
                            if (CollectedImages[SN].Count > 0)
                            {
                                try
                                {
                                    CollectedImages[SN][0]?.Dispose(); // 尝试释放
                                    CollectedImages[SN].RemoveAt(0);
                                }
                                catch (Exception innerEx)
                                {
                                    AsyncLogHelper.Error(SN + $"清理异常图像失败:{innerEx.Message}", innerEx);
                                }
                            }
                            // 单个图像处理失败不终止循环,继续处理下一个
                            // 4. 所有图像处理完成后,清空CallBackImg
                            if (CallBackImg != null)
                            {
                                CallBackImg.Dispose();
                                CallBackImg = null;
                            }
                            continue;
                        }
                        // 4. 所有图像处理完成后,清空CallBackImg
                        if (CallBackImg != null)
                        {
                            CallBackImg.Dispose();
                            CallBackImg = null;
                            AsyncLogHelper.Error($"LBCamera[{SN}]: 处理单帧图像异常 - {ex.Message}", ex);
                            continue; // 单帧异常,继续处理下一帧
                        }
                    }
                }
            });
            }
            catch (Exception ex)
            {
                AsyncLogHelper.Error($"LBCamera[{SN}]: 消费队列异常 - {ex.Message}", ex);
            }
        }
        /// <summary>