Breaking async code in Swift

AsyncBroken.swift

import PlaygroundSupport
import Foundation

class Worker {
    
    private let queue = DispatchQueue.global(qos: .background)
    private let serialQueue = DispatchQueue(label: "com.acme.serial")
    public private(set) var count = 0
    
    func incrementCount() {
        serialQueue.sync {
            count += 1
        }
    }
    
    func work() {
        let workItem = DispatchWorkItem() { [weak self] in
            guard let s = self else { return }
            s.incrementCount()
            print("🔵 Work [\(s.count)]")
        }
        
        queue.async(execute: workItem)
        
        workItem.wait()
    }
    
}

let worker = Worker()
let queue1 = DispatchQueue(label: "com.acme.queue1", attributes: .concurrent)
let queue2 = DispatchQueue(label: "com.acme.queue2", attributes: .concurrent)
let queue3 = DispatchQueue(label: "com.acme.queue3", attributes: .concurrent)
let range = 0..<5
queue1.async {
    range.forEach { _ in
        worker.work()
        print("🔴 Done [\(worker.count)]")
    }
}
queue2.async {
    range.forEach { _ in
        worker.work()
        print("🔴 Done [\(worker.count)]")
    }
}
queue3.async {
    range.forEach { _ in
        worker.work()
        print("🔴 Done [\(worker.count)]")
    }
}

PlaygroundPage.current.needsIndefiniteExecution = true

AsyncWorking.swift

// Always return the current value from the work item to get the correct value.

import PlaygroundSupport
import Foundation

class Worker {
    
    private let workerQueue = DispatchQueue(label: "com.acme.worker")
    private let serialQueue = DispatchQueue(label: "com.acme.serial")
    private var count = 0
    
    func incrementCount() {
        serialQueue.sync {
            count += 1
        }
    }
    
    func value() -> Int {
        return serialQueue.sync {
            count
        }
    }
    
    func work() -> Int {
        var currentCount = 0
        let workItem = DispatchWorkItem() { [weak self] in
            guard let s = self else { return }
            s.incrementCount()
            print("🔵 Work [\(s.value())]")
            currentCount = s.value()
        }
        
        workerQueue.async(execute: workItem)
        
        workItem.wait()
        return currentCount
    }
    
}

let worker = Worker()
let queue1 = DispatchQueue(label: "com.acme.queue1", attributes: .concurrent)
let queue2 = DispatchQueue(label: "com.acme.queue2", attributes: .concurrent)
let queue3 = DispatchQueue(label: "com.acme.queue3", attributes: .concurrent)
let range = 0..<5
queue1.async {
    range.forEach { _ in
        let count = worker.work()
        print("🔴 Done [\(count)]")
    }
}
queue2.async {
    range.forEach { _ in
        let count = worker.work()
        print("🔴 Done [\(count)]")
    }
}
queue3.async {
    range.forEach { _ in
        let count = worker.work()
        print("🔴 Done [\(count)]")
    }
}

PlaygroundPage.current.needsIndefiniteExecution = true

Serialously.swift

import PlaygroundSupport
import Foundation

class Worker {
    
    private let workerQueue = DispatchQueue(label: "com.acme.worker")
    private let serialQueue = DispatchQueue(label: "com.acme.serial")
    private var count = 0
    
    func incrementCount() {
        serialQueue.sync {
            count += 1
        }
    }
    
    func value() -> Int {
        return serialQueue.sync {
            count
        }
    }
    
    func work() {
        let workItem = DispatchWorkItem() { [weak self] in
            guard let s = self else { return }
            s.incrementCount()
            print("🔵 Work [\(s.value())]")
        }
        
        workerQueue.async(execute: workItem)
        
        workItem.wait()
    }
    
}

let worker = Worker()
let queue1 = DispatchQueue(label: "com.acme.queue1", attributes: .concurrent)
let queue2 = DispatchQueue(label: "com.acme.queue2", attributes: .concurrent)
let queue3 = DispatchQueue(label: "com.acme.queue3", attributes: .concurrent)
let range = 0..<5
queue1.async {
    range.forEach { _ in
        worker.work()
        print("🔴 Done [\(worker.value())]")
    }
}
queue2.async {
    range.forEach { _ in
        worker.work()
        print("🔴 Done [\(worker.value())]")
    }
}
queue3.async {
    range.forEach { _ in
        worker.work()
        print("🔴 Done [\(worker.value())]")
    }
}

PlaygroundPage.current.needsIndefiniteExecution = true