Ҳангоми оғозёбии амалиёти монеа, чӣ мешавад бо…

Паралельная очередь временно становится последовательной. Выполняющиеся до барьера задачи завершаются, затем выполняется только барьерная задача. Новые задачи не запускаются до завершения барьера. После завершения барьерной задачи очередь восстанавливает параллельное выполнение для оставшихся задач.

Пример использования 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 завершена")
    }
}

// Вывод покажет, что задачи Task 3 и Task 4 начинаются только после завершения Барьерной задачи.

Ҳангоми оғозёбии амалиёти монеа, чӣ мешавад бо навбати параллелӣ?