SKIP LOCKED в PostgreSQL

27.08.2024

PostgreSQL

Комментариев нет

SKIP LOCKED — это опция в SELECT ... FOR UPDATE и SELECT ... FOR SHARE, которая позволяет игнорировать заблокированные строки. Это полезно для организации конкурентной обработки данных, когда несколько потоков (или процессов) обрабатывают записи без конфликтов.

Пример использования

Допустим, у нас есть таблица tasks, и несколько процессов выбирают задачи для обработки.

CREATE TABLE tasks (
    id SERIAL PRIMARY KEY,
    description TEXT,
    status TEXT DEFAULT 'pending'
);

CREATE TABLE tasks (

id SERIAL PRIMARY KEY,

description TEXT,

status TEXT DEFAULT 'pending'

);

Добавим несколько задач:

INSERT INTO tasks (description) VALUES
    ('Task 1'), ('Task 2'), ('Task 3');

INSERT INTO tasks (description) VALUES

('Task 1'), ('Task 2'), ('Task 3');

Теперь представим, что два процесса читают задачи одновременно. Если мы просто сделаем:

SELECT * FROM tasks WHERE status = 'pending' FOR UPDATE;

1 2	SELECT * FROM tasks WHERE status = 'pending' FOR UPDATE;

Обе транзакции могут попытаться заблокировать одни и те же строки, что приведёт к блокировке ожидания (deadlock).

Используем SKIP LOCKED, чтобы избежать ожидания:

BEGIN;
SELECT * FROM tasks WHERE status = 'pending' FOR UPDATE SKIP LOCKED LIMIT 1;
UPDATE tasks SET status = 'processing' WHERE id = 1;
COMMIT;

BEGIN;

SELECT * FROM tasks WHERE status = 'pending' FOR UPDATE SKIP LOCKED LIMIT 1;

UPDATE tasks SET status = 'processing' WHERE id = 1;

COMMIT;

FOR UPDATE – блокирует строку, чтобы другие транзакции её не выбрали.
SKIP LOCKED – пропускает заблокированные строки, чтобы избежать ожидания.
LIMIT 1 – берём только одну задачу для обработки.

Когда полезно SKIP LOCKED?

Очереди задач – распределение работы между процессами без конфликтов.
Балансировка нагрузки – эффективное управление обработкой записей.
Избежание блокировок – процессы не ждут разблокировки данных.

Но не используйте SKIP LOCKED для обычных выборок, так как он может пропускать важные записи, если они заблокированы.

postgresql skip locked

SKIP LOCKED в PostgreSQL

27.08.2024

PostgreSQL

Комментариев нет

Пример использования

Recommended Posts

Transactional Outbox таблица PostgreSQL

Описание плейбука Ansible по развертыванию кластера Postgresql + Patroni + Pgbouncer

Пояснение конфига для Pgbouncer

Добавить комментарий Отменить ответ