Unable to use Job Scope beans in a multi-threaded or partitioned step [BATCH-2269]

Carlos Silva commented

We also had this problem, so we define a tweaked TaskExecutor that registers each thread in the JobSynchronizationManager, and in finally it releases it:

    TaskExecutor taskExecutor() {
        return new SimpleAsyncTaskExecutor() {
            @Override
            protected void doExecute(Runnable task) {
                //gets the jobExecution of the configuration thread
                def jobExecution = JobSynchronizationManager.context.jobExecution
                super.doExecute(new Runnable() {
                    @Override
                    void run() {
                        JobSynchronizationManager.register(jobExecution)

                        try {
                            task.run()
                        } finally {
                            JobSynchronizationManager.release()
                        }
                    }
                })
            }
        }
    }

Then we use that executor:

new FlowBuilder<SimpleFlow>('readControlFilesFlow')
               .start(firstStep)
               .split(taskExecutor())
               .add(anotherStep)
               .end()

If this is not fixed, can we please have the workaround updated in this issue itself? I am facing similar issues. This is the first time we are using Spring batch on our platform, and we will be using multi-threaded steps.

We need a context object for passing some data across steps. The ExecutionContext will not suffice in multithreaded access, as we will require a ‘read-then-update’ pattern (repeatable read isolation reqd). Hence we need our own context with a JobScope - and that is not working for the same reason.