ExecutorService invokeAll（）が呼び出されている呼び出し可能番号

Question

fixedThreadPoolから呼び出し可能な関数のリストを呼び出す際に問題があります。すべての呼び出し可能コードが実行されますが、それらのうちのいくつかは異なるスレッドに同時にディスパッチされるように見えるので、実際には複数回呼び出されます。

try { 
    ExecutorService es = Executors.newFixedThreadPool(Environment.nThreads); 
    es.invokeAll(Environment.jobPool); 
    es.shutdown(); 
} catch (InterruptedException e) { 
    e.printStackTrace(); 
} 

Answer 1

おそらく、リストにあなたのCallableタスクの一部を重複しています：以下のコードを参照してください。すべてCallableの実装のメソッドを正しく実装するjava.util.Setを使用してみてください。

Answer 2

Callableがキャッチされない例外をスローした場合、その動作は未定義です。中断された例外については、たとえばExecutorServiceを停止します。また、incokeAllはコレクションを受け付けているので、ちょうどあなたが何を私はExecutorServiceのがちょうど呼び出さないかなり確信して

Set<?> set = new HashSet<?>(jobPool); 

を重複していないことを確認することをお使いのArrayListのうち、HashSetのを構築し、それを渡します同じCallableは2回です。