Spring批次如何停运

Question

按照标题，我有一个使用spring Batch在后端运行的服务。
我的服务：

@Service
publlic class TestBatch {
public void testDelay(String jobID) {
        // TODO Auto-generated method stub
        try {
            for(int i=0; i< 1000; i++) {
                Thread.sleep(1000);
                System.out.println(jobID + " is running");
            }
           
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

public class TestTasklet implement Tasklet {

@Resource
    private TestBatch testBatch ;

    @Override
    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {        
        testBatch.testDelay("Test01"); // Param to show in cololog
        return RepeatStatus.FINISHED;
    }
}

@Service
public class JobService {

    @Autowired
    private SimpleJobOperator simpleJobOperator;

    @Autowired
    private JobExplorer jobs;

    public void stopJob(String jobid) {
        simpleJobOperator.stop(jobid);// Using job operator

        JobExecution jobExecution = jobs.getJobExecution(jobid); // Using job execution
        jobExecution.stop();
    }
}

作业已停止，但控制台中仍输出文本：

Test01 is running
Test01 is running
Test01 is running
...

我不知道如何在作业停止时停止testbatch-methodtestdelay()。我怎么做？

Answer 1

您需要使用StoppableTasklet，而不是tasklet。当通过JobOperator请求停止作业时，Spring Batch将调用StoppableTasklet#stop。

但是，确保代码正确停止取决于您，以下是Javadoc的摘录：

It is up to each implementation as to how the stop will behave.
The only guarantee provided by the framework is that a call to JobOperator.stop(long)
will attempt to call the stop method on any currently running StoppableTasklet.