Simplify

Author: dfed

Sources/AsyncQueue/ActorQueue.swift

@@ -42,28 +42,29 @@ public final class ActorQueue: Sendable {
 
         streamTask = Task.detached(priority: priority) {
             actor ActorExecutor {
-                func seriallyExecute(_ task: @escaping @Sendable () async -> Void) async {
+                func suspendUntilStarted(_ task: @escaping @Sendable () async -> Void) async {
                     let semaphore = Semaphore()
-                    Task {
-                        await self.execute(task, afterSignaling: semaphore)
-                    }
-                    // Wait for the task to start.
+                    executeWithoutWaiting(task, afterSignaling: semaphore)
+                    // Suspend the calling code until our enqueued task starts.
                     await semaphore.wait()
                 }
 
-                private func execute(
+                private func executeWithoutWaiting(
                     _ task: @escaping @Sendable () async -> Void,
-                    afterSignaling semaphore: Semaphore
-                ) async {
-                    // Signal that the task has started.
-                    await semaphore.signal()
-                    await task()
+                    afterSignaling semaphore: Semaphore)
+                {
+                    // Utilize the serial (but not FIFO) Actor context to execute the task without requiring the calling method to wait for the task to complete.
+                    Task {
+                        // Now that we're back within the serial Actor context, signal that the task has started.
+                        await semaphore.signal()
+                        await task()
+                    }
                 }
             }
 
             let executor = ActorExecutor()
             for await task in taskStream {
-                await executor.seriallyExecute(task)
+                await executor.suspendUntilStarted(task)
             }
         }
     }

Sources/AsyncQueue/Semaphore.swift

@@ -29,7 +29,7 @@ actor Semaphore {
             return
         }
 
-        await withCheckedContinuation { continuation in
+        await withUnsafeContinuation { continuation in
             continuations.append(continuation)
         }
     }
@@ -52,6 +52,6 @@ actor Semaphore {
         count < 0
     }
 
-    private var continuations = [CheckedContinuation<Void, Never>]()
+    private var continuations = [UnsafeContinuation<Void, Never>]()
     private var count = 0
 }