线程阻塞

Wpf_AiSportsMicrospace/Common/SportOperate.cs

@@ -27,6 +27,7 @@ namespace Wpf_AiSportsMicrospace.Common
         IPointTracker _rightTracker;
         IPointTracker _leftElbow;
         IPointTracker _rightElbow;
+        WebcamClient _webcamClient;
 
         public SportOperate()
         {
@@ -42,8 +43,8 @@ namespace Wpf_AiSportsMicrospace.Common
         }
         public WebcamClient CreateRTSP()
         {
-            WebcamClient webcamClient = WebcamClient.CreateRTSP("192.168.3.64", "admin", "yd708090", 554u);
+            _webcamClient = WebcamClient.CreateRTSP("192.168.3.64", "admin", "yd708090", 554u);
-            return webcamClient;
+            return _webcamClient;
         }
 
         /// <summary>

Wpf_AiSportsMicrospace/Home.xaml.cs

@@ -1,6 +1,7 @@
 
 using Microsoft.ML.Runtime;
 using System;
+using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Collections.ObjectModel;
 using System.ComponentModel;
@@ -36,7 +37,8 @@ namespace Wpf_AiSportsMicrospace
         private SportBase _sport;
         private readonly SportDetectionQueue _detectQueue;
         private WebcamClient _webcamClient;
-
+        private ConcurrentQueue<VideoFrame> _frameQueue = new();
+        private CancellationTokenSource _cts = new();
         private SportOperate _sportOperate;
 
         public Home()
@@ -76,17 +78,36 @@ namespace Wpf_AiSportsMicrospace
             _sportOperate = new SportOperate();
             _webcamClient = _sportOperate.CreateRTSP();
             
-            //处理抽帧回调
+            _webcamClient.OnExtractFrame += frame =>
-            _webcamClient.OnExtractFrame += this.OnFrameExtracted;
+            {
-            _webcamClient.StartExtract();//开始抽帧
+                if (frame != null)
+                    _frameQueue.Enqueue(frame);
+            };
+            _webcamClient.StartExtract();
+
+            StartFrameProcessing();
         }
 
-        private void OnFrameExtracted(VideoFrame frame)
+        private void StartFrameProcessing()
         {
-            if (frame == null) return;
-
-            // 抽帧和人体识别全部在后台线程
             Task.Run(() =>
+            {
+                while (!_cts.Token.IsCancellationRequested)
+                {
+                    if (_frameQueue.TryDequeue(out var frame))
+                    {
+                        ProcessFrame(frame);
+                    }
+                    else
+                    {
+                        Thread.Sleep(5);
+                    }
+                }
+            }, _cts.Token);
+        }
+
+
+        private void ProcessFrame(VideoFrame frame)
         {
             try
             {
@@ -133,31 +154,20 @@ namespace Wpf_AiSportsMicrospace
                 if (liftHandAction == 1)
                 {
                     // 启动进度条动画;
-                        SlideCoverFlow(coverFlow.StartSelectedProgress);
+                    Dispatcher.BeginInvoke(() => coverFlow.StartSelectedProgress());
-                        return;
                 }
             }
             catch (Exception ex)
             {
                 Console.WriteLine("OnFrameExtracted error: " + ex.Message);
             }
-            });
         }
 
-        // 抽象 UI 更新到方法中
+        protected override void OnClosed(EventArgs e)
-        private void SlideCoverFlow(Action slideAction)
         {
-            Application.Current?.Dispatcher?.BeginInvoke(new Action(() =>
+            base.OnClosed(e);
-            {
+            _cts.Cancel();
-                try
+            _webcamClient?.StopExtract();
-                {
-                    slideAction?.Invoke();
-                }
-                catch (Exception ex)
-                {
-                    Console.WriteLine("UI update error: " + ex.Message);
-                }
-            }), System.Windows.Threading.DispatcherPriority.Background);
         }
     }
 }