Update proposal and implementation

Author: FranzBusch

Evolution/0016-mutli-producer-single-consumer-channel.md

@@ -23,33 +23,24 @@ import Bionic
 #error("Unsupported platform")
 #endif
 
-@usableFromInline
-internal class Lock {
+internal struct Lock {
 #if canImport(Darwin)
-    @usableFromInline
   typealias Primitive = os_unfair_lock
 #elseif canImport(Glibc) || canImport(Musl) || canImport(Bionic)
   typealias Primitive = pthread_mutex_t
 #elseif canImport(WinSDK)
-    @usableFromInline
   typealias Primitive = SRWLOCK
 #else
   #error("Unsupported platform")
 #endif
 
-    @usableFromInline
   typealias PlatformLock = UnsafeMutablePointer<Primitive>
-    @usableFromInline
   let platformLock: PlatformLock
 
   private init(_ platformLock: PlatformLock) {
     self.platformLock = platformLock
   }
-
-    deinit {
-        self.deinitialize()
-    }
-
+  
   fileprivate static func initialize(_ platformLock: PlatformLock) {
 #if canImport(Darwin)
     platformLock.initialize(to: os_unfair_lock())
@@ -71,8 +62,7 @@ internal class Lock {
     platformLock.deinitialize(count: 1)
   }
 
-    @usableFromInline
-  static func lock(_ platformLock: PlatformLock) {
+  fileprivate static func lock(_ platformLock: PlatformLock) {
 #if canImport(Darwin)
     os_unfair_lock_lock(platformLock)
 #elseif canImport(Glibc) || canImport(Musl) || canImport(Bionic)
@@ -84,8 +74,7 @@ internal class Lock {
 #endif
   }
 
-    @usableFromInline
-  static func unlock(_ platformLock: PlatformLock) {
+  fileprivate static func unlock(_ platformLock: PlatformLock) {
 #if canImport(Darwin)
     os_unfair_lock_unlock(platformLock)
 #elseif canImport(Glibc) || canImport(Musl) || canImport(Bionic)
@@ -109,12 +98,10 @@ internal class Lock {
     platformLock.deallocate()
   }
 
-  @inlinable
   func lock() {
     Lock.lock(platformLock)
   }
 
-    @inlinable
   func unlock() {
     Lock.unlock(platformLock)
   }
@@ -127,7 +114,6 @@ internal class Lock {
     ///
     /// - Parameter body: The block to execute while holding the lock.
     /// - Returns: The value returned by the block.
-    @inlinable
     func withLock<T>(_ body: () throws -> T) rethrows -> T {
         self.lock()
         defer {
@@ -142,17 +128,14 @@ internal class Lock {
     }
 }
 
-@usableFromInline
 struct ManagedCriticalState<State> {
-  @usableFromInline
-  final class LockedBuffer: ManagedBuffer<State, Lock.Primitive> {
+  private final class LockedBuffer: ManagedBuffer<State, Lock.Primitive> {
     deinit {
       withUnsafeMutablePointerToElements { Lock.deinitialize($0) }
     }
   }
 
-    @usableFromInline
-  let buffer: ManagedBuffer<State, Lock.Primitive>
+  private let buffer: ManagedBuffer<State, Lock.Primitive>
 
   init(_ initial: State) {
     buffer = LockedBuffer.create(minimumCapacity: 1) { buffer in
@@ -161,7 +144,6 @@ struct ManagedCriticalState<State> {
     }
   }
 
-    @inlinable
   func withCriticalRegion<R>(_ critical: (inout State) throws -> R) rethrows -> R {
     try buffer.withUnsafeMutablePointers { header, lock in
       Lock.lock(lock)

Sources/AsyncAlgorithms/Locking.swift

@@ -0,0 +1,17 @@
+import DequeModule
+import Synchronization
+
+@available(macOS 15.0, iOS 18.0, watchOS 11.0, tvOS 18.0, visionOS 2.0, *)
+final class ManualTaskExecutor: TaskExecutor {
+    private let jobs = Mutex<Deque<UnownedJob>>(.init())
+    
+    func enqueue(_ job: UnownedJob) {
+        self.jobs.withLock { $0.append(job) }
+    }
+    
+    func run() {
+        while let job = self.jobs.withLock({ $0.popFirst() }) {
+            job.runSynchronously(on: self.asUnownedTaskExecutor())
+        }
+    }
+}