windwalker-io
diff --git a/‎packages/queue/src/Driver/DatabaseQueueDriver.php‎
Lines changed: 2 additions & 0 deletions b/‎packages/queue/src/Driver/DatabaseQueueDriver.php‎
Lines changed: 2 additions & 0 deletions
@@ -105,6 +105,8 @@ function (Query $query) use ($now) {
                         ->where('reserved', '<', $now->modify('-' . $this->timeout . 'seconds'));
                 }
             )
+            ->order('visibility', 'ASC')
+            ->order('id', 'ASC')
             ->forUpdate($do);
 
         $data = $this->db->transaction(
Original file line number	Diff line number	Diff line change
`@@ -105,6 +105,8 @@ function (Query $query) use ($now) {`
`105`	`105`	`->where('reserved', '<', $now->modify('-' . $this->timeout . 'seconds'));`
`106`	`106`	`}`
`107`	`107`	`)`
	`108`	`+ ->order('visibility', 'ASC')`
	`109`	`+ ->order('id', 'ASC')`
`108`	`110`	`->forUpdate($do);`
`109`	`111`
`110`	`112`	`$data = $this->db->transaction(`