RejectedExecutionException в потоках Java

Question

Я пишу многопоточную программу в java. Я написал что-то вроде этого

exec.execute(p) // where p is a runnable task working on an array 
print array 
exec.shutdown 

Проблемы я столкнулся в том, что массив печатается дает правильный вывод, но тогда отвергнутое выполнение Исключение приходит я не понимаю, почему, когда нити были обработаны и учитывая правильный выход, почему ошибка ...

Answer 1

Я думаю, что вы слишком рано закрываете своего исполнителя. Это пример того, как я думаю, что вы должны работать.

public class Main { 
    public static void main(String[] args) throws Exception { 

     // the array to modify 
     final int[] array = new int[1000]; 

     // start the executor (that modifies the array) 
     ExecutorService executor = Executors.newFixedThreadPool(10); 

     for (int i = 0; i < 1000; i++) { 
      final int c = i; 
      executor.execute(new Runnable() { 
       @Override 
       public void run() { 
        array[c] = c; 
       } 
      }); 
     } 

     // wait for all tasks to quit 
     executor.shutdown(); 
     while (!executor.awaitTermination(10, TimeUnit.SECONDS)); 

     // print the array 
     System.out.println(Arrays.toString(array)); 
    } 
} 

Также обратите внимание, что работает на одном массиве, в то же время может привести к несогласованности - вы должны быть действительно уверены, что вы не делаете работу на массив, который зависит от массива. более

Answer 2

Одним из вариантов может быть получить в будущем, когда вы предоставляете исполнителю, а затем блокировать на будущее по телефону получить

Answer 3

Проблема в том, вы все еще представляя новые задачи даже после вызова shutdown(). Поэтому использование executor.awaitTermination() не поможет.

Чтобы устранить проблему, проверьте, что исполнитель не выключается во время отправки задания.

пример:

if (!executor.isShutdown()) 
{ 
    executor.execute(new Runnable() { 
         @Override 
         public void run() { 
           array[c] = c; 
         } 
        }); 
} 

Надеется, что это помогает ...

Answer 4

Я использовал для завершения работы исполнителей, созданных во время выполнения останова крюка

Runtime.getRuntime().addShutdownHook(new Thread() { 

      public void run() { 
      if(!eExecutor.isShutdown()) { 
       eExecutor.shutdown(); 
       // await termination code 
       } 
      } 

     });