需要提交多少次调用才能与 newWorkStealingPool 一起使用？

Question

我正在阅读有关Executors.newWorkStealingPool 的内容，并且想知道如何设置它。

我的线程将从LinkedBlockingQueue中拉出，因此将连续运行（除非在“take”调用处被阻止）。

假设我不知道运行此代码的主机上将提供多少个内核。我如何知道要添加多少个 Runnable 对象实例？

Runnable processRecord = () -> {

    try {

        consumeRecord(blockingQueue.take());

    } catch (InterruptedException e) {

        e.printStackTrace();

    }

public void setup() {

    ExecutorService workPool = Executors.newWorkStealingPool();

-----> 我传入了多少个线程实例？

    workPool.submit(processRecord);

}

更有可能的是 - 我如何（正确）使用这个线程构造？

Answer 1

Runnables提交到工作窃取池 ( ForkJoinPool) 会执行一次（就像在任何其他线程池中一样）。对于示例实现，processRecord您需要为中的每个元素提交一个blockingQueue