java - Java可调用: Time taken more than a single thread process

我有以下示例代码。

import java.util.*;
import java.lang.*;
import java.io.*;

import java.util.concurrent.*;
public class CalculationThread implements Callable<Long> {

    public Long call() throws Exception {
        long k=0L;
        for(int i=0;i<100000;i++){
            for(int j=0;j<50;j++){
                k=i+j;
            }
        }
        return k;
    }
    public static void main(String[] args) throws InterruptedException {
        ExecutorService executorService = Executors.newFixedThreadPool(4);
        long startTime = System.nanoTime();
        for(int lo=0;lo<5000;lo++){
            Future<Long> result = executorService.submit(new CalculationThread());

            try {
                Long l = result.get();
            } catch (Exception e) {
                result.cancel(true);
            }

        }
        long endTime = System.nanoTime();
        System.out.println("Using threads took "+(endTime - startTime) + " ns");

        executorService.shutdown();
        executorService.awaitTermination(1, TimeUnit.SECONDS);

        long k=0L;
        startTime = System.nanoTime();
        for(int lo=0;lo<5000;lo++){
            for(int i=0;i<100000;i++){
                for(int j=0;j<50;j++){
                    k=i+j;
                }
            }

        }
        endTime = System.nanoTime();
        System.out.println("Generally it takes "+(endTime - startTime) + " ns");

    }
}

输出与

Using threads took 101960490 ns
Generally it takes 143107865 ns

到

Using threads took 245339720 ns
Generally it takes 149699885 ns

可以看到，第二行几乎是恒定的，而线程版本却变化很大。为什么会这样呢？如何减少可变性？如果我是Java多线程的新手，请让我知道我是否在做一些愚蠢的事情。

最佳答案

Future＃get阻塞，直到您的可调用结束为止。因此，主线程将一个Callable提交到池中，然后等待它完成，然后再提交下一个。您需要创建池的四个线程的开销，然后在线程和对象创建之间创建上下文，在上下文中创建可调用对象(随着可调用对象被丢弃，将进行垃圾回收)，然后您就不会执行任何操作了同时工作。

您如何获得使用池的版本速度更快的数字令人费解。当我在本地运行此代码时(并且很好地制作了MVCE，顺便说一句，我可以复制并粘贴而无需做任何更改，并且可以正常工作)，我得到的线程池部分的数字始终更高，大约是单线程部分的3倍。线程代码。