java - Junit测试并发性

我正在尝试通过多个线程进行访问时测试java.util.concurrent.ConcurrentLinkedQueue。下面提到的是我的Junit测试，该测试使用RepeatedTest在两个并发线程中运行。我的问题是:例如在ConcurrentLinkedQueue上使用RepeatedTest来测试并发性是否正确？源代码在下面提到。

谢谢

import java.util.concurrent.ConcurrentLinkedQueue;
import junit.extensions.ActiveTestSuite;
import junit.extensions.RepeatedTest;
import junit.extensions.TestSetup;
import junit.framework.TestCase;

public class TestNonBlockingConcurrentQueue extends TestCase{

private static ConcurrentLinkedQueue clq;

public void testPut() throws Exception {
    int messageCounter = 0;
    for(;messageCounter <10000; messageCounter++){
        clq.offer(messageCounter);
    }
    assertEquals(clq.size(), messageCounter);
}

public void testGet() throws Exception {
    while(!clq.isEmpty()){
        clq.poll();
    }
    assertEquals("Size should be zero", clq.size(), 0);
}

public static junit.framework.Test suite( ) {
    ActiveTestSuite ats = new ActiveTestSuite();

    TestSetup setup = new TestSetup(ats) {
       protected void setUp() throws Exception {
            System.out.println("Creating ConcurrentLinkedQueue..");
            clq = new ConcurrentLinkedQueue();
        }
        protected void tearDown(  ) throws Exception {
            clq = null;
        }
    };
    ats.addTest(new RepeatedTest(new TestNonBlockingConcurrentQueue("testPut"), 2));
    ats.addTest(new RepeatedTest(new TestNonBlockingConcurrentQueue("testGet"), 2));
    return setup;

}

public TestNonBlockingConcurrentQueue(String testName){
    super(testName);
}

最佳答案

JUnitPerf使用RepeatedTest来测试并发代码，因此在上面的测试中使用它来做相同的事情似乎是合理的，请参见:

http://www.clarkware.com/software/JUnitPerf.html

还有其他方法可以对并发代码进行单元测试，尽管它们都不能够真正验证您的代码是线程安全的:

Concurrent Runner

ConcJunit

另请参阅:Unit Testing Concurrent Code