与 Spring 异步执行并行

Question

我想遍历元素列表并异步（以并行方式）对它们执行操作。

这是我的代码：

@Autowired
ElemManager elemManager;

... 
List<Elem> elems = new ArrayList<>();

for ( Elem elem : elems ) {
     System.out.println(elemManager.doSomething(elem).get());
}

其中 ElemManager 是：

public class ElemManager {

  @Async
  public Future<String> doSomething( Elem elem ) {
    // do something
    return "done";
}

我还在 spring 上下文中创建了一个线程池并启用了异步执行，因此：

@Configuration
@EnableAsync
public class TaskConfiguration implements AsyncConfigurer {

  @Override
  public Executor getAsyncExecutor() {
    final ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
    threadPoolTaskExecutor.setMaxPoolSize( 5 );
    threadPoolTaskExecutor.setAwaitTerminationSeconds( 60 );
    threadPoolTaskExecutor.initialize();
    return threadPoolTaskExecutor;
  }

  @Override
  public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
    return new CustomAsyncExceptionHandler();
  }

}

我错过了什么吗？通过 Spring 异步执行支持并行执行方法是正确的方法吗？

Answer 1

您实际上并没有使用 Spring 调用它。你只是像一个普通的旧方法一样调用它。

但除此之外，呼召Future.get()意味着你等待未来完成。

Future先将 s添加到列表中，然后依次调用.get()它们：

List<Future<?>> futures = new ArrayList<>();
for ( Elem elem : elems ) {
  futures.add(elemManager.doSomething(elem));
}
for (Future<?> future : futures) {
  System.out.println(future.get());
}