Java执行人如果在编译时间中不知道任务计数，则不执行所有任务

Question

我有一个非常简单的Java代码段：

  ExecutorService executor = null;          
      try {
          executor = Executors.newFixedThreadPool(4);             
          for (int i = 0; i < 10; i++) {                
              executor.submit( () -> processRule(rule_queue.poll()));           
            }
       }   

这是：如果我替换10个（在我的情况下，使用rule_queue queue中的对象计数使用rule_queue.size.size（），那么并非所有任务都将被执行。

它是一个非常奇怪的行为，对于1-2个固定线程螺纹，它将起作用，但是对于3及以上的固定线程，通常只执行5-7个任务

。 t将其用于循环

。

中 运行所有任务以及如何并行运行4，然后将所有其他任务放在执行者队列中的所有任务（最多可达300）

。 。

Answer 1

我认为您被问题取代的

for (int i = 0; i < 10; i++) {                
    executor.submit( () -> processRule(rule_queue.poll()));           
}

是

for (int i = 0; i < rule_queue.size(); i++) {
//                  ^^^^^^^^^^^^^^^^^
    executor.submit( () -> processRule(rule_queue.poll()));           
}

rule_queue.size（）在每次迭代时都被重新评估。考虑初始队列大小为2的情况。

Iteration    i   rule_queue.size()   result
---------    -   -----------------   ------
    1        0           2           submit
    2        1           1           exit loop

因此，只有一半的规则会提交。相反，您想要的是：

while(rule_queue.size() > 0) {
    executor.submit( () -> processRule(rule_queue.poll()));           
}

如果您在IDE调试器中介绍了代码，您将立即看到这一点。