测试并发应用（九）MultithreadedTC测试并发代码-阿里云开发者社区

测试并发应用（九）MultithreadedTC测试并发代码

2017-05-02 1573

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介：

声明：本文是《 Java 7 Concurrency Cookbook 》的第八章，作者： Javier Fernández González 译者：郑玉婷

MultithreadedTC测试并发代码

MultithreadedTC 是一个 Java 库用来测试并发应用。它的主要目的是为了解决并发应用的不确定的问题。你不能控制他们的执行顺序。为了这个目睹，它包含了内部节拍器来控制应用的不同线程的执行顺序。这些测试线程作为类的方法来实现的。

在这个指南，你将学习如何使用 MultithreadedTC 库来为LinkedTransferQueue 实现一个测试。

准备
你必须从 http://code.google.com/p/ multithreadedtc/ 下载 MultithreadedTC library，并从 http://www.junit.org/ 下载 JUnit library, Version 4.10。把 junit-4.10.jar 和 MultithreadedTC-1.01.jar文件加入项目的库中。

怎么做呢…

按照这些步骤来实现下面的例子：:

 
      01 
      //1.   创建一个类，名为 ProducerConsumerTest，扩展 MultithreadedTestCase 类。 
     
      02 
       public class ProducerConsumerTest extends MultithreadedTestCase {  
     
      03 
        
      04 
      //2.   声明一个私有 LinkedTransferQueue 属性，用 String 类为参数，名为 queue。 
     
      05 
       private LinkedTransferQueue<String> queue;  
     
      06 
        
      07 
      //3.   实现 initialize() 方法。此方法不接收任何参数，也不返回任何值。它调用父类的 initialize() 方法，然后初始化 queue 属性。 
     
      08 
      @Override 
     
      09 
       public void initialize() {  
     
      10 
           super.initialize();  
     
      11 
           queue=new LinkedTransferQueue<String>();  
     
      12 
           System.out.printf("Test: The test has been initialized\n");  
     
      13 
      } 
     
      14 
        
      15 
      //4.   实现 thread1() 方法。它将实现的逻辑是第一个consumer。调用 queue 的 take() 方法，然后把返回值写入操控台。 
     
      16 
       public void thread1() throws InterruptedException {  
     
      17 
           String ret=queue.take();  
     
      18 
           System.out.printf("Thread 1: %s\n",ret);  
     
      19 
      } 
     
      20 
        
      21 
      //5.   实现 thread2() 方法。它将实现的逻辑是第二个consumer。首先，使用 waitForTick() 方法，一直等到第一个线程在 take() 方法中进入休眠。然后，调用queue的 take() 方法，并把返回值写入操控台。 
     
      22 
       public void thread2() throws InterruptedException {  
     
      23 
           waitForTick(1);  
     
      24 
           String ret=queue.take();  
     
      25 
           System.out.printf("Thread 2: %s\n",ret);  
     
      26 
      } 
     
      27 
        
      28 
      //6.   实现 thread3() 方法。它将实现的逻辑是producer。 首先，使用 waitForTick() 两次一直等到2个consumers被阻塞。然后，调用 queue的 put() 方法插入2个String 到queue中。 
     
      29 
       public void thread3() {  
     
      30 
           waitForTick(1);  
     
      31 
           waitForTick(2);  
     
      32 
           queue.put("Event 1");  
     
      33 
           queue.put("Event 2");  
     
      34 
           System.out.printf("Thread 3: Inserted two elements\n");  
     
      35 
      } 
     
      36 
        
      37 
      //7.    最后，实现 finish() 方法。写信息到操控台表明测试结束执行。使用assertEquals() 方法检查2个事件已经被consumed（queue的大小为0）。 
     
      38 
       public void finish() {  
     
      39 
           super.finish();  
     
      40 
           System.out.printf("Test: End\n");  
     
      41 
           assertEquals(true, queue.size()==0);  
     
      42 
           System.out.printf("Test: Result: The queue is empty\n");  
     
      43 
      } 
     
      44 
        
      45 
      //8.   创建例子的主类通过创建一个类，名为 Main 并添加 main()方法。 
     
      46 
       public class Main {  
     
      47 
        
      48 
       public static void main(String[] args) throws Throwable {  
     
      49 
        
      50 
      //9.   创建 ProducerConsumerTest 对象，名为 test。 
     
      51 
       ProducerConsumerTest test=new ProducerConsumerTest();  
     
      52 
        
      53 
      //10. 使用 TestFramework 类的 runOnce()方法来执行测试。 
     
      54 
       System.out.printf("Main: Starting the test\n");  
     
      55 
      TestFramework.runOnce(test); 
     
      56 
       System.out.printf("Main: The test has finished\n");

它是如何工作的…

在这个指南，你使用MultithreadedTC库为 LinkedTransferQueue 类实现了一个测试。你可以使用这个库和它的节拍器为任何并发应用或者类实现测试。在例子中，你实现经典的 producer/ consumer 问题，2个consumers 和一个producer。你想要测试的是在buffer里的第一个介绍的 String 对象会被第一个consumer 消耗，和在buffer里第二个介绍的String对象会被第二个到达的consumer消耗。

MultithreadedTC库是基于JUnit 库的。JUnit库是在Java中最经常用来实现unit测试时使用的库。使用 MultithreadedTC 库来实现一个基本测试，你必须扩展 MultithreadedTestCase 类。这个类扩展了 junit.framework.AssertJUnit 类，包含了全部检查测试结果的方法。它并没有扩展 junit.framework.TestCase 类，使用你不能在其他 JUnit 测试中导入MultithreadedTC测试。

然后，你实现了以下这些方法：

initialize(): 此方法的实现是可选的。当你开始测试时，它就会执行，为了初始化测试中使用的对象而使用它。
finish(): 此方法的实现是可选的。当测试结束时，它就会执行。你可以使用它在测试或者检查测试结果期间来关闭或者释放资源。
实现测试的方法：这些方法的主要逻辑就是测试你的实现。他们用thread作为始关键词连接着字符串例如, thread1()。

使用 waitForTick() 方法来控制线程的执行顺序。此方法接收一个整数type作为参数，把正在执行的thread放入休眠直到全部在测试里运行的线程都被阻塞。等他们被阻塞时， MultithreadedTC 库调用 waitForTick() 方法恢复被阻塞的线程。

传递给 waitForTick() 方法作为参数的整数是用来控制执行顺序的。MultithreadedTC 库的节拍器有个内部计数器。当全部线程被阻塞时，库增加计数器到下个在 waitForTick() 调用中的数字，那么被阻塞的。

从内部来说，当 MultithreadedTC 库执行测试，首先它执行方法。然后，它创建每个用thread作为关键词开头的方法的线程（例子中是，方法 thread1(), thread2(), 和 thread3()），当全部线程都结束运行后，就执行 finish() 方法。为了运行测试，你要使用 TestFramework 类的 runOnce() 方法。

更多…

如果 MultithreadedTC library 检测的全部线程都被阻塞，但是没有一个是被 waitForTick() 方法阻塞的，那么测试就会被认为在deadlock状态，并抛出 java.lang.IllegalStateException 异常。

参见

第八章，测试并发应用：FindBugs分析并发代码

文章转自并发编程网-ifeve.com

测试并发应用（九）MultithreadedTC测试并发代码

MultithreadedTC测试并发代码

热门文章

最新文章

相关课程

相关电子书

相关实验场景