你真的掌握了并发编程volatile synchronized么?
生活随笔
收集整理的這篇文章主要介紹了
你真的掌握了并发编程volatile synchronized么?
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
先看代碼:
import java.util.concurrent.atomic.AtomicInteger;/**** @author xialuomantian*/
public class NewTest {static volatile int a = 1;static volatile int b = 1;//static int a = 1;//static int b = 1;public static AtomicInteger aa = new AtomicInteger(0);public static AtomicInteger bb = new AtomicInteger(0);public static AtomicInteger ab = new AtomicInteger(0);static void add() {a++;b++;}static synchronized void print() {if (a > b) {aa.getAndIncrement(); } else if (a < b) {bb.getAndIncrement();} if (a == b) {ab.getAndIncrement();}}public static void main(String[] args) {System.out.println(Thread.currentThread().getName());for (int i = 0; i < 100000; i++) {new Thread(() -> { add();print();}).start();}System.out.println("a>b:" + aa);System.out.println("b>a:" + bb);System.out.println("a==b:" + ab);}
}
再去掉volatile
/** To change this license header, choose License Headers in Project Properties.* To change this template file, choose Tools | Templates* and open the template in the editor.*/
package com.mycompany.mytest;import java.util.concurrent.atomic.AtomicInteger;/**** @author xialuomantian*/
public class NewTest {static int a = 1;static int b = 1;public static AtomicInteger aa = new AtomicInteger(0);public static AtomicInteger bb = new AtomicInteger(0);public static AtomicInteger ab = new AtomicInteger(0);static void add() {a++;b++;}static synchronized void print() {if (a > b) {aa.getAndIncrement(); } else if (a < b) {bb.getAndIncrement();} if (a == b) {ab.getAndIncrement();}}public static void main(String[] args) {System.out.println(Thread.currentThread().getName());for (int i = 0; i < 100000; i++) {new Thread(() -> { add();print();}).start();}System.out.println("a>b:" + aa);System.out.println("b>a:" + bb);System.out.println("a==b:" + ab);}
}
下面是幾種結果:
總結
以上是生活随笔為你收集整理的你真的掌握了并发编程volatile synchronized么?的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: K8S的横向自动扩容的功能Horizon
- 下一篇: 线上java JVM问题排查