- 浏览: 459796 次
- 性别:
- 来自: 杭州
文章分类
最新评论
-
ty1972873004:
sunwang810812 写道我运行了这个例子,怎么结果是这 ...
Java并发编程: 使用Semaphore限制资源并发访问的线程数 -
lgh1992314:
simpleDean 写道请问,Logger.setLevel ...
Java内置Logger详解 -
sunwang810812:
我运行了这个例子,怎么结果是这样的:2号车泊车6号车泊车5号车 ...
Java并发编程: 使用Semaphore限制资源并发访问的线程数 -
jp260715007:
nanjiwubing123 写道参考你的用法,用如下方式实现 ...
面试题--三个线程循环打印ABC10次的几种解决方法 -
cb_0312:
SurnameDictionary文章我没看完,现在懂了
中文排序
在本篇博文中,将给出一个实例去验证volatile修饰的变量并不能保证其数据同步.
Java内存模型规定了所有变量都存储在主内存中,每条线程都有自己的工作内存,线程的工作内存保存了被该线程使用到变量的主内存副本拷贝,线程对变量的所有操作(读取,赋值等)都必须在工作内存中进行,而不能直接读写主内存中的变量。不同线程也不能直接访问对方工作内存中的变量,线程间变量值的传递均需要通过主内存来完成,线程,主内存,工作内存三者的交互关系如图所示。
当一个变量定义成volatile之后, 保证了此变量对所有线程的可见性,也就是说当一条线程修改了这个变量的值,新的值对于其它线程来说是可以立即得知的.此时,该变量的读写操作直接在主内存中完成.
Volatile 变量具有 synchronized 的可见性特性,但是不具备原子特性。
Volatile variables share the visibility features of synchronized, but none of the atomicity features.
虽然增量操作(x++)看上去类似一个单独操作,实际上它是一个由读取-修改-写入操作序列组成的组合操作,必须以原子方式执行,而 volatile 不能提供必须的原子特性。
While the increment operation (x++) may look like a single operation, it is really a compound read-modify-write sequence of operations that must execute atomically -- and volatile does not provide the necessary atomicity.
在多线程并发的环境下, 各个线程的读/写操作可能有重叠现象, 在这个时候, volatile并不能保证数据同步.
下面将给出一个实例:
实例 ==> 500个线程一起运行,每个线程对1到100求和1000次操作,然后将一个volatile共享变量值加1. 当500个线程都完成操作之后, 期望的值是500,因为每个线程执行完毕之后都会对这个volatile变量加1.
一直循环执行这个程序,直到出现volatile变量的值小于500为止,也就是出现数据不同步.
public class NonSafeThread implements Runnable { /** 共享资源, 每个线程执行完之后加 1 */ private volatile int volatileCount = 0; public void run() { /* * 每个线程调用sum100()方法,1000次 */ for (int i = 1; i <= 1000; i++) { sum100(); } /* * 计算完毕之后, volatileCount 加 1 */ increase(); } private void increase() { volatileCount++; } /** * 对 1 到 100 求和 */ private int sum100() { int result = 0; for (int i = 1; i <= 100; i++) { result += i; } return result; } /** * @return the volatileCount */ public int getVolatileCount() { return volatileCount; } }
/** * @author Eric * * @version 1.0 */ public class NonSafeThreadTest { public static void main(String[] args) { /** 记录循环次数 */ int loopCount = 0; /** 以main函数主线程创建一个是线程组 */ ThreadGroup threadGroup = Thread.currentThread().getThreadGroup(); for (;;) { loopCount++; /* * 启动500个线程,初始化的线程会添加到当前线程组中 */ NonSafeThread nonSafeThread = new NonSafeThread(); startThreads(nonSafeThread); /* * 如果线程组中除了主线程之外,还有其它线程,则休眠5毫秒,然后再判断线程组中 剩余的线程数,直到只剩下主线程一个为止。 */ while (!isOnlyMainThreadLeft(threadGroup)) { sleep(5); } /* * 500个线程运行完毕,那么此时的volatile变量volatileCount的值应该500, 因为每个线程将其值加1。 * * 验证是否出现线程不安全的情况。 */ validate(loopCount, nonSafeThread.getVolatileCount(), 500); } } /** * 启动500个线程 */ private static void startThreads(NonSafeThread nonSafeThread) { for (int i = 0; i < 500; i++) { new Thread(nonSafeThread).start(); } } /** * 验证是否出现线程不安全的情况。 如果是,则打印出线程不安全的信息。 */ private static void validate(int loopCount, int actualValue, int expectedValue) { if (!isVolatileCountExpected(actualValue, expectedValue)) { printNonSafeMessage(loopCount, actualValue, expectedValue); /* * 正常退出程序。 */ System.exit(0); } } /** * 在控制台打印出现线程不安全时的信息。 */ private static void printNonSafeMessage(int loopCount, int actualValue, int expectedValue) { System.out.println(String.format( "第%d次循环,出现线程不安全的情况,volatile的值不正确,期望值是%d, 但是500个线程运行的情况下是%d", loopCount, expectedValue, actualValue)); } /** * 判断实际中的volatile值与期望值是否一致。 */ private static boolean isVolatileCountExpected(int actualValue, int expectedValue) { return actualValue == expectedValue; } /** * 让线程休眠millis毫秒 */ private static void sleep(long millis) { try { Thread.sleep(millis); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 判断一个线程组是否只剩下主线程了。 * * 如果是则返回true,如果不是则放回false. */ private static boolean isOnlyMainThreadLeft(ThreadGroup tg) { return tg.activeCount() == 1; } }
某次运行,输出的结果如下:
第83次循环,出现线程不安全的情况,volatile的值不正确,期望值是500, 但是500个线程运行的情况下是499
在这种情况下,可以通过 Lcak和synchronized来保证数据的同步.
如:
1. 使用Lock,修改NonSafeThread类的run方法的内容:
public void run() { lock.lock(); try { /* * 每个线程调用sum100()方法,1000次 */ for (int i = 1; i <= 1000; i++) { sum100(); } /* * 计算完毕之后, volatileCount 加 1 */ increase(); } finally { lock.unlock(); } }
2. 使用synchronized
public void run() { synchronized ("") { /* * 每个线程调用sum100()方法,1000次 */ for (int i = 1; i <= 1000; i++) { sum100(); } /* * 计算完毕之后, volatileCount 加 1 */ increase(); } }
如果用Lock或者synchronized修改了NonSafeThread类, 如果再想跑这个程序的话,需要控制一下NonSafeThreadTest中for循环中执行的次数,比如1000次 (我运行程序的时候,一般都在100次以内打印出数据不安全的结果),以免导致程序在Lock或者synchronized修改后一直执行下去.
评论
12 楼
MouseLearnJava
2013-08-06
freezingsky 写道
哥们,把内存模型这一块研究完一起讲了,并发这一块就基本完成了!加油!
谢谢你的建议. 正在学习Java内存模型,以后会在博文中记录一些学习的内容.
在这之前,想先记录下 Semaphore 和 Exchanger的内容. 谢谢
11 楼
MouseLearnJava
2013-08-06
wwy_0918 写道
anlystar 写道
楼主理解错了,
volatile是 原子变量 ,保证该变量在存取的时候是同步的,但是 "++" 并不是原子操作,在虚拟机底层“++”也是分几步实现的:先取、在计算、最后赋值,在这几步之间其他线程修改了该变量也会出现线程问题,volatile比较适用于一个线程更改,多条线程读取的情况,能保证在一条线程中更改了,其他线程能立即获取到最新的值,若是多条线程更改的情况,请使用AtomicInteger 或者AtomicLong等
这个是正确的
volatile是 原子变量 ,保证该变量在存取的时候是同步的,但是 "++" 并不是原子操作,在虚拟机底层“++”也是分几步实现的:先取、在计算、最后赋值,在这几步之间其他线程修改了该变量也会出现线程问题,volatile比较适用于一个线程更改,多条线程读取的情况,能保证在一条线程中更改了,其他线程能立即获取到最新的值,若是多条线程更改的情况,请使用AtomicInteger 或者AtomicLong等
freezingsky 写道
volatile不能保证数据的同步,只能说它具有可见性。这里涉及的原因,与java的内存模型有关。同时,对于数据的操作,比如++或者--,这里就涉及到一些所谓的原语(PV)。记得java在并发包里用的是类似玩CAS(好像是compare and set?)的方式来完成非锁同步。
谢谢你们的指正和信息.
正是Java里面的运算并非原子操作,导致了volatile变量的运算在并发下产生了不安全.
10 楼
freezingsky
2013-08-05
哥们,把内存模型这一块研究完一起讲了,并发这一块就基本完成了!加油!
9 楼
JavaSam
2013-08-05
fisher123 写道
其实LZ想说volatile只是一种弱同布策略,对这个变量的操作必须是原子的,不然就会出现错误。
如果操作不是原子的,就必须用强同步措施,lock,synchronized等等。
如果操作不是原子的,就必须用强同步措施,lock,synchronized等等。
好吧,错怪lz了
8 楼
wwy_0918
2013-08-05
wwy_0918 写道
anlystar 写道
楼主理解错了,
volatile是 原子变量 ,保证该变量在存取的时候是同步的,但是 "++" 并不是原子操作,在虚拟机底层“++”也是分几步实现的:先取、在计算、最后赋值,在这几步之间其他线程修改了该变量也会出现线程问题,volatile比较适用于一个线程更改,多条线程读取的情况,能保证在一条线程中更改了,其他线程能立即获取到最新的值,若是多条线程更改的情况,请使用AtomicInteger 或者AtomicLong等
这个是正确的volatile是 原子变量 ,保证该变量在存取的时候是同步的,但是 "++" 并不是原子操作,在虚拟机底层“++”也是分几步实现的:先取、在计算、最后赋值,在这几步之间其他线程修改了该变量也会出现线程问题,volatile比较适用于一个线程更改,多条线程读取的情况,能保证在一条线程中更改了,其他线程能立即获取到最新的值,若是多条线程更改的情况,请使用AtomicInteger 或者AtomicLong等
freezingsky 写道
volatile不能保证数据的同步,只能说它具有可见性。这里涉及的原因,与java的内存模型有关。同时,对于数据的操作,比如++或者--,这里就涉及到一些所谓的原语(PV)。记得java在并发包里用的是类似玩CAS(好像是compare and set?)的方式来完成非锁同步。
所说。
7 楼
JavaSam
2013-08-05
没有人,也没有哪本书说volatile能保证数据同步!!
6 楼
wwy_0918
2013-08-05
anlystar 写道
楼主理解错了,
volatile是 原子变量 ,保证该变量在存取的时候是同步的,但是 "++" 并不是原子操作,在虚拟机底层“++”也是分几步实现的:先取、在计算、最后赋值,在这几步之间其他线程修改了该变量也会出现线程问题,volatile比较适用于一个线程更改,多条线程读取的情况,能保证在一条线程中更改了,其他线程能立即获取到最新的值,若是多条线程更改的情况,请使用AtomicInteger 或者AtomicLong等
这个是正确的volatile是 原子变量 ,保证该变量在存取的时候是同步的,但是 "++" 并不是原子操作,在虚拟机底层“++”也是分几步实现的:先取、在计算、最后赋值,在这几步之间其他线程修改了该变量也会出现线程问题,volatile比较适用于一个线程更改,多条线程读取的情况,能保证在一条线程中更改了,其他线程能立即获取到最新的值,若是多条线程更改的情况,请使用AtomicInteger 或者AtomicLong等
5 楼
freezingsky
2013-08-05
volatile不能保证数据的同步,只能说它具有可见性。这里涉及的原因,与java的内存模型有关。同时,对于数据的操作,比如++或者--,这里就涉及到一些所谓的原语(PV)。记得java在并发包里用的是类似玩CAS(好像是compare and set?)的方式来完成非锁同步。
4 楼
anlystar
2013-08-05
楼主理解错了,
volatile是 原子变量 ,保证该变量在存取的时候是同步的,但是 "++" 并不是原子操作,在虚拟机底层“++”也是分几步实现的:先取、在计算、最后赋值,在这几步之间其他线程修改了该变量也会出现线程问题,volatile比较适用于一个线程更改,多条线程读取的情况,能保证在一条线程中更改了,其他线程能立即获取到最新的值,若是多条线程更改的情况,请使用AtomicInteger 或者AtomicLong等
volatile是 原子变量 ,保证该变量在存取的时候是同步的,但是 "++" 并不是原子操作,在虚拟机底层“++”也是分几步实现的:先取、在计算、最后赋值,在这几步之间其他线程修改了该变量也会出现线程问题,volatile比较适用于一个线程更改,多条线程读取的情况,能保证在一条线程中更改了,其他线程能立即获取到最新的值,若是多条线程更改的情况,请使用AtomicInteger 或者AtomicLong等
3 楼
fisher123
2013-08-05
其实LZ想说volatile只是一种弱同布策略,对这个变量的操作必须是原子的,不然就会出现错误。
如果操作不是原子的,就必须用强同步措施,lock,synchronized等等。
如果操作不是原子的,就必须用强同步措施,lock,synchronized等等。
2 楼
michaellou
2013-08-05
volatile不稳定
1 楼
sd6815892
2013-08-05
楼主对volatile不具备原子性用代码阐述的很清楚,这个在很多地方都能看到,不过我想看到volatile的可见性也能用代码阐述,也就是比较有volatile和不用volatile的变量有什么不同
发表评论
-
工厂类中移除if/else语句
2016-07-10 19:52 847面向对象语言的一个强大的特性是多态,它可以用来在代码中移除 ... -
Java编程练手100题
2014-12-11 17:13 6667本文给出100道Java编程练手的程序。 列表如下: 面 ... -
数组复制的三种方法
2014-11-30 12:57 2172本文将给出三种实现数组复制的方法 (以复制整数数组为例)。 ... -
数组复制的三种方法
2014-11-30 12:54 0本文将给出三种实现数组复制的方法 (以复制整数数组为例)。 ... -
四种复制文件的方法
2014-11-29 13:21 1681尽管Java提供了一个类ava.io.File用于文件的操 ... -
判断一个字符串中的字符是否都只出现一次
2014-11-25 12:58 2651本篇博文将给大家带来几个判断一个字符串中的字符是否都只出现一 ... -
使用正则表达式判断一个数是否为素数
2014-11-23 13:35 2101正则表达式能够用于判断一个数是否为素数,这个以前完全没有想过 ... -
几个可以用英文单词表达的正则表达式
2014-11-21 13:12 3694本文,我们将来看一下几个可以用英文单词表达的正则表达式。这些 ... -
(广度优先搜索)打印所有可能的括号组合
2014-11-20 11:58 1911问题:给定一个正整n,作为括号的对数,输出所有括号可能 ... -
随机产生由特殊字符,大小写字母以及数字组成的字符串,且每种字符都至少出现一次
2014-11-19 14:48 3936题目:随机产生字符串,字符串中的字符只能由特殊字符 (! ... -
找出1到n缺失的一个数
2014-11-18 12:57 3112题目:Problem description: You h ... -
EnumSet的几个例子
2014-11-14 16:24 8703EnumSet 是一个与枚举类型一起使用的专用 Set 实现 ... -
给定两个有序数组和一个指定的sum值,从两个数组中各找一个数使得这两个数的和与指定的sum值相差最小
2014-11-12 11:24 3281题目:给定两个有序数组和一个指定的sum值,从两个数组 ... -
Java面试编程题练手
2014-11-04 22:49 6649面试编程 写一个程序,去除有序数组中的重复数字 编 ... -
Collections用法整理
2014-10-22 20:55 9795Collections (java.util.Collect ... -
The Code Sample 代码实例 个人博客开通
2014-09-04 18:48 1368个人博客小站开通 http://thecodesample. ... -
Collections.emptyXXX方法
2014-06-08 13:37 2100从JDK 1.5开始, Collections集合工具类中预先 ... -
这代码怎么就打印出"hello world"了呢?
2014-06-08 00:37 7353for (long l = 4946144450195624L ... -
最短时间过桥
2014-04-21 22:03 4068本文用代码实现最短时间过桥,并且打印如下两个例子的最小过桥时间 ... -
将数组分割成差值最小的子集
2014-04-20 22:34 2836本文使用位掩码实现一个功能 ==》将数组分割成差值最小的子集 ...
相关推荐
此外,本书还提供了有关并发编程的全方位的详细内容,例如限制和同步、死锁和冲突、依赖于状态的操作控制、异步消息传递和控制流、协作交互,以及如何创建基于web的服务和计算型服务。 本书的读者对象是那些希望掌握...
3.4.2 示例:使用Volatile类型来发布不可变对象 3.5 安全发布 3.5.1 不正确的发布:正确的对象被破坏 3.5.2 不可变对象与初始化安全性 3.5.3 安全发布的常用模式 3.5.4 事实不可变对象 3.5.5 可变对象 3.5.6 ...
3.4.2 示例:使用Volatile类型来发布不可变对象 3.5 安全发布 3.5.1 不正确的发布:正确的对象被破坏 3.5.2 不可变对象与初始化安全性 3.5.3 安全发布的常用模式 3.5.4 事实不可变对象 3.5.5 可变对象 3.5.6 ...
本书全面介绍了如何使用Java 2平台进行并发编程,较上一版新增和扩展的内容包括:, ·存储模型 ·取消 ·可移植的并行编程 ·实现并发控制的工具类, Java平台提供了一套广泛而功能强大的api,工具和技术。...
龙果 java并发编程原理实战 第2节理解多线程与并发的之间的联系与区别 [免费观看] 00:11:59分钟 | 第3节解析多线程与多进程的联系以及上下文切换所导致资源浪费问题 [免费观看] 00:13:03分钟 | 第4节学习并发的四...
本资源为您提供了关于 Java 并发编程理论基础的精讲,涵盖了多线程编程的核心概念、基本原理以及在 Java 中的应用。通过深入学习,您将建立坚实的并发编程基础,能够更好地理解和应对多线程编程中的挑战。 并发编程...
同步容器与并发容器.mp4 并发容器CopyOnWriteArrayList原理与使用.mp4 并发容器ConcurrentLinkedQueue原理与使用.mp4 Java中的阻塞队列原理与使用.mp4 实战:简单实现消息队列.mp4 并发容器ConcurrentHashMap原理与...
第46节同步容器与并发容器00:18:44分钟 | 第47节并发容器CopyOnWriteArrayList原理与使用00:15:52分钟 | 第48节并发容器ConcurrentLinkedQueue原理与使用00:31:03分钟 | 第49节Java中的阻塞队列原理与使用00:26:...
java并发编程原理实战 第2节理解多线程与并发的之间的联系与区别 [免费观看] 00:11:59分钟 | 第3节解析多线程与多进程的联系以及上下文切换所导致资源浪费问题 [免费观看] 00:13:03分钟 | 第4节学习并发的四个...
Java线程:volatile关键字 Java线程:新特征-线程池 Java线程:新特征-有返回值的线程 Java线程:新特征-锁(上) Java线程:新特征-锁(下) Java线程:新特征-信号量 Java线程:新特征-阻塞队列 Java线程:新特征-...
Java线程:volatile关键字 Java线程:新特征-线程池 Java线程:新特征-有返回值的线程 Java线程:新特征-锁(上) Java线程:新特征-锁(下) Java线程:新特征-信号量 Java线程:新特征-阻塞队列 Java线程:新特征-...
Java并发编程常见知识点源码集锦,涉及到对象锁,Executors多任务线程框架,线程池等示例,列出一些源码包中包括的内容: volatile关键字的非原子性、volatile关键字的使用、AtomicInteger原子性操作、线程安全小...
主要介绍了Java并发编程之volatile变量介绍,volatile提供了弱同步机制,用来确保将变量更新通知到其它线程,需要的朋友可以参考下
并发编程:编写多线程代码,解决多线程带来的问题 为什么要学并发编程? 首先,来看一个案例:手写网站服务器案例。 高性能应用程序的一把钥匙,应用程序的翅膀,面试高频的考点 中间件几乎都是多线程应用:MySQL、...
volatile关键字: 1:简化实现或者同步策略验证的...1:写入变量不依赖变量的当前值,或者能够保证只有单一的线程修改变量的值; 2:变量不需要和其他变量共同参与不变约束; 3:访问变量时不需要其他原因需要加锁。
java并发编程 基础知识,守护线程与线程, 并行和并发有什么区别? 什么是上下文切换? 线程和进程区别 什么是线程和进程? 创建线程有哪几种方式?,如何避免线程死锁 线程的 run()和 start()有什么区别? 什么是 ...