分叉和联接功能jdk7线程数

Question

我一直在研究JDK 7中的新特性，即Fork和Join。在Javadoc中，它指出，在ForkJoinWG中，不能仅在ForkJoinPool的上下文中执行fork。但是它没有提到fork（）方法调用是否创建了一个新线程。

ForkJoinPool使用工作窃取算法来平衡线程之间的工作，但没有提到实际创建了多少线程。

我有一个任务，我应该以某种方式分解它，但我担心ForkJoinPool会创建太多线程，并且会因为管理这些线程的开销而降低执行性能。

有人能帮我吗？

Answer 1

Fork不一定会创建新的线程。在我的基准测试中，它只创建一个线程，每个可用的核心一个额外的线程。附加基准；从main（）调用Factorizer.factorize（71236789143834319L），说。

import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.RecursiveTask;

public class Factorizer extends RecursiveTask<Long> {

static ForkJoinPool fjPool = new ForkJoinPool();
static final int sequentialThreshold = 10000;

private long number, low, high;

Factorizer(long number, long low, long high) {
    this.number = number; this.low = low; this.high = high;
}

private long factorize() {
    if ((number % 2) == 0) {
        return 2;
    }
    // ensures i is odd (we already know number is not even)
    long i = ((low % 2) == 0) ? low + 1: low;
    for (/**/; i < high; i+=2) {
        if ((number % i) == 0) {
            return i;
        }
    }
    return number;
}

@Override
protected Long compute() {

    // ugly debug statement counts active threads
    System.err.println(Thread.enumerate(
            new Thread[Thread.activeCount()*2]));

    if (high - low <= sequentialThreshold) {
        return factorize();
    } else {
        long mid = low + (high - low) / 2;
        Factorizer left = new Factorizer(number, low, mid);
        Factorizer right = new Factorizer(number, mid, high);
        left.fork();
        return Math.min(right.compute(), left.join());
    }
}

static long factorize(long num) {
    return fjPool.invoke(new Factorizer(num, 2, (long)Math.sqrt(num+1)));
}
}

注意-这只是一个测试。不要使用这段代码来认真考虑任何大的因素。