3

这个小代码片段永远不会在 jdk8u45 上完成，并且曾经在 jdk8u20 上正确完成：

public class TestForkJoinPool {

    final static ExecutorService pool = Executors.newWorkStealingPool(8);
    private static volatile long consumedCPU = System.nanoTime();

    public static void main(String[] args) throws InterruptedException {
        final int numParties = 100;
        final Phaser p = new Phaser(1);
        final Runnable r = () -> {
            p.register();
            p.arriveAndAwaitAdvance();
            p.arriveAndDeregister();
        };

        for (int i = 0; i < numParties; ++i) {
            consumeCPU(1000000);
            pool.submit(r);
        }

        while (p.getArrivedParties() != numParties) {}
    }

    static void consumeCPU(long tokens) {
        // Taken from JMH blackhole
        long t = consumedCPU;
        for (long i = tokens; i > 0; i--) {
            t += (t * 0x5DEECE66DL + 0xBL + i) & (0xFFFFFFFFFFFFL);
        }
        if (t == 42) {
            consumedCPU += t;
        }
    }
}

Phaser的文档指出

在 ForkJoinPool 中执行的任务也可以使用 Phasers，这将确保在其他人被阻塞等待阶段推进时执行任务有足够的并行性。

但是ForkjoinPool#mangedBlock 的 javadoc指出：

如果在 ForkJoinPool 中运行，可能会首先扩展池以确保足够的并行度

那里只有一个可能。所以我不确定这是否是一个错误，或者只是不依赖 Phaser/ForkJoinPool 合约的错误代码：Phaser/ForkJoinPool 组合的合约有多难防止死锁？

我的配置：

  1. Linux adc 3.14.27-100.fc19.x86_64 #1 SMP 2014 年 12 月 17 日星期三 19:36:34 UTC x86_64 x86_64 x86_64 GNU/Linux
  2. 8核i7
4

1 回答 1

1

看起来您的问题来自 JDK 8u20 和 8u45 之间 ForkJoinPool 代码的更改。

在 u20 中，ForkJoin 线程在被回收之前总是至少存活 200 毫秒（参见 ForkJoinPool.FAST_IDLE_TIMEOUT）。

在 u45 中，一旦 ForkJoinPool 达到其目标并行度加上 2 个额外线程，线程将在它们用完工作后立即死亡，无需等待。您可以在 ForkJoinPool.java（第 1810 行）中的 awaitWork 方法中看到这种变化：

    int t = (short)(c >>> TC_SHIFT);  // shrink excess spares
    if (t > 2 && U.compareAndSwapLong(this, CTL, c, prevctl))
        return false;

您的程序使用 Phasers 任务来创建额外的工作人员。每个任务都会产生一个新的补偿工作者，用于接收下一个提交的任务。
但是，一旦达到目标并行度 + 2，补偿工作者将立即死亡，无需等待，也没有机会接起随后将立即提交的任务。

我希望这有帮助。

于 2015-06-02T16:09:45.683 回答