Apex批处理作业静态变量状态保持及多批处理连续执行方案

你踩的这个坑其实很常见——静态变量在Apex异步上下文（比如批处理、Queueable）里的行为和同步代码完全不同。因为每个异步执行都是独立的进程，静态变量属于进程级，不会在不同的异步上下文之间共享，哪怕是同一个类的静态变量也不行。而Database.Stateful的作用就是让批处理/Queueable的实例变量在异步执行的不同环节（或链式调用）中被序列化保存，这才是正确的状态传递方式。

下面给你两个无需数据库存储状态的可行方案，都是基于Stateful机制实现的：

方案一：用Stateful Queueable链式触发批处理 #

Queueable Apex本身支持Database.Stateful，而且比批处理更轻量，适合这种纯触发后续任务的场景，不需要处理任何查询数据。

代码示例 #

public class BatchJobChainer implements Queueable, Database.Stateful {
    // 把你要依次执行的批处理类名按顺序列在这里
    private List<String> targetBatchClasses = new List<String>{
        'AccountCleanupBatch', 
        'ContactSyncBatch', 
        'OpportunityRollupBatch',
        // 继续添加你的批处理类...
    };
    private Integer currentExecutionIndex = 0;

    public void execute(QueueableContext context) {
        // 检查是否还有未执行的批处理
        if (currentExecutionIndex < targetBatchClasses.size()) {
            // 动态实例化当前批处理类
            Type batchType = Type.forName(targetBatchClasses[currentExecutionIndex]);
            Database.Batchable<SObject> batchInstance = (Database.Batchable<SObject>)batchType.newInstance();
            
            // 启动批处理作业
            Database.executeBatch(batchInstance);
            
            // 更新索引，因为是Stateful，这个值会被序列化保存到下一次链式调用
            currentExecutionIndex++;
            
            // 如果还有剩余任务，继续链式调用自己
            if (currentExecutionIndex < targetBatchClasses.size()) {
                System.enqueueJob(this);
            }
        }
    }
}

怎么用 #

只需要在同步代码里启动这个Queueable：

System.enqueueJob(new BatchJobChainer());

方案二：用Stateful批处理做控制器 #

如果你的场景需要和数据处理结合（比如根据查询结果决定要执行哪些批处理），可以用批处理作为控制器，同样依赖Stateful保存索引状态。

代码示例 #

public class BatchJobController implements Database.Batchable<SObject>, Database.Stateful {
    private List<String> targetBatchClasses = new List<String>{'FirstBatch', 'SecondBatch', ...};
    private Integer currentJobIndex = 0;

    public Database.QueryLocator start(Database.BatchableContext bc) {
        // 这里返回一个空的查询（比如查一条无关记录），因为我们不需要处理数据
        return Database.getQueryLocator('SELECT Id FROM Account LIMIT 1');
    }

    public void execute(Database.BatchableContext bc, List<SObject> scope) {
        // 执行环节不需要做实际工作，只是占位
    }

    public void finish(Database.BatchableContext bc) {
        if (currentJobIndex < targetBatchClasses.size()) {
            // 实例化并启动当前批处理
            Type batchType = Type.forName(targetBatchClasses[currentJobIndex]);
            Database.Batchable<SObject> batchInstance = (Database.Batchable<SObject>)batchType.newInstance();
            Database.executeBatch(batchInstance);
            
            // 更新索引
            currentJobIndex++;
            
            // 如果还有任务，重新启动当前控制器批处理（Stateful会保留更新后的索引）
            if (currentJobIndex < targetBatchClasses.size()) {
                Database.executeBatch(this);
            }
        }
    }
}

关键注意点 #

1. 为什么Stateful能保存状态？：Salesforce会把实现了Stateful的异步类实例序列化后存储，在下次执行（链式调用或重新启动批处理）时反序列化，所以实例变量的值会被完整保留，这和静态变量的进程级存储完全不同。
2. 动态类实例化的要求：你要执行的批处理类必须是public或global的，否则Type.forName无法找到并实例化它。
3. 错误处理：如果某个批处理执行失败，后续任务会继续执行。如果需要在失败时停止，可以在批处理的finish方法里捕获异常，然后在控制器里添加一个Stateful变量（比如private Boolean hasFailed = false;），判断后不再触发后续任务。

这两个方案都完全不需要数据库存储状态，纯靠Apex的Stateful机制实现异步任务的顺序执行，完美避开governor limits的问题。

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