5

在我的应用程序中，我必须从主应用程序线程异步处理多个作业并收集每个作业的结果。我有一个简单的 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));
}
}
4

2 回答 2

1

您需要考虑您的主要目标是什么，因为您当前的代码可以与其他与 Spring 相关的类一起正常工作。Spring 提供对原生 Java ExecutorService 以及其他流行的 3rd 方库（如 Quartz）的支持

可能您所追求的是在spring容器上设置执行程序服务（例如：在您的spring beans 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>

并用注释装饰你的MyService类@Service并注入对执行器服务的引用

于 2013-06-24T22:56:35.703 回答
0

我最终在 Spring 应用程序上下文中定义了我的 bean，并将完成服务注入 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>
于 2013-06-28T20:41:42.367 回答