複数のスレッドを分割する

Question

私は、引数を提供し、クラスのmainメソッドを実行するテストケースを持っています。 Junitを使用して、複数のスレッドを同時に実行して、クラスのmainメソッドを実行する最良の方法は何でしょうか。

Answer 1

なぜあなたはそれをしますか？ は本当にが複数のスレッドで実行されていますか？奇妙なデザインだと私は確信しています。

一方、プログラムの並列実行をテストする場合（別々のJVM内で）は、マルチスレッドと同じではなく、JUnitは同じプログラム内で実行するので、実行しませんJVM。それでも問題はありませんが、違いを知っていることを確認してください。

SO上のいくつかの例：

• Concurrent JUnit testing
• How do I test a concurrent Java program which expects cmd line arguments?（別のJVMで並列テスト実行のためのいくつかの他のツール）

Answer 2

ないTestNGはあなたのためのオプションですが、それはだかどうかわからそれとかなり簡単です：

@Test(invocationCount = 100, threadPoolSize = 10) 
public void myTest() { ... } 

これにより、テストメソッドが10種類の異なるスレッドから100回呼び出されます。このテストが合格し、それをたくさん実行すると、テスト対象のコードがマルチスレッドセーフであることがかなり確信で​​きます。ここで

Answer 3

は軽量なソリューションです：ここでは

は、あなたがテストするクラスである：ここでは

package mTTest; 

/** 
* UUT class is the Unit Under Test. This will be tested. 
* It has two simple method: 
* push(): sets the message string if it's null, and waits otherwise. 
* pop(): if there is any message sets it null and returns it. 
* 
*/ 
public class UUT { 
    String message = null; 

    synchronized void push(String msg){ 
     while (null != message) { 
      try { 
       wait(); 
      } catch (InterruptedException e) { 
      } 
     } 
     message = msg; 
     notifyAll(); 
    } 

    synchronized String pop(){ 
     while (null == message) { 
      try { 
       wait(); 
      } catch (InterruptedException e) { 
      } 
     } 
     String ret = message; 
     message = null; 
     notifyAll(); 
     return ret; 
    } 


} 

は、Testクラスです。これはJUnitフレームワークによって呼び出されます。 multiTest（）メソッドを書き直してください。 パッケージmTTest;

import static org.junit.Assert.assertEquals; 

import java.util.ArrayList; 
import java.util.Collections; 
import java.util.List; 
import java.util.ListIterator; 

import org.junit.Test; 

/** 
* This is the JUnit test class. Method in this class will invoked by the JUnit 
* framework. 
*/ 
public class DUTTest { 

    /** 
    * Stores sub test threads errors. 
    */ 
    private static List<AssertionError> errors; 

    /** 
    * sub test threads call this function with they errors. 
    * @param err 
    */ 
    static void handle(AssertionError err){ 
     errors.add(err); 
    } 

    /** 
    * Simpler single thread test 
    * @throws InterruptedException 
    */ 
    @Test 
    public void testSingle() { 
     UUT dut = new UUT(); 

     dut.push("hello"); 

     assertEquals("set-get", "hello", dut.message); 
    } 


    /** 
    * Complex multi-thread test 
    * @throws InterruptedException 
    */ 
    @Test 
    public void testMulti() throws Exception { 
     /* 
     * Initialization 
     */ 
     errors = Collections.synchronizedList(new ArrayList<AssertionError>()); 
     UUT dut = new UUT(); 
     MyTestThread th = new MyTestThread(dut); 

     /* 
     * Tests 
     */ 
     dut.push("hello"); 

     assertEquals("set-get", "hello", dut.message); 

     th.start(); 

     dut.push("hello"); 

     th.join(); 

     /* 
     * Error handling 
     */ 
     ListIterator<AssertionError> iter = errors.listIterator(errors.size()); 

     while (iter.hasPrevious()) { 
      AssertionError err = iter.previous(); 
      err.printStackTrace(); 
      if(iter.previousIndex() == -1){ 
       throw err; 
      } 
     } 
    } 


} 

ここにはスレッドがありますが、これは数回呼び出すことができます。オーバーライドtest（）メソッド。

package mTTest; 

import static org.junit.Assert.assertEquals; 

/** 
* This is the custom test thread class. The main test thread (which is started 
* by JUnit) starts this thread. 
* 
*/ 
public class MyTestThread extends Thread { 
    UUT dut; 

    /** 
    * Constructor 
    * @param dut : should be overwritten to your custom DUT-class 
    */ 
    public MyTestThread(UUT dut) { 
     this.dut =dut; 
    } 

    /** 
    * run() method is final to prevent overriding. Override test instead. 
    * It just calls the test method and handle the assertion errors. 
    */ 
    @Override 
    public final void run() { 
     try{ 
      test(); 
     } catch (AssertionError ex){ 
      DUTTest.handle(ex); 
     } 
    } 


    /** 
    * Write your tests here. run calls this function. 
    */ 
    void test(){ 
     assertEquals("set-get", "This will cause an ERROR", dut.pop()); 
     assertEquals("set-get", "hello", dut.pop()); 
    } 
}