Joseph

/** * 移动延迟任务 * * @param string $from * @param string $to * @param bool $attempt */ public function migrateExpiredJobs($from, $to, $attempt = true) { $this->redis->watch($from); $time = time(); $limit...

/** * 获取所有到期任务 * * @param string $from * @param int $time * @return array */ protected function getExpiredJobs($from, $time, $options = []) { return $this->redis->zRangeByScore($from, '-inf', $time, $options); }