タイミングウィンドウがないように、注文を変更する必要があります。
コンシューマーPOP(各コンシューマーには一意の$ Consumer_idがあります)
Update queue
set last_pop = '$consumer_id'
where last_pop is null
order by id limit 1;
$job =
Select * from queue
where last_pop = '$consumer_id'
order by id desc
limit 1;
サプライヤープッシュ
insert into queue
(id, last_pop, ...)
values
(NULL, NULL, ...);
キューはid列によって時間どおりに並べ替えられ、POP時にconsumer_idに割り当てられます。