Как работает Dispatch Barrier?

Как работает Dispatch Barrier в GCD

Dispatch Barrier — это специальный механизм в Grand Central Dispatch (GCD) для контроля порядка выполнения задач в concurrent queue (параллельной очереди). Его основная цель — обеспечить монопольный доступ к ресурсу для одной задачи, временно превращая параллельную очередь в последовательную.

Основная идея

В обычной параллельной очереди задачи выполняются одновременно на разных потоках. Если несколько задач пытаются читать и изменять общий ресурс (например, массив или файл), возникают race conditions. Barrier блокирует это, создавая "точку синхронизации".

Механизм работы

1. До барьерной задачи: все задачи, добавленные в очередь до barrier, выполняются параллельно как обычно.
2. Барьерная задача: когда очередь встречает barrier task, она:
   • Ждет завершения всех предыдущих задач.
   • Затем выполняет барьерную задачу в одиночку (никакие другие задачи не выполняются параллельно с ней).
3. После барьерной задачи: все задачи, добавленные после barrier, начинают выполняться параллельно после завершения барьерной задачи.

Ключевые особенности

• Работает только с custom concurrent queues (созданными через DispatchQueue(label: ..., attributes: .concurrent)).
• Не работает с global queues и serial queues.
• Barrier гарантирует, что барьерная задача — единственная, выполняемая в момент её работы.

Практический пример

Рассмотрим ситуацию с чтением/записью в общий массив:

class DataManager {
    private var data: [String] = []
    private let queue = DispatchQueue(label: "com.example.datamanager", attributes: .concurrent)
    
    func readData(completion: @escaping ([String]) -> Void) {
        queue.async {
            completion(self.data) // Множество чтений может происходить параллельно
        }
    }
    
    func writeData(newElement: String) {
        queue.async(flags: .barrier) { // Барьерная задача
            self.data.append(newElement) // Запись происходит в одиночку
        }
    }
}

Как это реализовано внутри

Barrier использует внутренний механизм блокировки очереди:

1. Когда система видит .barrier, она устанавливает "барьерный флаг" для очереди.
2. Планировщик GCD останавливает запуск новых задач из этой очереди.
3. После выполнения всех активных задач запускается барьерная задача.
4. После её завершения барьерный флаг снимается, и очередь возвращается к параллельному режиму.

Сценарии использования

• Модификация общего ресурса: когда нужно безопасно изменить данные, используемые многими потоками.
• Обновление состояния: например, переключение режима работы (с read-only на write-mode).
• Синхронизация конфигурации: изменение настроек, влияющих на все последующие операции.

Важные ограничения

// Это НЕ будет работать как барьер:
DispatchQueue.global().async(flags: .barrier) { ... }

// Это будет работать:
let customQueue = DispatchQueue(label: "test", attributes: .concurrent)
customQueue.async(flags: .barrier) { ... }

Альтернативы и сравнение

• Serial queue: всегда последовательная, но не позволяет параллельным чтениям.
• Семафоры (DispatchSemaphore): более низкоуровневый контроль, но сложнее в управлении.
• Акторы (Actor): в Swift 5.5 предоставляют похожую безопасность на уровне языка.

Barrier — это эффективный компромисс между производительностью (параллельные чтения) и безопасностью (монопольные записи). Он позволяет оптимизировать работу с ресурсами в многопоточной среде без полной последовательности выполнения.