Java线程安全 关于原子性与volatile的试验
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Java线程安全 关于原子性与volatile的试验，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3025字，纯文字阅读大概需要5分钟。
内容图文
1. 变量递增试验
1
static
/*
volatile
*/
int shared=0;//volatile也无法保证++操作的原子性 2staticsynchronizedint incrShared(){//不加synchronized的话，shared最终结果值小于预期 3return ++shared;
4 }
5publicstaticvoid testIncrShared(String[] args) throws InterruptedException {
6 shared=0;
7 Thread[] thrds = new Thread[20];
8for(int j=0;j<thrds.length;j++){
9 thrds[j] = new Thread(new Runnable() {
10 @Override
11publicvoid run() {
12for(int k=0;k<1000;k++){
13 System.out.println(incrShared());
14 }
15 }
16 });
17 }
18for(int j=0;j<thrds.length;j++){
19 thrds[j].start();
20 }
21for(int j=0;j<thrds.length;j++){
22 thrds[j].join();
23 }
24 System.out.println(shared);
25 }
2. volatile试验
1
static
/*
volatile
*/
int a0,a1;//这里加volatile的话，可以避免r0==r1==0的结果 2static/*volatile*/int r0,r1;//这里即使加volatile，也无法避免r0==r1==0的结果 3publicstaticvoid testVolatile(String[] args) throws InterruptedException {
4int[] a=newint[2];
5int[] r=newint[2];
6finalint SLEEP=10;
7final Object lock=new Object();
8 Runnable run1=new Runnable() {
9 @Override
10publicvoid run() {
11try {
12 Thread.sleep(SLEEP);
13 } catch (InterruptedException e) {
14 e.printStackTrace();
15 }
16//synchronized (lock) {//加锁也可以建立happens-before关系，避免r0==r1==0的结果17 a0=1;
18//}19 r1=a1;
20 }
21 };
22 Runnable run2=new Runnable() {
23 @Override
24publicvoid run() {
25try {
26 Thread.sleep(SLEEP);
27 } catch (InterruptedException e) {
28 e.printStackTrace();
29 }
30//synchronized (lock) {31 a1=1;
32//}33 r0=a0;
34 }
35 };
36 Thread thrd1;
37 Thread thrd2;
3839int i;
40int[][] acnt=newint[2][2];
41int[][] rcnt=newint[2][2];
42for(i=0;i<10000;i++){
43 a0=a1=0;
44 r0=r1=0;
45 thrd1 = new Thread(run1);
46 thrd2 = new Thread(run2);
4748 thrd1.start();
49 thrd2.start();
5051 thrd1.join();
52 thrd2.join();
5354 a[0]=a0;
55 a[1]=a1;
56 r[0]=r0;
57 r[1]=r1;
58 System.out.println(i);
59 System.out.println(Arrays.toString(a));
60 System.out.println(Arrays.toString(r));
61 acnt[a[0]][a[1]]++;
62 rcnt[r[0]][r[1]]++;
63 }
64 System.out.println(Arrays.deepToString(acnt));
65 System.out.println(Arrays.deepToString(rcnt));
66 }
3. volatile试验2
1
static
boolean shouldStop=false;
2publicstaticvoid testVolatile2(String[] args) throws InterruptedException {
3 shouldStop=false;
4 Runnable run1=new Runnable() {
5 @Override
6publicvoid run() {
7int i=0;
8while (!shouldStop) {//无法读取到线程2修改后的shouldStop值，导致无限循环 9 i++;
10//System.out.println(i);//如果调用其他函数的话，就又可以读取到shouldStop的最新值了11 }
12 }
13 };
14 Runnable run2=new Runnable() {
15 @Override
16publicvoid run() {
17try {
18 Thread.sleep(10);
19 } catch (InterruptedException e) {
20 e.printStackTrace();
21 }
22 shouldStop=true;
23 }
24 };
25 Thread thrd1;
26 Thread thrd2;
2728int i;
29int[][] acnt=newint[2][2];
30int[][] rcnt=newint[2][2];
31for(i=0;i<100;i++){
32 thrd1 = new Thread(run1);
33 thrd2 = new Thread(run2);
3435 thrd1.start();
36 thrd2.start();
3738 thrd2.join();
39 System.out.println(i);
40 System.out.println(shouldStop);
41 thrd1.join();
4243 }
44 }
原文：http://www.cnblogs.com/SonicU/p/6852888.html
内容总结
以上是互联网集市为您收集整理的Java线程安全 关于原子性与volatile的试验全部内容，希望文章能够帮你解决Java线程安全 关于原子性与volatile的试验所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】