Java 8 流 - 超时？

我想循环一个巨大的数组并执行一组需要很长时间的复杂指令。但是，如果超过 30 秒，我希望它放弃。

ex.

final long start = System.currentTimeMillis();
myDataStructure.stream()
    .while(() -> System.currentTimeMillis() <= start + 30000)
    .forEach(e ->
    {
      ...
    });

我想避免只是说return在 - 的里面forEach如果满足特定条件则调用。

我会为此创建一个自定义池，例如：

ForkJoinPool forkJoinPool = new ForkJoinPool(1);
    try {
        forkJoinPool.submit(() ->
        IntStream.range(1, 1_000_000).filter(x -> x > 2).boxed().collect(Collectors.toList()))
                .get(30, TimeUnit.MILLISECONDS);
    } catch (TimeoutException e) {
        // job not done in your interval
    }