中断并行流执行

Question

请考虑以下代码：

Thread thread = new Thread(() -> tasks.parallelStream().forEach(Runnable::run));

任务是应该并行执行的运行表的列表。当我们启动这个线程，并且它开始执行时，根据一些计算，我们需要中断（取消）所有这些任务。

中断线程只会停止执行中的一个。我们怎么对付别人？或者流不应该这样使用？或者你知道更好的解决办法？

Answer 1

实际上并不是在创建的线程上运行Runnables。您正在运行一个将提交到池的线程,因此：

thread thread=新线程（（）->tasks.ParallelStream（）.foreach（runnable：：run））；

在本例中，用较小的术语来说，您要做的是

List<Runnable> tasks = ...;
Thread thread = new Thread(new Runnable(){
    public void run(){
       for(Runnable r : tasks){
          ForkJoinPool.commonPool().submit(r);
       }
    }
});

据我所知，您无法获得使用ParallelStream执行任务的线程的句柄，因此可能不走运。您总是可以做一些棘手的事情来获得线程，但这样做可能不是最好的主意。