Spring并行执行一个方法答案

【问题标题】：Spring Parallel Execution Of A MethodSpring并行执行一个方法
【发布时间】：2014-12-28 23:11:32
【问题描述】：

我的情况是，我有一组对象，每个对象都必须运行一个昂贵的方法，大约需要 5-10 秒才能完成。

如何并行运行所有方法并定期检查状态？

我尝试将 @Async 注释与 Future 响应一起使用，但没有任何改变。

public static void populate(String marketId) {
    //irrelevant code removed

    List<Company> companies = mongo().find(new Query(c), Company.class);
    List<Future> futures = new ArrayList<Future>();

    for(Company comp : companies) {
        futures.add(comp.updateData(market));
    }
}

@Async
public Future<Boolean> updateData(Market market) {
    //do my slow logic here

    return new AsyncResult(false);

}

ThreadPoolTaskExecutor是要走的路吗？

【问题讨论】：

标签： java spring spring-mvc multitasking

【解决方案1】：

对于您使用 AsyncResult 的原因（以及哪个实现...... ejb？），我有点困惑。如果我没记错的话，它不会那样工作，因为（据我所知）AsyncResult 连接到 bean 和 @Asyncronous 注释使得来自特定 bean 方法的响应是异步的。但如果在对象内部使用，它将是有效的顺序。

你需要的是一个正常的未来。如果是这样，您需要在执行程序中实际运行这些期货，然后通过调用 future.get() 等到它们完成。你可以在这里找到一个很好的教程： http://java.dzone.com/articles/javautilconcurrentfuture

您也可以查看 Akka。演员模型是我个人最喜欢的，因为你可以简单地生成一堆工人，告诉他们该做什么，并让他们在他们完成工作后通知你。如果你手头只有一个简单的任务，这可能还是有点矫枉过正，这取决于你的风格。

ExecutorService pool = Executors.newFixedThreadPool(10);

public static void populate(String marketId) {
    //irrelevant code removed

    List<Company> companies = mongo().find(new Query(c), Company.class);
    List<Future> futures = new ArrayList<Future>();

    for(Company comp : companies) {
        futures.add(comp.updateData(market));
    }

    for(Future future: futures) {
        future.get()
    }
}

public Future<Boolean> updateData(Market market) {
  return pool.submit(new Callable<Boolean>() {
            @Override
            public Void call() throws Exception {
                //do your slow stuff here;
                return false;
            }
        })

}

当然，如果您需要从这些期货中获得一些实际回报，这是有道理的。如果它们是无效的，并且您只需要一个线程来在其他地方运行一些副作用，那么这样做就没有意义了，您可以简单地使用 runnables 和 executor。与此类似的东西： wait until all threads finish their work in java

【讨论】：