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

这是我目前暂时的解决方案 通过重写保留方法 来判断状态是否为pending状态 如果不是则睡5ms 重新检测一次 直到1秒后如果还拿不到就不管这个了 但是1秒后还拿不到的情况几乎为0 我这边通过日志分析最大的延迟才45ms 测试了一下 大概执行了100万个任务 有8万个左右有延迟 基本都是5ms以内 看服务器redis的负载情况吧
github.com/laravel/horizon/issues/...

<?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);
    }
}

然后在服务提供者里面覆盖原有的注册的单例

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