LenicsДобрый вечер. С блокировками, транзакциями и аналогичным, работать не приходилось. На днях искал решение задачи, но так и не добился положительных результатов или полного представления того, что мне всеж необходимо точно и как это найти.

Ситуация вот в чем. Имеется у меня дерево задач, у каждой ID автоинкримент. Имеется 5-ть обработчиков, которые выполняют работу с данным списком параллельно.

Принцип работы заключается в том, что каждый из них запрашивает строку, где статус выполнения = 0, и где демон_айди = 0, Limit 1.

После, присваивают по ID строки свой демон_айди и спокойно с ней работают. Видел некий набор типовых рекомендаций, для того, чтобы исключить выполнения работы с данной строкой несколькими демонами.
Самое интересно и простое в моем понимание было предложение использовать SELECT FOR UPDATE. Провел опыты, сделал запрос данного вида одним демоном, после не выполняя обновление каких-то данных данным демоном выполнил запрос вторым демоном. В итоге - он несмотря ни на какие FOR UPDATE спокойно взял данную строку и стал ее использовать.

Т.е. вариант, по каким-то причинам не проканал, либо я его не совсем верно понял.

В моем понимании, чтобы не было в случае каких-либо ошибок заблокированной пол таблицы, для меня, наверно, было бы оптимальнее всего просто при первом обращении к строке выполнять ее блокировку на некоторое время, к примеру, до 5-ть секунд, или до выполнения UPDATE ее, указывая явный ее ID. Чтобы, в это время, все остальные демоны просто проходили ее мимо.

Возможно, Вы предложите какие-то другие идеи по реализации, буду благодарен. Единственное, по возможности, предоставьте ответ чуть более развернутый, так как повторюсь - для меня такая задача совсем новая.


Таблица - InnoDB

Спасибо.


...вариантов несколько, напромер (на мой взгляд) самый простой:

1. выполнить апдейт

update table1
set daemon_id = <THIS_DAEMON_ID> -- ИД конкретного демона
,status = 'INPROGRESS'
where daemon_id in null -- незанятые задачи
and status = 'CREATED' -- надо продумать стейт-машину
order by insert_time --- взять первый по времени создания задачи
limit 1

далее:
проверить что UPDATE_COUNT равен 1, если нет -- повторить через 30 секунд --
например если свободных задач пока нет

затем

select *
from table 1
where
daemon_id = <THIS_DAEMON_ID> -- ИД конкретного демона
,status = 'INPROGRESS'

и спокойно работать над задачей....