当您想使用 postgres 的 SELECT FOR UPDATE SKIP LOCKED 功能来确保从表中读取并声明任务的两个不同用户不会被彼此阻塞并且也不会得到另一个用户已经读取的任务:
查询中正在使用连接来检索任务。除了包含主要信息的表之外,我们不希望任何其他表具有行级锁定。下面的示例查询 - 仅锁定表中的行 - 以下查询中的“任务”
SELECT v.someid , v.info, v.parentinfo_id, v.stage FROM task v, parentinfo pi WHERE v.stage = 'READY_TASK'
AND v.parentinfo_id = pi.id
AND pi.important_info_number = (
SELECT MAX(important_info_number) FROM parentinfo )
ORDER BY v.id limit 200 for update skip locked;
现在,如果用户 A 正在检索该表的大约 200 行,则用户 B 应该能够检索另一组 200 行。
编辑:根据下面的评论,查询将更改为:
SELECT v.someid , v.info, v.parentinfo_id, v.stage FROM task v, parentinfo pi WHERE v.stage = 'READY_TASK'
AND v.parentinfo_id = pi.id
AND pi.important_info_number = (
SELECT MAX(important_info_number) FROM parentinfo) ORDER BY v.id limit 200 for update of v skip locked;
如何最好地下订单以便对行进行排序?虽然如果多个用户调用此命令,该命令将生效,但仍应维护正在返回的行的一些顺序神圣性。
此外,这是否还确保调用相同选择查询的多个线程将检索一组不同的行,或者仅对更新命令进行锁定?