Воркеры

Словом «воркер» называют три несвязанные вещи. У них общее только название — поэтому имеет смысл сначала их развести.

Проверка: спросите, что он потребляет. Обработчик очереди потребляет очередь, Web Worker — сообщения, которые вы ему шлёте, Service Worker — события fetch. Задача не потребляет ничего: она просыпается по таймеру и выполняется.

Обе кнопки запускают одну и ту же функцию: декодировать изображение, уменьшить его и пройти по каждому пикселю, собирая гистограмму цветов. Отличается только поток выполнения. Следите за индикатором, а не за палитрой.

Путь через воркер передаёт ArrayBuffer, а не копирует его: postMessage(data, [buffer]) передаёт владение и обнуляет копию отправителя. На большой фотографии это разница между копированием и передачей указателя — и самая часто упускаемая часть API.

Исходящая очередь уведомлений — настоящая таблица-очередь, а это её потребитель. Работа забирается одной атомарной командой: строки блокируются, помечаются и возвращаются вместе, поэтому два воркера не могут взять одну и ту же строку.

UPDATE notifications.notification_deliveries AS d
SET status = 'processing',
    attempts = d.attempts + 1,
    attempted_at = now()
FROM (
    SELECT id
    FROM notifications.notification_deliveries
    WHERE status = 'pending'
      AND next_attempt_at <= now()
    ORDER BY next_attempt_at, created_at
    LIMIT $1
    FOR UPDATE SKIP LOCKED
) AS c
WHERE d.id = c.id
RETURNING d.id, d.channel, d.attempts;

Текущая глубина очереди

Счётчик попыток служит и токеном ограждения. Если воркер умирает во время отправки, сборщик возвращает строку в очередь после истечения срока захвата — а поскольку повторный захват увеличивает счётчик, запоздалая запись мёртвого воркера уже не совпадает и отбрасывается, вместо того чтобы испортить строку.

Фоновая работа в этом проекте состоит из задач, а не из воркеров. Это различие не придирка — оно решает, нужна ли вам очередь вообще.

Всё запланированное здесь именно проталкивается, а не вытягивается: cron, интервал или клик администратора прямо называют работу. Смотрите витрину задач.