Laravel batch批量作业最后一个任务持续处于pending状态如何解决

DevOps 小满

2026-10-8

问题原因

Batch使用方式导致的竞态问题
你当前的实现逻辑是先dispatch一个空Batch，再遍历用户动态追加Job。如果队列消费速度较快，在你完成所有Job的追加操作前，已经提交的Job就全部执行完成，此时Batch的计数逻辑会出现偏差：后续追加的最后一个Job实际执行完成后，Batch的待处理计数无法正确扣减，就会出现状态卡在pending的情况。
Job缺少必要的特征（Trait）
如果你的SearchJob类没有引入Illuminate\Bus\Batchable特征，Job执行完成后无法主动通知Batch更新进度，也会出现Job实际执行完毕，但Batch仍标记其为待处理的问题。
异常处理逻辑的影响
如果你在Job内部自行捕获了所有执行异常，没有将异常抛出到队列上层，也没有手动调用Batch的对应方法更新任务状态，也会导致状态同步失败。

解决办法

调整Batch创建逻辑（最优先方案）
不要先分发空Batch再动态追加Job，而是先收集所有需要执行的Job，一次性提交给Batch后再分发，从根源上避免竞态问题。调整后代码如下：

function serverAdded() {
    $jobs = [];
    // 即使使用lazy游标，也可以逐个将Job存入数组，不会额外加载全量用户数据到内存
    foreach (User::lazy() as $user) {
        $jobs[] = new SearchJob($user);
    }

    $batch = Bus::batch($jobs)
        ->allowFailures()
        ->catch(function() { /* 异常处理逻辑 */ })
        ->then(function() { /* 完成回调逻辑 */ })
        ->dispatch();
}

检查Job类的特征引入
确保你的SearchJob类正确引入了Batchable特征，示例如下：

use Illuminate\Bus\Batchable;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;

class SearchJob implements ShouldQueue
{
    use Batchable, Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    // 你的业务逻辑
}

手动校准异常场景的状态
如果你在Job内部自行捕获了异常并标记任务失败，需要同步调用Batch的方法更新状态：

// 业务逻辑执行失败时
if ($this->batch() && !$this->batch()->cancelled()) {
    $this->batch()->recordFailedJob();
}

兜底处理方案
如果仍偶发该问题，可以添加定时任务，扫描创建时间超过2小时、待处理任务数为1、且已处理任务数+失败任务数=总任务数-1的Batch，手动调用$batch->recalculate()重新计算状态，或直接更新Batch状态为完成。

内容的提问来源于stack exchange，提问作者Martin