Spring相当于CompletionService？

Question

在我的应用程序中，我必须从主应用程序线程异步处理多个作业，并收集每个作业的结果。我有一个简单的Java解决方案，它使用ExecutorService和收集作业结果的ExecutorCompletionService来实现这一点。

现在我想把我的代码转换成Spring解决方案。这些文档向我展示了ExecutorService和@Async注释的使用方式，但我不确定如何以及是否可以收集多个作业的结果。

换句话说：我正在寻找相当于CompletionService的Spring。有这样的事情吗？

我当前的代码：

class MyService {

private static ExecutorService executorService;
private static CompletionService<String> taskCompletionService;

// static init block
static {
    executorService = Executors.newFixedThreadPool(4);
    taskCompletionService = new ExecutorCompletionService<String>(executorService);

    // Create thread that keeps looking for results
    new Thread(new Runnable() {

        @Override
        public void run() {
            while (true) {
                try {
                    Future<String> future = taskCompletionService.take();
                    String s = future.get();
                    LOG.debug(s);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (ExecutionException e) {
                    e.printStackTrace();
                }
            }
        }

    }).start();
}

// This method can and will be called multiple times, 
// so multiple jobs are submitted to the completion service
public void solve(List<Long> ids) throws IOException, SolverException {
    String data = createSolverData(ids);
    taskCompletionService.submit(new SolverRunner(data, properties));
}
}

Answer 1

最后，我在Spring应用程序上下文中定义了我的bean，并将completionservice注入MyService。很有魅力。

<task:executor id="solverExecutorService" pool-size="5" queue-capacity="100" />
<spring:bean id="solverCompletionService" class="nl.marktmonitor.solver.service.SolverCompletionService" scope="singleton">
    <constructor-arg name="executor" ref="solverExecutorService"/>
</spring:bean>

Answer 2

您需要考虑您的主要目标是什么，因为您当前的代码与其他与Spring相关的类一起可以很好地工作。Spring提供对本机Java ExecutorService以及其他流行的第三方库（如Quartz）的支持

可能您所追求的是在Spring容器上设置执行器服务（例如：在Spring bean xml上使用以下配置）

<bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
  <property name="corePoolSize" value="5" />
  <property name="maxPoolSize" value="10" />
  <property name="queueCapacity" value="25" />
</bean>

并用@Service注释装饰您的MyService类，并将引用注入executor服务