別のスレッドを作成するメソッドをテストするには？

Question

これは初めてですが、私はマルチスレッドJavaプログラム用のJUnitを作成しようとしています。

私は以下のような方法があります。どうすればJUnitを書くことができますか？そのような似たような例を指していますか？アドバンスでおかげさまで... !!

public void myMethod(Input input) { 
    if (!this.isStreamingPaused()) { 
     ExecutorService publisherThreadPool = getThreadPool(); 
     PublisherThread publisher = new PublisherThread(); 
     publisher.setInputData(input); 
     publisherThreadPool.execute(publisher); 
     publisherThreadPool.shutdown(); 
    } 
} 

public ExecutorService getThreadPool() { 
     final ThreadFactory threadFactory = new BasicThreadFactory.Builder() 
       .namingPattern("MyName-%d") 
       .priority(Thread.NORM_PRIORITY) 
       .build(); 
     return Executors.newFixedThreadPool(1, threadFactory); 
} 

Answer 1

あなたはこれらの変更を行い、あなたのPublisherThreadクラスでjava.util.concurrent.CountDownLatch

public void myMethod(Input input) { 
    if (!this.isStreamingPaused()) { 
     ExecutorService publisherThreadPool = getThreadPool(); 

     // in case that you'd have more of the same kind of operations to do 
     // you can use appropriately a higher count than 1 
     CountDownLatch latch = new CountDownLatch(1); 

     PublisherThread publisher = new PublisherThread(); 
     publisher.setInputData(input); 
     publisherThreadPool.execute(publisher); 
     publisherThreadPool.shutdown(); 


     try { 
      latch.await(); 
     } catch (InterruptedException e) { 
      LOG.info("Interrupted by another thread"); 
     } 
    } 
} 

を使用して試すことができます：

private CountDownLatch latch; 

public PublisherThread(CountDownLatch latch){ 
    this.latch = latch; 
} 

public void run(){ 
    try{ 
     // kafka business logic 
     // .... 
    } finally { 
     // you don't want your program to hang in case of an exception 
     // in your business logic 
     latch.countDown(); 
    } 
}