Blocking Task

TaskQueue.swift

// TaskQueue.swift

import Foundation

class TaskQueue {
    private actor TaskQueueActor {
        private var blocks = [() async -> Void]()
        private var currentTask: Task<Void, Never>?
        
        func addBlock(priority: TaskPriority? = nil, block: @escaping () async -> Void) {
            blocks.append(block)
            next(priority: priority)
        }
        
        func next(priority: TaskPriority? = nil) {
            guard currentTask == nil, !blocks.isEmpty else { return }
            
            let block = blocks.removeFirst()
            currentTask = Task(priority: priority) {
                await block()
                currentTask = nil
                next(priority: priority)
            }
        }
    }
    
    private let taskQueueActor = TaskQueueActor()
    
    func dispatch(priority: TaskPriority? = nil, block: @escaping () async -> Void) {
        Task(priority: priority) {
            await taskQueueActor.addBlock(block: block)
        }
    }
}