laravel horizon pending任务中存在已完成的任务

<?php

namespace App\Horizon\Repositories;

use App\Managers\RedisKeyManager;
use Illuminate\Support\Facades\Log;
use Laravel\Horizon\JobPayload;
use Laravel\Horizon\Repositories\RedisJobRepository as HorizonRedisJobRepository;
use RedisException;

class RedisJobRepository extends HorizonRedisJobRepository
{
    /**
     * 保留
     *
     * @param $connection
     * @param $queue
     * @param JobPayload $payload
     * @return void
     * @throws RedisException
     */
    public function reserved($connection, $queue, JobPayload $payload): void
    {
        // 循環總時長
        $totalTime = 0;

        // 如果horizon的任務不是pending狀態
        while ('pending' !== redis_horizon()->hget($payload->id(), 'status')) {
            // 如果循環時間大於等於1s
            if ($totalTime >= 1000000) {
                break;
            }

            // 睡5ms
            usleep(5000);

            $totalTime += 5000;
        }

        if ($totalTime && config('c.horizon_pending_update_delay_log')) {
            Log::debug('Horizon pending狀態等待更新延遲時間:' . ($totalTime / 1000) . 'ms');
        }

        parent::reserved($connection, $queue, $payload);
    }
}
Copy

$this->app->singleton(JobRepository::class, RedisJobRepository::class);Copy