Какие знаешь примитивы синхронизации?

Примитивы синхронизации в PHP (Backend Context)

Как backend-разработчик PHP с фокусом на многопоточность и конкурентность, я глубоко понимаю примитивы синхронизации, хотя стоит отметить, что традиционный PHP (в контексте веб-запросов) использует shared-nothing архитектуру, где каждый запрос обрабатывается изолированно. Однако при работе с PHP CLI (например, воркеры, демоны, очереди задач), расширениями для многопоточности (pthreads, parallel) или при взаимодействии с внешними системами (базы данных, кэш, файловая система) понимание синхронизации критически важно.

Ключевые примитивы синхронизации

1. Мьютексы (Mutex, Mutual Exclusion)

Мьютекс — базовый примитив для обеспечения взаимного исключения доступа к общему ресурсу. В PHP его можно реализовать через:

• Расширение pthreads (для многопоточности)
• Файловые блокировки (flock) для синхронизации между процессами
• Внешние системы (Redis, Memcached, базы данных) для распределённой синхронизации

// Пример с использованием flock (межпроцессная синхронизация)
$fp = fopen('/tmp/lockfile', 'w+');
if (flock($fp, LOCK_EX)) { // Получаем эксклюзивную блокировку
    // Критическая секция
    $counter = (int) file_get_contents('/tmp/counter.txt');
    $counter++;
    file_put_contents('/tmp/counter.txt', $counter);
    flock($fp, LOCK_UN); // Снимаем блокировку
} else {
    throw new Exception('Не удалось получить блокировку');
}
fclose($fp);

2. Семафоры (Semaphores)

Семафоры — счётчики для управления доступом к ресурсу с ограниченной ёмкостью. В PHP доступны через:

• Расширение sysvsem (System V семафоры)
• Расширение sem (для POSIX семафоров)
• Эмуляцию через Redis с атомарными операциями

// Пример с использованием sysvsem
$semKey = ftok(__FILE__, 't');
$semaphore = sem_get($semKey, 1, 0666, 1); // Максимум 1 процесс

if (sem_acquire($semaphore)) { // Захват семафора
    try {
        // Критическая секция
        // ... операции с общим ресурсом ...
    } finally {
        sem_release($semaphore); // Освобождение
    }
}

3. Условные переменные (Condition Variables)

Условные переменные позволяют потокам ждать определённых условий. В PHP доступны в расширении pthreads:

// Примерная структура с pthreads (упрощённо)
class WorkerThread extends Thread {
    private $condition;
    
    public function run() {
        $this->synchronized(function($thread) {
            while (!$thread->conditionMet) {
                $thread->wait(); // Ожидание сигнала
            }
            // Выполнение после получения сигнала
        }, $this);
    }
}

4. Блокировки чтения-записи (Read-Write Locks)

R/W блокировки оптимизируют сценарии, где чтение происходит чаще записи:

• Несколько читателей могут работать одновременно
• Писатель требует эксклюзивного доступа

// Реализация через Redis с использованием SET с NX/EX
class RedisReadWriteLock {
    public function acquireReadLock($key, $timeout = 5) {
        // Логика для получения блокировки на чтение
        // Часто реализуется через счётчик читателей
    }
    
    public function acquireWriteLock($key, $timeout = 5) {
        // Эксклюзивная блокировка для записи
        $redis = new Redis();
        return $redis->set($key, 'locked', ['nx', 'ex' => $timeout]);
    }
}

5. Спин-локи (Spinlocks)

Спин-локи — busy-wait блокировки, где поток активно проверяет доступность. В PHP реже используются из-за отсутствия native потоков, но могут применяться в расширениях.

6. Барьеры (Barriers)

Барьеры синхронизируют выполнение группы процессов/потоков в определённой точке.

Практическое применение в PHP Backend

1. Обработка очередей (Gearman, RabbitMQ) — предотвращение дублирующей обработки
2. Кэширование — предотвращение cache stampede при обновлении кэша
3. Работа с файлами — синхронизация записи в логи или конфигурации
4. Распределённые системы — координация между воркерами в разных процессах

Важные нюансы для PHP

• Отсутствие native многопоточности в веб-сценариях упрощает многие задачи синхронизации
• Межпроцессная синхронизация часто реализуется через внешние хранилища
• Deadlock prevention — критически важно при использовании блокировок
• Время ожидания (timeout) — обязательно устанавливать таймауты для блокировок
• Идемпотентность операций — предпочтительнее блокировок там, где это возможно

Выбор примитива зависит от конкретного сценария: для простых случаев достаточно файловых блокировок, для распределённых систем — Redis-based решения, для CPU-bound многопоточных задач — расширение parallel.

Понимание этих примитивов позволяет проектировать масштабируемые и надёжные backend-системы даже в экосистеме PHP, где традиционно делается упор на изоляцию запросов.