核心数越多，多线程速度就越慢

Question

我正在尝试使用多线程实现埃拉托色尼素筛。 线程由跑步池处理

ThreadPoolExecutor executor = 
    new ThreadPoolExecutor(
        6,   // cores
        10,  // threads
        1000,
        TimeUnit.MILLISECONDS, 
        new ArrayBlockingQueue<Runnable>(n)
    );

而筛子本身就是这样实现的

for (int i=2; i<Math.sqrt(n); i++ ){
    if (list[i].get()) { // boolean list initialized earlier
        executor.execute(new Calc(i,n));
    }
}

run 方法如下所示

public void run(){
    for (int j=start*2;j<n;j=j+start){ 
        list[j].set(false); 
    }   
}

现在，我不明白的是，为什么当

corePoolSize

较低时（其他参数保持不变），程序运行得更快。 （2 核 2.5 毫秒；7 - 3.3 毫秒；等等）。 我想我可能会犯一些菜鸟错误，但我不明白为什么会发生这种情况？

编辑： 完整的类看起来像这样（必须为集群使用单个类，因此所有内容都在 Main 中：

int start;
int n;
Main(int start,int n){
    this.start=start;
    this.n=n;
}
public void run(){
            for (int j=start*2;j<n;j=j+start){
                list[j].set(true);
            }


        }


private static list myBoolean[];

   public static void main(String[] args) {
    int  n = 20000;     
    list= new AtomicBoolean[n+1];


for (int i=2; i<n; i++ ){
            list[i]=new AtomicBoolean(false);
       }
      ThreadPoolExecutor executor = 
                new ThreadPoolExecutor(
                        7,
                    10,
                    1000,
                    TimeUnit.MILLISECONDS, 
                    new ArrayBlockingQueue<Runnable>(n));

    long startedTime = System.nanoTime();
    for (int i=2; i<Math.sqrt(n); i++ ){
        if (list[i]){
            executor.execute(new Main(i,n));
        }
    }   

    executor.shutdown();
    try {
        executor.awaitTermination(60, TimeUnit.MINUTES);
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }   
    System.out.println("Work time "+(float)(System.nanoTime()-startedTime)/1000000+" s.");

    }

}

Answer 1

这在很大程度上取决于您有多少个核心。如果你有 2 个核心并且想要在 7 个线程上执行，那么由于线程上下文切换，只会使速度变慢。这就是所谓的阿姆达尔定律。

还值得一提的是，执行器构造函数的前 2 个参数是 corePoolSize 和 MaximumPoolSize java doc

corePoolSize

表示要保留在池中的线程数，即使它们处于空闲状态，而

maximumPoolSize

是最大线程数池中允许的线程

无论如何，主要原因是您唯一要测量的是执行器关闭所需的时间。您用 false 初始化数组：

list[i]=new AtomicBoolean(false);

那么你为线程池创建任务的唯一情况就是当你找到一个真正的元素

if (list[i]){

。由于没有真正的元素，这永远不会发生，因此不会计划/执行任何任务。