Прерывание выполнения параллельного потока

На самом деле вы не запускаете Runnables в потоке, который создаете. Вы запускаете поток, который будет отправлен в пул, поэтому:

Thread thread = new 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, который делегирует общий пул при обработке параллельных исполнений.

Насколько я знаю, вы не можете получить дескриптор потоков, выполняющих ваши задачи, с помощью parallelStream, поэтому вам может не повезти. Вы всегда можете делать хитрые вещи, чтобы получить нить, но, вероятно, это не лучшая идея.

Вы можете использовать ForkJoinPool для прерывания потоков:

@Test
public void testInterruptParallelStream() throws Exception {
    final AtomicReference<InterruptedException> exc = new AtomicReference<>();

    final ForkJoinPool forkJoinPool = new ForkJoinPool(4);
    // use the pool with a parallel stream to execute some tasks
    forkJoinPool.submit(() -> {
        Stream.generate(Object::new).parallel().forEach(obj -> {
            synchronized (obj) {
                try {
                    // task that is blocking
                    obj.wait();
                } catch (final InterruptedException e) {
                    exc.set(e);
                }
            }
        });
    });

    // wait until the stream got started
    Threads.sleep(500);
    // now we want to interrupt the task execution
    forkJoinPool.shutdownNow();
    // wait for the interrupt to occur
    Threads.sleep(500);
    // check that we really got an interruption in the parallel stream threads
    assertTrue(exc.get() instanceof InterruptedException);
}

Рабочие потоки действительно прерываются, завершая операцию блокировки. Вы также можете позвонить shutdown() из Consumer.

Обратите внимание, что эти сны могут быть не настроены для правильного модульного теста, у вас могут быть лучшие идеи, чтобы просто подождать по мере необходимости. Но достаточно показать, что он работает.

Что-то вроде следующего должно работать для вас:

AtomicBoolean shouldCancel = new AtomicBoolean();
...
tasks.parallelStream().allMatch(task->{
    task.run();
    return !shouldCancel.get();
});

В документации к методу allMatch конкретно указано, что он не может оценивать предикат для всех элементов, если это не необходимо для определения результата. Поэтому, если предикат не совпадает, когда вы хотите отменить, ему больше не нужно оценивать. Кроме того, вы можете проверить возвращаемый результат, чтобы увидеть, был ли цикл отменен или нет.