与另一个任务并行运行一个任务

Question

我有以下Foo使用FooProcessor类的课程。所以我想做的是，在运行cp1实例处理方法的同时，我要并行运行cp2.process()。

public class Foo {

    public static void main(String [] args){

        FooProcessor cp1 = new FooProcessor();
        FooProcessor cp2 = new FooProcessor();

        cp1.process();
        // in parallel process cp2.process();
    }

}

public class FooProcessor {
    public void process(){
        System.out.println("Processing..");
    }
}

但是，我要按顺序cp1，所以我要它运行并完成，如果cp2没有完成或失败，那就很好。如果确实失败，我想加入结果。该示例中未返回任何内容，但我想返回结果。

为此，应该使用TaskExecutor吗？还是线程？

我只希望cp2与cp1并行运行。或者，如果我添加更多内容，例如说cp3，我希望它也可以与cp1并行运行。

Answer 1

总结一下，我的实现方式：

• 例如，通过ExecutorService运行您的不同进程ExecutorService executor = Executors.newFixedThreadPool(nThreads);
• 将所有任务的期货存储在列表中（由ExecutorService＃submit返回）
• 等待future1.get()完成，future1将来与cp1链接在哪里
• 一旦get退货（cp1完成），取消所有其他期货，（或shutdownNow如果不再需要执行者，则取消执行者服务）
• 为了使取消过程起作用，您的cp2，cp3等需要实施中断策略，以使他们尽快停止正在执行的操作。