AsyncItemWriter与CompositeItemWriter能否配合？解决编译类型不匹配错误

可以配合使用，你遇到的编译错误是泛型类型不匹配导致的，以下是问题分析和修正方案：

错误原因分析 #

根据Spring Batch 4.3.x的源码定义：

• AsyncItemWriter<T> 实现 ItemWriter<T>，作用是异步执行委托的ItemWriter<T>写入操作
• CompositeItemWriter<T> 的setDelegates方法要求参数为List<ItemWriter<? super T>>

你声明的列表类型是List<AsyncItemWriter<Employee>>，由于泛型的不变性，该类型无法直接赋值给List<ItemWriter<? super Employee>>，因此触发编译错误。

修正后的代码示例 #

调整列表的泛型声明，使其兼容AsyncItemWriter<Employee>：

@Bean
public AsyncItemWriter<Employee> asyncEmployeeJsonWriter() {
    AsyncItemWriter<Employee> asyncItemJsonWriter = new AsyncItemWriter<>();
    asyncItemJsonWriter.setDelegate(empJsonWriter);
    // 可选：自定义线程池，默认使用SimpleAsyncTaskExecutor
    // asyncItemJsonWriter.setTaskExecutor(new ThreadPoolTaskExecutor());
    return asyncItemJsonWriter;
}

@Bean
public AsyncItemWriter<Employee> asyncEmployeeCsvWriter() {
    AsyncItemWriter<Employee> asyncItemCsvWriter = new AsyncItemWriter<>();
    asyncItemCsvWriter.setDelegate(empCsvWriter);
    return asyncItemCsvWriter;
}

@Bean
public CompositeItemWriter<Employee> compositeItemWriter() {
    // 调整列表泛型为ItemWriter<? super Employee>，兼容AsyncItemWriter<Employee>
    List<ItemWriter<? super Employee>> itemWriterList = new ArrayList<>();
    itemWriterList.add(asyncEmployeeJsonWriter());
    itemWriterList.add(asyncEmployeeCsvWriter());
    
    CompositeItemWriter<Employee> compositeItemWriter = new CompositeItemWriter<>();
    compositeItemWriter.setDelegates(itemWriterList);
    return compositeItemWriter;
}

额外注意事项 #

1. 等待异步任务完成：AsyncItemWriter默认waitForCompletion=true，会阻塞直到所有异步写入任务完成；如果不需要等待后续步骤，可设置asyncItemWriter.setWaitForCompletion(false)。
2. 线程安全：确保empJsonWriter和empCsvWriter是线程安全的，因为AsyncItemWriter会在多线程环境中调用它们的write方法。

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