在java中，使用了synchronized关键字和Lock锁实现了资源的并发访问控制，在同一时间只允许唯一了线程进入临界区访问资源(读锁除外)，这样子控制的主要目的是为了解决多个线程并发同一资源造成的数据不一致的问题。在另外一种场景下，一个资源有多个副本可供同时使用，比如打印机房有多个打印机、厕所有多个坑可供同时使用，这种情况下，Java提供了另外的并发访问控制--资源的多副本的并发访问控制，今天使用的Semaphore即是其中的一种。
Java通过代码模拟高并发可以以最快的方式发现我们系统中潜在的线程安全性问题，此处使用Semaphore(信号量)和 Count
1、Semaphore
JDK 1.5之后会提供这个类
Semaphore是一种基于计数的信号量。它可以设定一个阈值，基于此，多个线程竞争获取许可信号，做完自己的申请后归还，超过阈值后，线程申请许可信号将会被阻塞。Semaphore可以用来构建一些对象池，资源池之类的，比如数据库连接池，我们也可以创建计数为1的Semaphore，将其作为一种类似互斥锁的机制，这也叫二元信号量，表示两种互斥状态。
2、CountDownLatch
JDK 1.5之后会提供这个类，
CountDownLatch这个类能够使一个线程等待其他线程完成各自的工作后再执行。例如，应用程序的主线程希望在负责启动框架服务的线程已经启动所有的框架服务之后再执行。
CountDownLatch是通过一个计数器来实现的，计数器的初始值为线程的数量。每当一个线程完成了自己的任务后，计数器的值就会减1。当计数器值到达0时，它表示所有的线程已经完成了任务，然后在闭锁上等待的线程就可以恢复执行任务。
如下图：
以上两个类可以搭配使用，达到模拟高并发的效果，以下使用代码的形式进行举例：
package modules;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaph
如上方法模拟5000次请求，同时最大200个并发操作，观察最后的结果，发现每次的结果都有差别，和预期不符，得出结果部分如下：
22:18:26.449 [main] INFO modules.CountExample - count:4997
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:4995
22:18:26.449 [main] INFO modules.CountExample - count:4998
最后结论：add 方法 非线程安全
那如何保证add方法 线程安全，将add方法进行如下修改即可：
private static void add() {
count.incrementAndGet();
}
执行结果如下：
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
22:18:26.449 [main] INFO modules.CountExample - count:5000
最后结论：修改后 的 add 方yoqbbACyUP法 线程安全
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。
本文标题: Java使用代码模拟高并发操作的示例
本文地址: /ruanjian/java/227029.html
如果觉得《java高并发代码示例 Java使用代码模拟高并发操作的示例》对你有帮助，请点赞、收藏，并留下你的观点哦！
