基础框架搭建和并发模拟工具,代码

（1）基础框架搭建

码云项目 ：https://gitee.com/dzxmy/concurrency

（2）并发模拟

（3）CountDownLatch 

通常用来 保证 几个线程执行完成之后，再执行其他的代码

（4）Semaphore

控制同一时刻的并发量

  

   

    

     

    
    

     

      @Slf4j
     
    
   

    

     

    
    

     

      @NotThreadSafe
     
    
   

    

     

    
    

     

      public class ConcurrencyTest {
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 //请求次数
     
    
   

    

     

    
    

     
 private static int clientTotal = 5000;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 //允许同时运行的线程数
     
    
   

    

     

    
    

     
 private static int threadTotal = 200;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 //计数
     
    
   

    

     

    
    

     
 public static int count = 0;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
 public static void main(String[] args) {
     
    
   

    

     

    
    

     

       ExecutorService executorService = Executors.newCachedThreadPool();
     
    
   

    

     

    
    

     
 final Semaphore semaphore = new Semaphore(threadTotal);
     
    
   

    

     

    
    

     
 final CountDownLatch countDownLatch = new CountDownLatch(clientTotal);
     
    
   

    

     

    
    

     
 for (int i = 0; i < clientTotal; i++) {
     
    
   

    

     

    
    

     

       executorService.execute(() -> {
     
    
   

    

     

    
    

     
 try {
     
    
   

    

     

    
    

     

       semaphore.acquire();
     
    
   

    

     

    
    

     

       add();
     
    
   

    

     

    
    

     

       semaphore.release();
     
    
   

    

     

    
    

     

       } catch (InterruptedException e) {
     
    
   

    

     

    
    

     
 log.error("exception", e);
     
    
   

    

     

    
    

     

       }
     
    
   

    

     

    
    

     

       countDownLatch.countDown();
     
    
   

    

     

    
    

     

       });
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

       }
     
    
   

    

     

    
    

     
 try {
     
    
   

    

     

    
    

     

       countDownLatch.await();
     
    
   

    

     

    
    

     

       } catch (InterruptedException e) {
     
    
   

    

     

    
    

     

       e.printStackTrace();
     
    
   

    

     

    
    

     

       }
     
    
   

    

     

    
    

     

       executorService.shutdown();
     
    
   

    

     

    
    

     
 log.info("count:{}", count);
     
    
   

    

     

    
    

     

       }
     
    
   

    

     

    
    

     
 private static void add() {
     
    
   

    

     

    
    

     

       count++;
     
    
   

    

     

    
    

     

       }
     
    
   

    

     

    
    

     

      }
     
    
  
 

运行代码可以看到每次计数的结果都不一样，并且可能不是5000，因为同一时刻200个线程同时运行将count加1，而count并不是对于线程之间可见,可能两个线程在读取count的时候结果是一样的，同时对值加+1，因此就会造成最后的结果可能不是5000，这种方式是线程不安全的。

文章来源: blog.csdn.net，作者：血煞风雨城2018，版权归原作者所有，如需转载，请联系作者。

原文链接：blog.csdn.net/qq_31905135/article/details/84185962