执行器服务:输出不是预期的

Question

我很难理解输出。在这里，我创建一个执行器，然后向其提交 1000 次Runnable任务。预期输出是 1000，因为我在 Runable 内部添加了 synchronized，但实际输出不是，例如 503。谁能帮我解释一下？BV

public class FutureTest {
    int count=0;
    public void testExecutor(){
        CountDownLatch counter = new CountDownLatch(1000);
        Runnable incr = ()->{
            //System.out.println("count="+count);
            synchronized(this){
                count++;    
            }
            counter.countDown();
        };
        ExecutorService service = Executors.newFixedThreadPool(10);
        IntStream.range(0, 1000).forEach(i->service.submit(incr));
        counter.await();
        service.shutdown();
        System.out.println(count);
    }

    public static void main(String[] args) {
        new FutureTest().testExecutor();
    }
}

Answer 1

您正在打印出调用线程中的计数，并且在调用计算线程中的所有 Runnable 代码之前。只需在你的 Runnable 中放一个简短的 Thread.sleep，就能看到计数更少。

public void testExecutor(){
    Runnable incr = ()->{
        //System.out.println("count="+count);
        synchronized(this){
            try {
                Thread.sleep(10);
            catch (InterruptedException e){}
            count++;    
        }
    };

您需要在所有线程完成其操作时使用一些通知，例如倒计时闩锁或.awaitTermination(...)。

    IntStream.range(0, 1000).forEach(i->service.submit(incr));
    service.shutdown();
    try {
        service.awaitTermination(1000, TimerUnit.SECONDS);
    } catch (InterruptedException e){}
    System.out.println(count);