Какво се случва с паралелната опашка при стартиране на бариерен операция?

Паралелната опашка временно става последователна. Задачите, изпълнявани преди бариерата, се завършват, след което се изпълнява само задачата на бариерата. Новите задачи не се стартират, докато задачата на бариерата не приключи. След като задачата на бариерата приключи, опашката възстановява паралелното изпълнение за останалите задачи.

Пример за използване на async/await с бариера, базирана на actor:

actor SharedDataManager {
    private var data: [String] = ["Initial"]

    func addData(_ item: String) { // Мутативен метод - бариера
        data.append(item)
        print("Добавено \(item). Текущи данни: \(data)")
    }

    func processData(completion: @escaping ([String]) -> Void) { // Не мутативен
        // Не изисква бариера, може да се изпълнява паралелно с други не мутативни
        DispatchQueue.global().async {
            // Интензивна обработка...
            let result = self.data.map { $0.uppercased() }
            completion(result)
        }
    }

    func getData() -> [String] { // Не мутативен метод - не бариера
        return data
    }
}

Пример за използване на Grand Central Dispatch (GCD) с бариера:

let concurrentQueue = DispatchQueue(label: "com.example.concurrentQueue", attributes: .concurrent)

func performTasks() {
    concurrentQueue.async {
        print("Задача 1 започна")
        Thread.sleep(forTimeInterval: 1) // Имитация на работа
        print("Задача 1 приключи")
    }

    concurrentQueue.async {
        print("Задача 2 започна")
        Thread.sleep(forTimeInterval: 1)
        print("Задача 2 приключи")
    }

    // Задача на бариерата
    concurrentQueue.async(flags: .barrier) {
        print("Задача на бариерата започна")
        Thread.sleep(forTimeInterval: 2) // Имитация на работа, изискваща ексклузивен достъп
        print("Задача на бариерата приключи")
    }

    // Други задачи
    concurrentQueue.async {
        print("Задача 3 започна")
        Thread.sleep(forTimeInterval: 1)
        print("Задача 3 приключи")
    }

    concurrentQueue.async {
        print("Задача 4 започна")
        Thread.sleep(forTimeInterval: 1)
        print("Задача 4 приключи")
    }
}

// Изходът ще покаже, че задачите 3 и 4 започват само след като задачата на бариерата приключи.