完善独占触摸设备初始化与热插拔恢复

- 按 Windows HID 顺序查询 FLTouch Feature Report 3，再切换多点输入模式
- 读取异常时释放旧句柄并自动重新发现、配置和初始化设备
- 启动时提前注册触摸提供器，未发现设备时持续轮询 PDX 与 FLTouch
- 记录连接与重连原因，并在游戏退出时终止后台恢复流程

Author: clansty

AquaMai.Mods/GameSystem/ExclusiveTouch/ExclusiveTouch.cs

@@ -20,9 +20,20 @@ public abstract class ExclusiveTouchBase(int playerNo, int vid, int pid, [CanBeN
     int timeoutMilliseconds = 20)
 {
     private UsbDevice device;
+    private readonly object deviceLock = new();
+    private volatile bool stopping;
     private TouchSensorMapper touchSensorMapper;
 
-    public bool IsConnected => device != null;
+    public bool IsConnected
+    {
+        get
+        {
+            lock (deviceLock)
+            {
+                return device != null;
+            }
+        }
+    }
 
     protected int PlayerNo => playerNo;
 
@@ -63,116 +74,217 @@ public TouchUpdate(ushort x, ushort y, int fingerId, bool isPressed)
 
     protected virtual string DiagnosticName => "ExclusiveTouch";
 
-    public bool Start()
+    public bool Start(bool logConnectionFailure = true)
     {
-        // 方便组 2P
-        UsbDeviceFinder finder;
-        
-        if (!string.IsNullOrWhiteSpace(serialNumber))
+        stopping = false;
+        if (!TryConnectDevice())
         {
-            // 优先使用序列号
-            finder = new UsbDeviceFinder(vid, pid, serialNumber);
+            if (logConnectionFailure)
+            {
+                MelonLogger.Msg($"[ExclusiveTouch] Cannot connect {playerNo + 1}P");
+            }
+            return false;
         }
-        else if (!string.IsNullOrWhiteSpace(locationPath))
+
+        try
         {
-            // 使用位置路径匹配
-            finder = new UsbDeviceLocationFinder(vid, pid, locationPath);
+            touchSensorMapper = new TouchSensorMapper(minX, minY, maxX, maxY, radius, flip,
+                aExtraRadius, bExtraRadius, cExtraRadius, dExtraRadius, eExtraRadius);
+
+            for (int i = 0; i < 256; i++)
+            {
+                allFingerPoints[i] = new TouchPoint();
+            }
+
+            Thread readThread = new(ReadThread);
+            readThread.IsBackground = true;
+            readThread.Start();
+            Application.quitting += () =>
+            {
+                stopping = true;
+                CloseCurrentDevice();
+            };
+            return true;
         }
-        else
+        catch (Exception e)
         {
-            // 使用第一个匹配的设备
-            finder = new UsbDeviceFinder(vid, pid);
+            MelonLogger.Error($"[ExclusiveTouch] Cannot initialize {playerNo + 1}P: {e}");
+            CloseCurrentDevice();
+            return false;
         }
-        
-        device = UsbDevice.OpenUsbDevice(finder);
-        if (device == null)
+    }
+
+    protected virtual void InitializeDevice(UsbDevice usbDevice) { }
+
+    private UsbDeviceFinder CreateFinder()
+    {
+        // 方便组 2P
+        if (!string.IsNullOrWhiteSpace(serialNumber))
         {
-            MelonLogger.Msg($"[ExclusiveTouch] Cannot connect {playerNo + 1}P");
-            return false;
+            // 优先使用序列号
+            return new UsbDeviceFinder(vid, pid, serialNumber);
+        }
+
+        if (!string.IsNullOrWhiteSpace(locationPath))
+        {
+            // 使用位置路径匹配
+            return new UsbDeviceLocationFinder(vid, pid, locationPath);
         }
 
+        // 使用第一个匹配的设备
+        return new UsbDeviceFinder(vid, pid);
+    }
+
+    private bool TryConnectDevice()
+    {
+        UsbDevice newDevice = null;
         try
         {
-            if (device is WinUsbDevice winUsbDevice)
+            newDevice = UsbDevice.OpenUsbDevice(CreateFinder());
+            if (newDevice == null) return false;
+
+            if (newDevice is WinUsbDevice winUsbDevice)
             {
                 // 触摸屏固件不能可靠处理 WinUSB 的选择性挂起
                 winUsbDevice.PowerPolicy.AutoSuspend = false;
             }
 
-            IUsbDevice wholeDevice = device as IUsbDevice;
+            IUsbDevice wholeDevice = newDevice as IUsbDevice;
             if (wholeDevice != null &&
                 (!wholeDevice.SetConfiguration(configuration) || !wholeDevice.ClaimInterface(interfaceNumber)))
             {
-                MelonLogger.Error($"[ExclusiveTouch] Cannot initialize {playerNo + 1}P");
-                device.Close();
-                device = null;
-                return false;
-            }
-            InitializeDevice(device);
-            touchSensorMapper = new TouchSensorMapper(minX, minY, maxX, maxY, radius, flip,
-                aExtraRadius, bExtraRadius, cExtraRadius, dExtraRadius, eExtraRadius);
-
-            for (int i = 0; i < 256; i++)
-            {
-                allFingerPoints[i] = new TouchPoint();
+                throw new InvalidOperationException("USB interface setup failed");
             }
 
-            Thread readThread = new(ReadThread);
-            readThread.Start();
-            TouchStatusProvider.RegisterTouchStatusProvider(playerNo, GetTouchState);
-            Application.quitting += () =>
+            InitializeDevice(newDevice);
+            lock (deviceLock)
             {
-                var tmpDevice = device;
-                device = null;
-                if (wholeDevice != null)
+                if (stopping)
                 {
-                    wholeDevice.ReleaseInterface(interfaceNumber);
+                    CloseDevice(newDevice);
+                    return false;
                 }
-                tmpDevice.Close();
-            };
+
+                device = newDevice;
+            }
+            ExclusiveTouchDiagnostics.Log(
+                "{0} player={1} connected driver={2}",
+                DiagnosticName, playerNo + 1, newDevice.DriverMode);
             return true;
         }
         catch (Exception e)
         {
-            MelonLogger.Error($"[ExclusiveTouch] Cannot initialize {playerNo + 1}P: {e}");
-            device?.Close();
-            device = null;
+            MelonLogger.Error($"[ExclusiveTouch] Cannot initialize {playerNo + 1}P: {e.Message}");
+            if (newDevice != null) CloseDevice(newDevice);
             return false;
         }
     }
 
-    protected virtual void InitializeDevice(UsbDevice usbDevice) { }
+    private void CloseCurrentDevice()
+    {
+        UsbDevice oldDevice;
+        lock (deviceLock)
+        {
+            oldDevice = device;
+            device = null;
+        }
+
+        if (oldDevice != null) CloseDevice(oldDevice);
+    }
+
+    private bool IsCurrentDevice(UsbDevice target)
+    {
+        lock (deviceLock)
+        {
+            return ReferenceEquals(target, device);
+        }
+    }
+
+    private void CloseDevice(UsbDevice target)
+    {
+        try
+        {
+            if (target is IUsbDevice wholeDevice)
+            {
+                wholeDevice.ReleaseInterface(interfaceNumber);
+            }
+        }
+        catch (Exception e)
+        {
+            MelonLogger.Warning($"[ExclusiveTouch] Cannot release {playerNo + 1}P interface: {e.Message}");
+        }
+
+        try
+        {
+            target.Close();
+        }
+        catch (Exception e)
+        {
+            MelonLogger.Warning($"[ExclusiveTouch] Cannot close {playerNo + 1}P device: {e.Message}");
+        }
+    }
 
     private void ReadThread()
     {
         byte[] buffer = new byte[packetSize];
-        var reader = device.OpenEndpointReader(endpoint);
         using var pinnedBuffer = new PinnedHandle(buffer);
-        
+
         try
         {
-            while (device != null)
+            while (!stopping)
             {
-                int bytesRead;
-                ErrorCode ec = reader.Read(pinnedBuffer.Handle, 0, buffer.Length, 100, out bytesRead); // 100ms 超时
+                UsbDevice currentDevice;
+                lock (deviceLock)
+                {
+                    currentDevice = device;
+                }
 
-                if (ec != ErrorCode.None)
+                if (currentDevice == null)
                 {
-                    if (ec == ErrorCode.IoTimedOut) continue; // 超时就继续等
-                    MelonLogger.Msg($"[ExclusiveTouch] {playerNo + 1}P: 读取错误: {ec}");
-                    break;
+                    Thread.Sleep(1000);
+                    TryConnectDevice();
+                    continue;
                 }
 
-                if (bytesRead > 0)
+                try
+                {
+                    using var reader = currentDevice.OpenEndpointReader(endpoint);
+                    while (!stopping)
+                    {
+                        int bytesRead;
+                        ErrorCode ec = reader.Read(pinnedBuffer.Handle, 0, buffer.Length, 100, out bytesRead); // 100ms 超时
+
+                        if (ec == ErrorCode.IoTimedOut) continue; // 超时就继续等
+                        if (ec != ErrorCode.None)
+                        {
+                            MelonLogger.Msg($"[ExclusiveTouch] {playerNo + 1}P: 读取错误: {ec}，尝试重连");
+                            ExclusiveTouchDiagnostics.Log(
+                                "{0} player={1} reconnect reason=read-error code={2}",
+                                DiagnosticName, playerNo + 1, ec);
+                            CloseCurrentDevice();
+                            break;
+                        }
+
+                        if (bytesRead > 0 && IsCurrentDevice(currentDevice))
+                        {
+                            OnTouchData(buffer);
+                        }
+                    }
+                }
+                catch (Exception e)
                 {
-                    OnTouchData(buffer);
+                    if (stopping) break;
+                    MelonLogger.Msg($"[ExclusiveTouch] {playerNo + 1}P: 读取异常: {e.Message}，尝试重连");
+                    ExclusiveTouchDiagnostics.Log(
+                        "{0} player={1} reconnect reason=read-exception error={2}",
+                        DiagnosticName, playerNo + 1, e.Message);
+                    CloseCurrentDevice();
                 }
             }
         }
         finally
         {
-            // 确保 reader 被正确释放
-            reader?.Dispose();
+            CloseCurrentDevice();
         }
     }
 
@@ -261,7 +373,7 @@ private ulong ComputeActiveMask()
         }
         return mask;
     }
-    private ulong GetTouchState(int player)
+    internal ulong GetTouchState(int player)
     {
         if (player != playerNo) return 0;
         lock (touchLock)