JUnitと並行処理：不可解なエラー

Question

JUnitを使用して並行性をテストするのは理想的ではありませんが、今のところ選択肢はありません。私は説明できない例外が発生しました。

私は要約すると、テストを実行します。

• 私はエグゼキュータ
• 各実行可能に1000年ランナブルを提出するが、私はエグゼキュータ終了
• JUnitのを待ちリスト
• に要素を追加しますリストには999個の要素しかないことがわかります
• runnable catchブロックには例外が出力されません

何が起こる可能性がありますか？

注：私は時々例外が発生します。コードには関連性のないものがいくつかありますが、私が何かを見逃してしまった場合に備えるために残しました。 XXXQueryはenumです。あなたはその周りに同期せずに、複数のスレッドでのごRunnable.run()方法でresultsArrayListに追加することはできません

public void testConcurrent() throws InterruptedException { 
    final int N_THREADS = 1000; 
    final XXXData xxxData = new AbstractXXXDataImpl(); 
    final List<QueryResult> results = new ArrayList<>(); 
    ExecutorService executor = Executors.newFixedThreadPool(N_THREADS); 
    for (int i = 0; i < N_THREADS; i++) { 
     final int j = i; 
     executor.submit(new Runnable() { 

      @Override 
      public void run() { 
       try { 
        results.add(xxxData.get(XXXQuery.values()[j % XXXQuery.values().length])); 
       } catch (Exception e) { 
        System.out.println(e); 
       } 
      } 
     }); 
    } 
    executor.shutdown(); 
    executor.awaitTermination(10, TimeUnit.SECONDS); 
    assertEquals(N_THREADS, results.size()); 
} 

Answer 1

。

アサーションに失敗したメッセージは、add()にN_THREADSがコールされましたが、同時実行競合状態のためにエントリが少なくなっていることを示しています。

リストの代わりに最終的な配列を使用します。ような何か：また

final QueryResult[] results = new QueryResult[N_THREADS]; 
for (int i = 0; i < N_THREADS; i++) { 
    ... 
     public void run() { 
      results[j] = data.get(Query.values()[j % Query.values().length]); 
     } 

、私はかなりXXXQuery.values()を得ることはありませんが、それは変更されない限り、私は、ループ上の変数にそれを引っ張るだろう。