java多线程-竞态
在java多线程编程中,我们经常会遇见这样的一种情况,在我们输入相同的数据,有时候输出的数据是正确,有时候输出的结果却是错误的,这种计算结果的正确性与时间有关的现象就被称之为竞态。
1.竞态产生的原因
在多线程编程时会出现多个线程共同访问一个变量,这样的变量即我们所说的共享变量或者共享资源;竞态产生的条件之一就是在于多个线程同时访问相同的变量并进行读写操作,当其中一个线程需要根据某个变量的状态来相应执行某个操作的之前,该变量很可能已经被其它线程修改,这个时候就产生的竞态。下边我们看个例子
public class Statistics { private int count = 0; private void add(int i){ count = count + i; System.out.println("线程"+Thread.currentThread().getId()+":"+count); } public static class StatisticsRunnable implements Runnable{ private Statistics statistics; public StatisticsRunnable( Statistics statistics){ this.statistics = statistics; } @Override public void run() { for(int i=0;i<10;i++){ this.statistics.add(1); } } } public static void main(String[] args) { Statistics statistics = new Statistics(); Thread t1 = new Thread(new StatisticsRunnable(statistics)); Thread t2 = new Thread(new StatisticsRunnable(statistics)); t1.start(); t2.start(); } }
运行结果:
线程12:2 线程11:2 线程12:3 线程11:4 线程12:5 线程11:6 线程12:7 线程11:8 线程11:10 线程12:9 线程11:11 线程12:12 线程11:13 线程12:14 线程11:15 线程12:16 线程11:17 线程12:18 线程11:19 线程12:20
按照常规逻辑,我们的统计类一直在增量加1,每个线程所打印的count是不会一样的,但是结果确并不是这样,出现了有时候结果是我们所想的,有时候却出现了两个线程打印相同的结果。这就是我所谓的竞态了,导致竞态的常见因素是多个线程在没有采取任何控制措施的情况下并发的更新、读取同一个共享变量。我反过来看例子,在线程11加完1之后,准备打印count,这个时候线程12并发的更新了count,导致线程实际打印的是线程12已经加1之后的count,出现了和想象不一样的结果,当我们加大循环次数,再多次运行上面的例子,我们还能发现最终的统计结果和我们想象有一定的差距,这种情况是两个线程交错的更新count,会出现一个线程的结果重新覆盖已经加1的count,这样就少统计了。所以竞态往往伴随着读取脏数据的问题,即一个线程读取到一个过时的数据,丢失更新问题,即一个线程所做的更新没有体现在后续其他线程对该数据的读取上。
需要注意的竞态不一定就导致计算结果的不正确,它只是不排除计算结果有时候正确,有时候错误,这也是我们多线程编程需要非常注意的,可能我们自测时并发量小,出现的结果都是正确的,一旦到线上高并发的情况时就出现了错误的结果,所以当多线程编程时如果出现共享变量一定需要注意是否会出现竞态。
2.竞态的模式
在竞态的典型案例中,常常有两个竞态模式:read-modify-write(读-改-写)和check-then-act(检测后行动)。read-modify-write(读-改-写)这个操作分为这几个步骤:一个线程读取了一个共享变量的值,然后根据这个值做一下计算,最后在更新该共享变量的值,在这个操作中如果我们没有采取任何控制措施,那么就可能出现竞态;一起分析一下这个过程,我们在读取一个值后,刚准备用这个值,但是这个时候这个值被别的线程改变了,同样的我们计算出结果需要更新这个结果,但是这个时候出现直接覆盖了别的线程更新过的值,这个过程出现了“脏读”和“更新丢失”的问题。check-then-act(检测后行动)这个操作的步骤:读取某个共享变量的值,根据该变量的值决定下一步的动作是什么时,在这个过程中,我们决定下一步准备怎么做的时候可能这个共享变量的值被别的线程更新了,出现了下一步的操作就不是我们想要的操作了,这样也出现了竞态。多线程编程中可以套用这两种模式,在使用一个共享变量时是否会出现以上两种模式的情况,就可以分析出是否会出现竞态。
2.竞态的解决方法
竞态的产生往往是操作共享变量产生的,所以当多个线程需要操作共享资源的时候,它们需要以某种顺序来确保该共享变量在某一时刻只能被一个线程使用,也就是说,当线程A需要使用共享变量,如果该共享变量正被线程B使用,同步机制就会让线程A一直等待下去,直到线程B结束对该共享变量的使用,线程A才能使用。比如我们在add的方法上加上synchronized
关键字之后在运行则结果一直正确的。 synchronized关键字会使其修改的方法在任时刻只能被一个线程执行,该方法涉及的共享变量在任意时刻只能有一个线程访问(读,写),从而避免了这个方法交错执行的而导致的干扰,这样就消除了竞态。
public class Statistics { private int count = 0; private synchronized void add(int i){ count = count + i; System.out.println("线程"+Thread.currentThread().getId()+":"+count); } public static class StatisticsRunnable implements Runnable{ private Statistics statistics; public StatisticsRunnable( Statistics statistics){ this.statistics = statistics; } @Override public void run() { for(int i=0;i<100;i++){ this.statistics.add(1); } } } public static void main(String[] args) { Statistics statistics = new Statistics(); Thread t1 = new Thread(new StatisticsRunnable(statistics)); Thread t2 = new Thread(new StatisticsRunnable(statistics)); t1.start(); t2.start(); } }
还有一种解决竞态的方法在多个线程访问共享变量时对共享变量的操作加锁,使共享变量在任意时刻只能有一个线程访问(读,写),也就避免了这个方法交错执行的而导致的干扰。
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class Statistics { private Lock lock = new ReentrantLock(); private int count = 0; private synchronized void add(int i){ try{ lock.lock(); count = count + i; System.out.println("线程"+Thread.currentThread().getId()+":"+count); }catch (Exception e){ e.printStackTrace(); }finally { lock.unlock(); } } public static class StatisticsRunnable implements Runnable{ private Statistics statistics; public StatisticsRunnable( Statistics statistics){ this.statistics = statistics; } @Override public void run() { for(int i=0;i<100;i++){ this.statistics.add(1); } } } public static void main(String[] args) { Statistics statistics = new Statistics(); Thread t1 = new Thread(new StatisticsRunnable(statistics)); Thread t2 = new Thread(new StatisticsRunnable(statistics)); t1.start(); t2.start(); } }
当然锁是一种重量级的操作,我们使用锁需要注意很过地方,这个些在接下来的文章中我都会讲到了,从这个两个例子我们可以看出避免竞态的实质就是,使共享变量在任意时刻只能有一个线程访问(读,写),满足我们上一篇文章的多线编程的原子性、可见性、有序性,就可以很好的避免竞态了
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
突破Java面试(49)-分库分表之后全局id的生成
0 Github 1 面试题 分库分表之后,id主键如何处理? 2 考点分析 其实这是分库分表之后你必然要面对的一个问题,就是id咋生成? 要是分成多个表之后,每个表都是从1开始累加,那肯定不对啊,需要一个全局唯一的id来支持! 下面来看看有哪些可行方案~ 3 数据库自增id 分库分表的id主键问题 系统每次得到一个id,都是 往一个库的一个表里插入一条没什么业务含义的数据 然后获取一个数据库自增id 拿到该id后,再写入对应的分库分表中 3.1 优点 就是方便简单,谁都会用 3.2 缺点 就是单库生成自增id,要是高并发的话,就会有瓶颈 如果你硬是要改进,那就专门开一个服务 该服务每次就拿到当前id最大值 然后自己递增几个id,一次性返回一批id 然后再把当前最大id值修改成递增几个id之后的一个值 但是无论怎么说都是基于单个数据库的! 3.3 适用场景 分库分表就俩原因 要
- 下一篇
【从入门到放弃-Java】并发编程-线程安全
概述 并发编程,即多条线程在同一时间段内“同时”运行。 在多处理器系统已经普及的今天,多线程能发挥出其优势,如:一个8核cpu的服务器,如果只使用单线程的话,将有7个处理器被闲置,只能发挥出服务器八分之一的能力(忽略其它资源占用情况)。同时,使用多线程,可以简化我们对复杂任务的处理逻辑,降低业务模型的复杂程度。 因此并发编程对于提高服务器的资源利用率、提高系统吞吐量、降低编码难度等方面起着至关重要的作用。 以上是并发编程的优点,但是它同样引入了一个很重要的问题:线程安全。 什么是线程安全问题 线程在并发执行时,因为cpu的调度等原因,线程会交替执行。如下图例子所示 public class SelfIncremental { private static int count; public static void main(S
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS7设置SWAP分区,小内存服务器的救世主
- CentOS7安装Docker,走上虚拟化容器引擎之路
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
- CentOS8安装Docker,最新的服务器搭配容器使用
- SpringBoot2整合Redis,开启缓存,提高访问速度
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- Docker安装Oracle12C,快速搭建Oracle学习环境
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS8,CentOS7,CentOS6编译安装Redis5.0.7