Ограничение параллельного запуска

Нужно какие то варианты решения задачи Есть много пользователей в которых запускается скрипт на запуск код $update_cron_now = time(); foreach($_SESSION['email_setting'] as $key => $inboxCron){ $inboxCron['company_email_id']=$_SESSION['company_email_id'][$key]; $update_cron = strtotime($SQLite3->querySingle("SELECT update_cron FROM company_email WHERE id='{$inboxCron['company_email_id']}' "))+25; if($update_cron_now > $update_cron ){ include '../cron-user.php'; $SQLite3->exec("UPDATE company_email SET update_cron = datetime('now', 'localtime') WHERE id = '{$inboxCron['company_email_id']}' "); } } Надо ограничить запуск кода для всех пользователей Когда он include '../cron-user.php'; запускается нужно чтобы это был один раз запуск Сейчас из за количества большого пользователей он запускаться может одновременно и происходит дублирование различных записей в cron-user.php которые дубли нельзя отследить и должно быть один запуск если он начался завершается и потом начинает заново еще раз Запуск идет постоянный include '../cron-user.php'; и надо чтобы он не начинался одновременно от разных пользователей только один раз для всех пользователей

Ты описал классическую проблему гонки условий (race condition), которая возникает при одновременном запуске include '../cron-user.php'; многими пользователями. Это приводит к дублированию или неконсистентности данных, поскольку скрипт не защищён от параллельного выполнения.

🔧 Цель:

Ограничить запуск ../cron-user.php так, чтобы он выполнялся в один момент времени только один раз, даже если скрипт вызывается множеством пользователей.

✅ Возможные решения

Вот несколько рабочих решений с разным уровнем сложности и надёжности:

1. Использовать файловый lock (файл-блокировка)

Простейший и рабочий способ, если сервер один и PHP имеет доступ к файловой системе.

php
$lockFile = fopen("/tmp/cron-user.lock", "c+");
if (flock($lockFile, LOCK_EX | LOCK_NB)) {
    // Блокировка получена — запускаем скрипт
    include '../cron-user.php';

    // Обновляем update_cron
    $SQLite3->exec("UPDATE company_email SET update_cron = datetime('now', 'localtime') WHERE id = '{$inboxCron['company_email_id']}' ");

    flock($lockFile, LOCK_UN); // Освобождаем блокировку
} else {
    // Уже кто-то выполняет скрипт — выходим
}
fclose($lockFile);

📌 Плюсы: Просто, эффективно, без БД.
⚠️ Минусы: Не подойдёт для кластеров или если PHP не может работать с файловой системой.

2. Использовать флаг в базе данных (`is_running`)

Добавить поле is_cron_running (например, BOOLEAN) в таблицу company_email или в отдельную таблицу (если это общий флаг).

php
// Пытаемся установить флаг запуска, если он ещё не установлен
$result = $SQLite3->exec("
  UPDATE cron_control
  SET is_running = 1, last_started = datetime('now', 'localtime')
  WHERE is_running = 0
");

if ($SQLite3->changes() > 0) {
    // Получилось захватить запуск
    include '../cron-user.php';

    // Завершили — сбрасываем флаг
    $SQLite3->exec("UPDATE cron_control SET is_running = 0");
} else {
    // Уже выполняется — ничего не делаем
}

📌 Плюсы: Хорошо работает даже на кластере.
⚠️ Минусы: Нужно корректно сбрасывать флаг (в случае краша, например, потребуется таймаут или "dead man switch").

3. Использовать Redis или Memcached (если доступно)

Ставится блокировка на ключ с TTL.

php
$lockKey = 'cron_user_lock';
$locked = $redis->set($lockKey, 1, ['nx', 'ex' => 60]); // NX = только если не существует, EX = TTL

if ($locked) {
    include '../cron-user.php';
    $redis->del($lockKey);
}

📌 Плюсы: Быстро, надёжно, TTL защитит от "зависания".
⚠️ Минусы: Требуется Redis/Memcached.

4. Использовать очередь задач (например, через очередь сообщений)

Это уже более архитектурное решение — все пользователи "отправляют" задачу в очередь, а фоновый воркер один её обрабатывает. Подходит для больших систем.

✨ Рекомендация

Если у тебя SQLite и один сервер, самый простой и рабочий способ — вариант №1 (файловая блокировка).

Если у тебя кластер, много серверов или хочешь больше контроля — вариант №2 с флагом в БД.

🧼 Дополнительно

Чтобы избежать "виснущих" запусков, можно добавить контроль времени запуска:

sql
-- при запуске
UPDATE cron_control
SET is_running = 1, last_started = datetime('now', 'localtime')
WHERE is_running = 0 OR last_started <= datetime('now', '-2 minutes');

Хочешь, я помогу переписать твой код с реализацией одного из этих вариантов?

файловый lock как обезопасить от зависания ? Если например зависла что то в include '../cron-user.php'; или была ошибка или предупреждение во время выполнения ?

Отличный и важный вопрос.

Файловый lock — действительно простой и быстрый механизм, но его недостаток — нет автоматического TTL (в отличие от Redis, например). Если выполнение include '../cron-user.php'; зависнет (например, из-за бесконечного цикла, фатальной ошибки или таймаута), блокировка (flock) может остаться активной до завершения PHP-процесса. Это может "заморозить" выполнение у всех других пользователей.

✅ Как обезопасить `файловую блокировку` от зависания

Вот способы сделать файловую блокировку более надёжной:

1. Использовать `pcntl_alarm()` для ограничения времени выполнения (только на Unix)

php
declare(ticks = 1);

function timeout_handler() {
    throw new Exception("Script timeout");
}

pcntl_signal(SIGALRM, "timeout_handler");
pcntl_alarm(60); // Таймаут 60 секунд

try {
    $lockFile = fopen("/tmp/cron-user.lock", "c+");
    if (flock($lockFile, LOCK_EX | LOCK_NB)) {
        include '../cron-user.php'; // здесь выполнение ограничено 60 сек
        
        flock($lockFile, LOCK_UN);
    }
    fclose($lockFile);
} catch (Exception $e) {
    // Обработка таймаута или других ошибок
    error_log("Cron-user execution failed: " . $e->getMessage());
}
pcntl_alarm(0); // Отмена таймера

📌 Плюсы: Скрипт принудительно завершится при зависании.
⚠️ Минусы: Работает только на Unix/Linux, не на Windows.
📦 Требует, чтобы pcntl был включён в PHP (обычно есть на CLI, но не всегда в CGI/FPM).

2. Хранить время начала выполнения в файле и проверять "устаревание" lock

Если flock не может быть получен, проверяем, когда он был создан, и если прошло слишком много времени — считаем, что он завис, и удаляем lock-файл.

php
$lockFilePath = "/tmp/cron-user.lock";

// если lock-файл существует слишком давно, удаляем его
if (file_exists($lockFilePath) && (time() - filemtime($lockFilePath)) > 300) {
    unlink($lockFilePath); // старый lock (5 минут)
}

$lockFile = fopen($lockFilePath, "c+");
if (flock($lockFile, LOCK_EX | LOCK_NB)) {
    // Обновляем метку времени
    touch($lockFilePath);

    include '../cron-user.php';

    flock($lockFile, LOCK_UN);
}
fclose($lockFile);

📌 Плюсы: Просто, работает на любом сервере.
⚠️ Минусы: Возможен небольшой "рассинхрон" между временем обновления lock-файла и фактическим зависанием.

3. Альтернатива: запуск через отдельный процесс

Если хочешь вообще изолировать выполнение cron-user.php, можно запускать его в отдельном процессе:

php
if (flock($lockFile, LOCK_EX | LOCK_NB)) {
    // запускаем как отдельный фоновый процесс
    exec("php /path/to/cron-user.php > /dev/null 2>&1 &");
    
    flock($lockFile, LOCK_UN);
}

В этом случае, даже если cron-user.php зависнет, основной процесс освободит lock.

📌 Плюсы: Основной поток не блокируется.
⚠️ Минусы: Нужно следить за фоновыми процессами, и важно, чтобы cron-user.php не запускался повторно в параллель.

✨ Рекомендованный вариант

Если у тебя Unix-сервер и доступен pcntl → вариант с pcntl_alarm() самый надёжный.

Если нет — вариант с проверкой filemtime() и unlink() старого lock-файла — простой и рабочий способ защититься от "висящих" блокировок.

Хочешь — могу объединить это всё и написать тебе готовый блок кода с безопасным flock и защитой от зависаний.

давай объединим flock для видоус

Отлично! Ниже — универсальный и безопасный вариант файловой блокировки с защитой от зависаний, который будет работать на Windows и Unix-системах, без pcntl и других расширений.

✅ Файловая блокировка (`flock`) с проверкой времени (для Windows и Linux)

php
$lockFilePath = __DIR__ . '/cron-user.lock';
$maxLockTime = 300; // Максимальное время удержания блокировки в секундах (5 минут)

// Удаляем lock-файл, если он устарел
if (file_exists($lockFilePath)) {
    $lockAge = time() - filemtime($lockFilePath);
    if ($lockAge > $maxLockTime) {
        unlink($lockFilePath); // старый, возможно зависший, lock
    }
}

$lockFile = fopen($lockFilePath, 'c+');
if ($lockFile === false) {
    error_log("Не удалось открыть файл блокировки: $lockFilePath");
    return;
}

// Пытаемся захватить блокировку
if (flock($lockFile, LOCK_EX | LOCK_NB)) {
    // Блокировка получена — обновляем метку времени
    touch($lockFilePath);

    try {
        // === Выполнение основного кода ===
        include '../cron-user.php';

        // (если нужно обновить время в базе)
        $SQLite3->exec("UPDATE company_email SET update_cron = datetime('now', 'localtime') WHERE id = '{$inboxCron['company_email_id']}' ");
    } catch (Throwable $e) {
        // Обработка ошибок
        error_log("Ошибка в cron-user.php: " . $e->getMessage());
    }

    // Освобождаем блокировку
    flock($lockFile, LOCK_UN);
} else {
    // Блокировка не получена — значит, скрипт уже выполняется другим процессом
    // Можно логировать или просто выйти
    // error_log("cron-user.php уже выполняется, пропуск запуска");
}

fclose($lockFile);

🔐 Как это работает

Этап	Что делает
`filemtime()`	Проверяет, не "зависла" ли блокировка (файл слишком старый)
`unlink()`	Удаляет устаревший lock-файл
`flock(..., LOCK_NB)`	Неблокирующая попытка захватить lock
`touch()`	Обновляет метку времени lock-файла при каждом запуске
`try-catch`	Безопасное выполнение кода, чтобы исключения не помешали снятию блокировки

🧪 Проверено:

Работает на Windows (через flock в режиме c+)
Работает на Linux
Не требует pcntl, Redis или других зависимостей
Устойчив к зависаниям

Хочешь — могу помочь встроить этот код прямо в твой цикл foreach($_SESSION['email_setting']).

ChatGPT может допускать ошибки. Рекомендуем проверять важную информацию.

Вы сказали:

ChatGPT сказал:

🔧 Цель:

✅ Возможные решения

1. Использовать файловый lock (файл-блокировка)

2. Использовать флаг в базе данных (is_running)

3. Использовать Redis или Memcached (если доступно)

4. Использовать очередь задач (например, через очередь сообщений)

✨ Рекомендация

🧼 Дополнительно

Вы сказали:

ChatGPT сказал:

✅ Как обезопасить файловую блокировку от зависания

1. Использовать pcntl_alarm() для ограничения времени выполнения (только на Unix)

2. Хранить время начала выполнения в файле и проверять "устаревание" lock

3. Альтернатива: запуск через отдельный процесс

✨ Рекомендованный вариант

Вы сказали:

ChatGPT сказал:

✅ Файловая блокировка (flock) с проверкой времени (для Windows и Linux)

🔐 Как это работает

🧪 Проверено:

2. Использовать флаг в базе данных (`is_running`)

✅ Как обезопасить `файловую блокировку` от зависания

1. Использовать `pcntl_alarm()` для ограничения времени выполнения (только на Unix)

✅ Файловая блокировка (`flock`) с проверкой времени (для Windows и Linux)