From b40544e59eb8119d81d2791f7473a7d5194cbbec Mon Sep 17 00:00:00 2001
From: mhbalthasar <98707331+mhbalthasar@users.noreply.github.com>
Date: Tue, 29 Oct 2024 23:00:08 +0800
Subject: [PATCH] Update SDLPlaybackData.cs

replace Mutex
---
 TuneLab/Audio/SDL2/SDLPlaybackData.cs | 96 +++++++++++++--------------
 1 file changed, 47 insertions(+), 49 deletions(-)

diff --git a/TuneLab/Audio/SDL2/SDLPlaybackData.cs b/TuneLab/Audio/SDL2/SDLPlaybackData.cs
index 6dac136..b7d0ea2 100644
--- a/TuneLab/Audio/SDL2/SDLPlaybackData.cs
+++ b/TuneLab/Audio/SDL2/SDLPlaybackData.cs
@@ -40,7 +40,7 @@ public enum PlaybackState
 
     public Thread producer;
 
-    public Mutex mutex;
+    public object mLocker = new object();
 
     // 控制块
     public struct CallbackBlock
@@ -62,8 +62,6 @@ public SDLPlaybackData()
         spec.callback = workCallback;
 
         pcm_buffer = null;
-
-        mutex = new Mutex();
     }
 
     public void Start()
@@ -197,38 +195,38 @@ public void SetState(PlaybackState newState)
     private void workCallback(IntPtr udata, IntPtr stream, int len)
     {
         // 上锁
-        mutex.WaitOne();
-
-        // 缓冲区置为静音
-        SDLReimpl.SDL_memset(stream, 0, (IntPtr)len);
-
-        if (scb.audio_len > 0 && scb.audio_chunk != IntPtr.Zero)
-        {
-            len = Math.Min(len, scb.audio_len);
-
-            // 将缓冲区中的声音写入流
-            SDL.SDL_MixAudioFormat(
-                stream,
-                IntPtr.Add(scb.audio_chunk, scb.audio_pos),
-                spec.format,
-                (uint)len,
-                SDL.SDL_MIX_MAXVOLUME
-            );
+        lock(mLocker){
 
-            scb.audio_pos += len;
-            scb.audio_len -= len;
-
-            samplesConsumed?.Invoke(len / sizeof(float));
-
-            // 判断是否完毕
-            if (scb.audio_len == 0)
+            // 缓冲区置为静音
+            SDLReimpl.SDL_memset(stream, 0, (IntPtr)len);
+    
+            if (scb.audio_len > 0 && scb.audio_chunk != IntPtr.Zero)
             {
-                notifyGetAudioFrame();
+                len = Math.Min(len, scb.audio_len);
+    
+                // 将缓冲区中的声音写入流
+                SDL.SDL_MixAudioFormat(
+                    stream,
+                    IntPtr.Add(scb.audio_chunk, scb.audio_pos),
+                    spec.format,
+                    (uint)len,
+                    SDL.SDL_MIX_MAXVOLUME
+                );
+    
+                scb.audio_pos += len;
+                scb.audio_len -= len;
+    
+                samplesConsumed?.Invoke(len / sizeof(float));
+    
+                // 判断是否完毕
+                if (scb.audio_len == 0)
+                {
+                    notifyGetAudioFrame();
+                }
             }
-        }
 
         // 放锁
-        mutex.ReleaseMutex();
+        }
     }
 
     // 通知缓冲区已空
@@ -275,26 +273,26 @@ private void poll()
                     case (int)SDLGlobal.UserEvent.SDL_EVENT_BUFFER_END:
                     {
                         // 上锁
-                        mutex.WaitOne();
-
-                        // 从文件中读取数据，剩下的就交给音频设备去完成了
-                        // 它播放完一段数据后会执行回调函数，获取等多的数据
-                        int samples = sampleProvider.Read(pcm_buffer, 0, spec.samples * spec.channels);
-                        if (samples <= 0)
-                        {
-                            // 播放完毕
-                            over = true;
-                        }
-                        else
-                        {
-                            // 重置缓冲区
-                            scb.audio_chunk = Marshal.UnsafeAddrOfPinnedArrayElement(pcm_buffer, 0);
-                            scb.audio_len = samples * sizeof(float); // 长度为读出数据长度，在read_audio_data中做减法
-                            scb.audio_pos = 0; // 设置当前位置为缓冲区头部
-                        }
+                        lock(mLocker){
+
+                            // 从文件中读取数据，剩下的就交给音频设备去完成了
+                            // 它播放完一段数据后会执行回调函数，获取等多的数据
+                            int samples = sampleProvider.Read(pcm_buffer, 0, spec.samples * spec.channels);
+                            if (samples <= 0)
+                            {
+                                // 播放完毕
+                                over = true;
+                            }
+                            else
+                            {
+                                // 重置缓冲区
+                                scb.audio_chunk = Marshal.UnsafeAddrOfPinnedArrayElement(pcm_buffer, 0);
+                                scb.audio_len = samples * sizeof(float); // 长度为读出数据长度，在read_audio_data中做减法
+                                scb.audio_pos = 0; // 设置当前位置为缓冲区头部
+                            }
 
                         // 放锁
-                        mutex.ReleaseMutex();
+                        }
                         break;
                     }
 
@@ -350,4 +348,4 @@ private void poll()
         // 解除固定缓冲区
         gch.Free();
     }
-}
\ No newline at end of file
+}