複数の同時スレッドでテスト・メソッドのセットを実行

Question

この3つのメソッドをそれぞれ10個の同時スレッドとして実行するJUnitベースのコードは何でしょうか。

@RunWith(SpringJUnit4ClassRunner.class 
@SpringBootTest 
public class TestClass { 


    @Test 
    public void readFromDBOneRecord(){ 
     try { 
     dbService.findOneByID("1"); 
     } catch (Exception error) { 
      Assert.fail("Unexpected error occured ."); 
     } 
    } 

    @Test 
    public void writeToDBOneRecord(){ 
     try { 
      dbService.save(entity.builder() 
          .setID("1").setName("John").build()) 
     } catch (Exception error) { 
      Assert.fail("Unexpected error occured ."); 
     } 
    } 

    @Test 
    public void deleteDbRecord(){ 
     try { 
      dbService.delete("1"); 
     } catch (Exception error) { 
      Assert.fail("Unexpected error occured ."); 
     } 
    } 
} 

場合によっては、一部のメソッドで例外がスローされることがあります。 deleteがwriteToDBOneRecordより前に実行されている場合と同様です。 だから配列は、メソッドごとにのみ3スレッドについて言うことになる例えば：

OperationNr|| OperationName || [ThreadNr/total threads per method]OperationType 

    1.  write  [2/3]w 
    2.  read   [1/3]r 
    3.  read   [3/3]r 
    4.  delete  [2/3]d 
    5.  read   [2/3]r 
    6.  delete  [3/3]d ->exception no record 
    7.  write  [1/3]w 
    8.  write  [3/3]w ->exception record already present 
    9.  delete  [1/3]d 

何だろう10件の同時スレッド（合計30）にそれぞれこの3試験方法を実行するためのコード？

Answer 1

あなたが並列にすべてをやりたいように、私はすべてをミックスし、次のようにスレッドを同期するCountDownLatchのインスタンスに依存しています：

@Test 
public void testMultiThreading() throws Exception { 
    // Total of reader threads 
    int reader = 5; 
    // Total of writer threads 
    int writer = 3; 
    // Total of remover threads 
    int remover = 1; 
    // CountDownLatch used to release all the threads at the same time 
    final CountDownLatch startSignal = new CountDownLatch(1); 
    // CountDownLatch used to be notified when all threads did their task 
    final CountDownLatch doneSignal = new CountDownLatch(reader + writer + remover); 
    // List in which we collect all the errors 
    final List<Exception> errors = Collections.synchronizedList(new ArrayList<>()); 
    // Create all the reader threads and start them 
    for (int i = 0; i < reader; i++) { 
     Thread thread = new Thread() { 
      public void run() { 
       try { 
        startSignal.await(); 
        dbService.findOneByID("1"); 
       } catch (Exception e) { 
        errors.add(e); 
       } finally { 
        doneSignal.countDown(); 
       } 
      } 
     }; 
     thread.start(); 
    } 
    // Create all the writer threads and start them 
    for (int i = 0; i < writer; i++) { 
     Thread thread = new Thread() { 
      public void run() { 
       try { 
        startSignal.await(); 
        dbService.save(entity.builder() 
         .setID("1").setName("John").build()); 
       } catch (Exception e) { 
        errors.add(e); 
       } finally { 
        doneSignal.countDown(); 
       } 
      } 
     }; 
     thread.start(); 
    } 
    // Create all the remover threads and start them 
    for (int i = 0; i < remover; i++) { 
     Thread thread = new Thread() { 
      public void run() { 
       try { 
        startSignal.await(); 
        dbService.delete("1"); 
       } catch (Exception e) { 
        errors.add(e); 
       } finally { 
        doneSignal.countDown(); 
       } 
      } 
     }; 
     thread.start(); 
    } 
    // Release the threads 
    startSignal.countDown(); 
    // Wait until all threads did their task 
    doneSignal.await(); 
    // If an error has been collected, print the stack trace and throws the 
    // first error to make the test fail 
    if (!errors.isEmpty()) { 
     for (Exception e : errors) { 
      e.printStackTrace(); 
     } 
     throw errors.get(0); 
    } 
} 

NB：あなたが与えられたユニットテストになりたい場合はいくつかの同時実行スレッドで実行されている場合は、contiperfを見てください。しかし、それを達成したい場合はそれらを混在させることはできません