线程正在等待ThreadPoolExecutor

此代码运行速度非常慢。我倾销了这些线程，并且几乎有一个线程正在同时运行，但是当我将ExecutorService更改为ForkJoinPool时，代码运行速度非常快。我不知道为什么线程都在等待，我的电脑有8个内核...线程正在等待ThreadPoolExecutor

public class Tests { 

    public static void main(String[] args) throws InterruptedException { 

     int NUM_OF_THREADS = 8; 
     int NUM_OF_INCREMENTS = 100_000_000; 
     //ExecutorService service = Executors.newWorkStealingPool(); 
     ExecutorService service = Executors.newFixedThreadPool(NUM_OF_THREADS); 
     final Counter counter = new StupidCounter(); 

     long before = System.currentTimeMillis(); 
     for (int i = 0; i < NUM_OF_INCREMENTS; i++) { 
      service.submit(newCounterClient(counter, i)); 
     } 
     service.shutdown(); 
     service.awaitTermination(1, TimeUnit.MINUTES); 
     long end = System.currentTimeMillis(); 
     System.out.println(end - before); 
     System.out.println(counter.getCounter()); 
    } 


    static class CounterClient implements Runnable { 
     private Counter counter; 
     private int num; 

     public CounterClient(Counter counter, int num) { 
      this.counter = counter; 
      this.num = num; 
     } 

     @Override 
     public void run() { 
      counter.increment(); 
     } 
    } 

    static interface Counter { 
     void increment(); 

     long getCounter(); 
    } 

    static class StupidCounter implements Counter { 
     long i = 0; 

     @Override 
     public void increment() { 
      i++; 
     } 

     @Override 
     public long getCounter() { 
      return i; 
     } 
    } 

}

"pool-1-thread-7" #17 prio=5 os_prio=31 tid=0x00007faaa481c000 nid=0x6503 waiting on condition [0x0000700001d6d000] 
    java.lang.Thread.State: WAITING (parking) 
    at sun.misc.Unsafe.park(Native Method) 
    - parking to wait for <0x00000006c006b3d8> (a java.util.concurrent.locks.ReentrantLock$NonfairSync) 
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) 
    at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836) 
    at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly(AbstractQueuedSynchronizer.java:897) 
    at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(AbstractQueuedSynchronizer.java:1222) 
    at java.util.concurrent.locks.ReentrantLock.lockInterruptibly(ReentrantLock.java:335) 
    at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:439) 
    at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
    at java.lang.Thread.run(617Thread.java:745)

来源

2016-12-16 user2727477

这是相当困难的，从这个代码得出任何真正结论，因为它不是真的做什么。执行程序的内部队列是瓶颈，这就是为什么您一次只能看到1个线程“工作”的原因。它并不真正起作用，它会从队列中获取下一个任务，使所有其他线程（也正在获取下一个任务）等待。除了LinkedBlockingQueue.take()的功能之外，您并不真正在这里测试任何东西。

increment()方法不是线程安全的，所以基本上你正在测试不好的代码，结果几乎不相关。如果您使CounterClient任务执行实际工作，需要几毫秒，那么与ForkJoinPool相比，您会发现性能差异较小（如果有）。

来源

2016-12-16 09:43:15 Kayaman

使用FixedThreadPool时，大部分时间都用于GarbageCollection，因为程序会消耗大量的时间。我尝试使用虚拟机参数-Xmx3g执行，并且在虚拟机尝试避免内存不足时仍然卡在垃圾收集中。

您可能想要使用Memory Dump来深入了解消耗的根本原因，但我猜测它是计数器中的实例。

无论如何，根本原因似乎是FixedThreadPool使用的LinkedBlockingQueue如工作队列。由于for循环将100_000_000元素添加到workQueue，所以很少有另一个Thread实现从中获取元素。因此，他们正在等待大部分时间，直到提交所有CounterClient s。

的ForkJoinPool采用了更非阻塞方式，据我了解多工作队列 S为提交的行动。

来源

2016-12-16 11:02:01 Alexander

线程正在等待ThreadPoolExecutor

回答

相关问题