feat: Enhance concurrency and thread safety across multiple components

Author: tattn

app/xcode/Sources/VCamAppExtension/ExtensionNotificationCenter.swift

@@ -1,13 +1,7 @@
-//
-//  ExtensionNotificationCenter.swift
-//  
-//
-//  Created by Tatsuya Tanaka on 2023/02/25.
-//
-
 import Foundation
+import os
 
-public enum ExtensionNotification: String, Equatable {
+public enum ExtensionNotification: String, Equatable, Sendable {
     case startCameraExtensionStream
     case stopAllCameraExtensionStreams
 
@@ -23,11 +17,11 @@ public enum ExtensionNotification: String, Equatable {
     }
 }
 
-public final class ExtensionNotificationCenter {
+public final class ExtensionNotificationCenter: Sendable {
     public static let `default` = ExtensionNotificationCenter()
 
-    private let center = CFNotificationCenterGetDarwinNotifyCenter()
-    private var observers: [ExtensionNotification: () -> Void] = [:]
+    private nonisolated(unsafe) let center = CFNotificationCenterGetDarwinNotifyCenter()
+    private let observers = OSAllocatedUnfairLock(initialState: [ExtensionNotification: @Sendable () -> Void]())
 
     public func post(_ notification: ExtensionNotification) {
         CFNotificationCenterPostNotification(
@@ -39,14 +33,14 @@ public final class ExtensionNotificationCenter {
         )
     }
 
-    public func setObserver(for notification: ExtensionNotification, using: @escaping () -> Void) {
-        defer {
+    public func setObserver(for notification: ExtensionNotification, using: @escaping @Sendable () -> Void) {
+        let alreadyRegistered = observers.withLock { observers in
+            let exists = observers.keys.contains(notification)
             observers[notification] = using
+            return exists
         }
 
-        guard !observers.keys.contains(notification) else {
-            return
-        }
+        guard !alreadyRegistered else { return }
 
         let observer = UnsafeRawPointer(Unmanaged.passUnretained(self).toOpaque())
         CFNotificationCenterAddObserver(
@@ -55,7 +49,7 @@ public final class ExtensionNotificationCenter {
             { _, observer, name, _, _ in
                 if let observer = observer, let name = name, let notification = ExtensionNotification(name: name) {
                     let observerSelf = Unmanaged<ExtensionNotificationCenter>.fromOpaque(observer).takeUnretainedValue()
-                    observerSelf.observers[notification]?()
+                    observerSelf.observers.withLock { $0[notification]?() }
                 }
             },
             notification.rawValue as CFString,
@@ -65,7 +59,7 @@ public final class ExtensionNotificationCenter {
     }
 
     public func removeAllObservers() {
-        observers.removeAll()
+        observers.withLock { $0.removeAll() }
         CFNotificationCenterRemoveEveryObserver(center, Unmanaged.passRetained(self).toOpaque())
     }
 }

app/xcode/Sources/VCamBridge/Debug.swift

@@ -1,28 +1,23 @@
-//
-//  Debug.swift
-//
-//
-//  Created by Tatsuya Tanaka on 2022/05/09.
-//
-//
 import AppKit
 import SwiftUI
 
-private var debugLog: ((String) -> Void)?
+@MainActor private var debugLog: ((String) -> Void)?
 
 
 @_cdecl("uniRegisterDebugLog")
-public func uniRegisterDebugLog(_ function: @escaping @convention(c) (UnsafePointer<CChar>) -> Void) {
+@MainActor public func uniRegisterDebugLog(_ function: @escaping @convention(c) (UnsafePointer<CChar>) -> Void) {
     debugLog = { function(($0 as NSString).utf8String!) }
 }
 
 public func uniDebugLog(_ message: String) {
     guard Thread.isMainThread else {
-        DispatchQueue.main.async {
+        Task { @MainActor in
             uniDebugLog(message)
         }
         return
     }
 
-    debugLog?(message)
+    MainActor.assumeIsolated {
+        debugLog?(message)
+    }
 }

app/xcode/Sources/VCamBridge/DeeplinkHandler.swift

@@ -1,18 +1,12 @@
-//
-//  DeeplinkHandler.swift
-//
-//
-//  Created by tattn on 2025/11/15.
-//
-
 import Foundation
 
 @_cdecl("uniHandleDeepLink")
-public func uniHandleDeepLink(_ url: UnsafePointer<CChar>) {
+@MainActor public func uniHandleDeepLink(_ url: UnsafePointer<CChar>) {
     let urlString = String(cString: url)
     DeeplinkHandler.handleURL(URL(string: urlString)!)
 }
 
+@MainActor
 public enum DeeplinkHandler {
     public static var handleURL: (URL) -> Void = { _ in }
 }

app/xcode/Sources/VCamBridge/RenderTexture.swift

@@ -1,11 +1,5 @@
-//
-//  RenderTexture.swift
-//
-//
-//  Created by Tatsuya Tanaka on 2022/03/25.
-//
-
-import MetalKit
+@preconcurrency import MetalKit
+import os
 
 public enum RenderTextureType: Int32 {
     case photo
@@ -14,7 +8,7 @@ public enum RenderTextureType: Int32 {
     case web
 }
 
-public final class MainTexture {
+public final class MainTexture: @unchecked Sendable {
     public static let shared = MainTexture()
 
     public private(set) var texture = CIImage(color: .black).cropped(to: .init(x: 0, y: 0, width: 1280, height: 720))
@@ -34,55 +28,3 @@ public final class MainTexture {
         self.texture = CIImage(mtlTexture: texture, options: nil)!
     }
 }
-
-public func __bridge<T : AnyObject>(_ ptr: UnsafeRawPointer) -> T {
-    Unmanaged.fromOpaque(ptr).takeUnretainedValue()
-}
-
-@_cdecl("uniRegisterMainTexture")
-public func uniRegisterMainTexture(imagePointer: UnsafeRawPointer?) {
-    guard let imagePointer else { return }
-    let bridgedMtlTexture: any MTLTexture = __bridge(imagePointer)
-
-#if FOR_DEBUG
-    os_log(.debug, " \(String(describing: bridgedMtlTexture).dropFirst(80), privacy: .public)")
-#endif
-
-//    let mtlTexture = bridgedMtlTexture.makeTextureView(pixelFormat: .rgba8Unorm_srgb)!
-    MainTexture.shared.setTexture(bridgedMtlTexture)
-}
-
-
-
-/* Information about the main texture
-
- <AGXG13XFamilyTexture: 0x12e87f730>
-     label =
-     textureType = MTLTextureType2D
-     pixelFormat = MTLPixelFormatRGBA8Unorm_sRGB
-     width = 1920
-     height = 1080
-     depth = 1
-     arrayLength = 1
-     mipmapLevelCount = 1
-     sampleCount = 1
-     cpuCacheMode = MTLCPUCacheModeDefaultCache
-     storageMode = MTLStorageModeShared
-     hazardTrackingMode = MTLHazardTrackingModeTracked
-     resourceOptions = MTLResourceCPUCacheModeDefaultCache MTLResourceStorageModeShared MTLResourceHazardTrackingModeTracked
-     usage = MTLTextureUsageShaderRead MTLTextureUsageRenderTarget
-     shareable = 0
-     framebufferOnly = 0
-     purgeableState = MTLPurgeableStateNonVolatile
-     swizzle = [MTLTextureSwizzleRed, MTLTextureSwizzleGreen, MTLTextureSwizzleBlue, MTLTextureSwizzleAlpha]
-     isCompressed = 1
-     parentTexture = <null>
-     parentRelativeLevel = 0
-     parentRelativeSlice = 0
-     buffer = <null>
-     bufferOffset = 0
-     bufferBytesPerRow = 0
-     iosurface = 0x0
-     iosurfacePlane = 0
-     allowGPUOptimizedContents = YES
- */

app/xcode/Sources/VCamBridge/UniBridge+Typed.swift

@@ -1,14 +1,7 @@
-//
-//  UniBridge+Typed.swift
-//
-//
-//  Created by tattn on 2025/12/07.
-//
-
 import Foundation
 
 // MARK: - Method ID Enum
-public struct UniBridgeMethodId: RawRepresentable {
+public struct UniBridgeMethodId: RawRepresentable, Sendable {
     static let playMotion = Self.init(rawValue: 0)
     static let stopMotion = Self.init(rawValue: 1)
     static let applyExpression = Self.init(rawValue: 2)
@@ -62,7 +55,7 @@ public struct ScreenResolutionPayload: Equatable {
 
 // MARK: - Bridge Callback
 public extension UniBridge {
-    fileprivate(set) static var methodCallback: (UniBridgeMethodId, UnsafeMutableRawPointer?, UnsafeMutableRawPointer?) -> Void = { _, _, _ in }
+    nonisolated(unsafe) fileprivate(set) static var methodCallback: (UniBridgeMethodId, UnsafeMutableRawPointer?, UnsafeMutableRawPointer?) -> Void = { _, _, _ in }
 }
 
 // MARK: - Bridge Implementation

app/xcode/Sources/VCamBridge/UniBridge.swift

@@ -1,9 +1,9 @@
 /// GENERATED BY ./scripts/generate_bridge
 import SwiftUI
-public final class UniBridge {
+public final class UniBridge: @unchecked Sendable {
     public static let shared = UniBridge()
     private init() {}
-    public enum IntType: Int32 {
+    public enum IntType: Int32, Sendable {
         case lensFlare = 0
         case facialExpression = 1
         case objectSelected = 2
@@ -15,7 +15,7 @@ public final class UniBridge {
     public var objectSelected: Binding<Int32> { intMapper.binding(.objectSelected) }
     public private(set) lazy var qualityLevel = intMapper.set(.qualityLevel)
 
-    public enum FloatType: Int32 {
+    public enum FloatType: Int32, Sendable {
         case camera = 0
         case light = 1
         case postExposure = 2
@@ -65,7 +65,7 @@ public final class UniBridge {
     public private(set) lazy var swivelOffset = floatMapper.set(.swivelOffset)
     public private(set) lazy var trackingSmoothing = floatMapper.set(.trackingSmoothing)
 
-    public enum BoolType: Int32 {
+    public enum BoolType: Int32, Sendable {
         case useAutoMode = 0
         case useShadow = 1
         case usePostEffect = 2
@@ -91,7 +91,7 @@ public final class UniBridge {
     public private(set) lazy var lipSyncWebCam = boolMapper.set(.lipSyncWebCam)
     public var hasPerfectSyncBlendShape: Bool { boolMapper.get(.hasPerfectSyncBlendShape) }
 
-    public enum StringType: Int32 {
+    public enum StringType: Int32, Sendable {
         case message = 0
         case loadVRM = 1
         case loadModel = 2
@@ -103,7 +103,7 @@ public final class UniBridge {
     public private(set) lazy var loadModel = stringMapper.set(.loadModel)
     public private(set) lazy var showEmojiStamp = stringMapper.set(.showEmojiStamp)
 
-    public enum TriggerType: Int32 {
+    public enum TriggerType: Int32, Sendable {
         case openVRoidHub = 0
         case resetCamera = 1
         case deleteObject = 2
@@ -123,7 +123,7 @@ public final class UniBridge {
     public private(set) lazy var resumeApp = triggerMapper.trigger(.resumeApp)
     public private(set) lazy var quitApp = triggerMapper.trigger(.quitApp)
 
-    public enum StructType: Int32 {
+    public enum StructType: Int32, Sendable {
         case backgroundColor = 0
         case environmentLightColor = 1
         case colorFilter = 2
@@ -137,7 +137,7 @@ public final class UniBridge {
     public private(set) lazy var bloomColor = structMapper.set(.bloomColor, type: Color.self)
     public private(set) lazy var vignetteColor = structMapper.set(.vignetteColor, type: Color.self)
 
-    public enum ArrayType: Int32 {
+    public enum ArrayType: Int32, Sendable {
         case hands = 0
         case fingers = 1
         case receiveVCamBlendShape = 2

app/xcode/Sources/VCamBridge/ValueBinding.swift

@@ -1,16 +1,9 @@
-//
-//  ValueBinding.swift
-//
-//
-//  Created by Tatsuya Tanaka on 2022/03/11.
-//
-
 import struct CoreGraphics.CGFloat
 import class AppKit.NSColor
 import struct SwiftUI.Binding
 import struct SwiftUI.Color
 
-public final class ValueBinding<Value, Kind: RawRepresentable> where Kind.RawValue == Int32 {
+public final class ValueBinding<Value, Kind: RawRepresentable>: @unchecked Sendable where Kind.RawValue == Int32, Kind: Sendable {
     public var getValue: ((Kind) -> Value)?
     public var setValue: (Kind, Value) -> Void = { _, _ in }
 
@@ -22,8 +15,8 @@ public final class ValueBinding<Value, Kind: RawRepresentable> where Kind.RawVal
     }
 }
 
-extension ValueBinding where Value: ValueBindingDefaultValue {
-    @inlinable public func binding(_ type: Kind, onGet: @escaping (Value) -> Void = { _ in }, onSet: @escaping (Value) -> Void = { _ in }) -> Binding<Value> {
+extension ValueBinding where Value: ValueBindingDefaultValue & Sendable {
+    @inlinable public func binding(_ type: Kind, onGet: @escaping @Sendable (Value) -> Void = { _ in }, onSet: @escaping @Sendable (Value) -> Void = { _ in }) -> Binding<Value> {
         .init { [weak self] in
             let value = self?.getValue?(type) ?? Value.defaultValue
             onGet(value)
@@ -50,7 +43,7 @@ extension ValueBinding where Value == Void {
 }
 
 extension ValueBinding where Value == UnsafeMutableRawPointer {
-    @inlinable public func binding<T: ValueBindingStructType>(_ kind: Kind, type: T.Type = T.self, onGet: @escaping (T) -> Void = { _ in }, onSet: @escaping (T) -> Void = { _ in }) -> Binding<T> {
+    @inlinable public func binding<T: ValueBindingStructType & Sendable>(_ kind: Kind, type: T.Type = T.self, onGet: @escaping @Sendable (T) -> Void = { _ in }, onSet: @escaping @Sendable (T) -> Void = { _ in }) -> Binding<T> {
         .init { [weak self] in
             guard let value = self?.getValue?(kind), UInt(bitPattern: value) != 0 else {
                 return T.defaultValue
@@ -79,7 +72,7 @@ extension ValueBinding where Value == UnsafeMutableRawPointer {
         }
     }
 
-    @inlinable public func binding<T: BridgeArrayType>(_ kind: Kind, size: Int, type: T.Type = T.self, onGet: @escaping (T) -> Void = { _ in }, onSet: @escaping (T) -> Void = { _ in }) -> Binding<T> {
+    @inlinable public func binding<T: BridgeArrayType & Sendable>(_ kind: Kind, size: Int, type: T.Type = T.self, onGet: @escaping @Sendable (T) -> Void = { _ in }, onSet: @escaping @Sendable (T) -> Void = { _ in }) -> Binding<T> {
         .init { [weak self] in
             guard let retrievedValue: T = self?.get(kind, size: size) else {
                 return T.defaultValue