Volatile详解

package com.shi.jvm;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

class MyData{
	
	volatile int num = 0;
	
	public void addTo60() {
		this.num = 60;
	}
	
	//目前num 是怎加了 volatile 修饰的 ：验证不保证原子性
	public void addPlus() {
		num++;
	}
	
	/**
	 * 使用原子整形来保证原子性
	 */
	AtomicInteger atomicInteger = new AtomicInteger();
	public void myAddAtomic() {
		atomicInteger.getAndIncrement();
	}
	
}

/**
 * 1 验证volatile的可见性 : 就是及时通知别的线程该值发生变化了
 * 		1.1. 假如 int num = 0; 没有增加 volatile关键字的修饰
 * 		结果：主线程一直在循环，一直没有收到 num 改变的通知
 *  	1.2. 在  int num = 0 前面增加 volatile关键字
 *  	结果： 在线程1把 num值改变之后 立即收到通知，退出循环
 *  
 * 2 验证volatile 不保证原子性
 * 	 2.1 原子性什么意思？
 * 		不可分割，完整性，也即某个线程正在做具体业务时，中间不可以被加塞或者被分割，
 * 	   	需要整体完整，要么同时成功，要么同时失败
 * 	 2.2 volatile 不保证原子性 验证
 *   	启动20个线程，每个线程自加1000次 看最钟结果
 *   	结果：每次执行的 myData.num 结果都是不一样的 
 *   2.3 为什么？
 *   	原因：num++ 底层是要经过3步操作才完成的
 *   2.4 怎么解决
 *   	(1).在方法中增加 synchronized
 *   	(2).使用 AtomicInteger 来实现原子性
 * @author shiye
 *
 */
public class ValatileTest {

	public static void main(String[] args) {
		ValatileTest.notAtomic();
	}
	
	/**
	 * 1 验证方法的可见性
	 */
	public static void checkSee() {
		MyData myData = new MyData();
		
		//1 启动 1 个新的线程，在这个线程里面改变主线程里面的值
		new Thread( () -> {
			System.out.println(Thread.currentThread().getName() + "\t come in");
			//睡眠3秒
			try {
				TimeUnit.SECONDS.sleep(3);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			myData.addTo60();
			System.out.println(Thread.currentThread().getName() + "\t updated num value:" + myData.num);
		},"AAA").start();
		
		//2 主线程是第2个线程，一直在循环
		while(myData.num == 0 ) {
		}
		
		System.out.println(Thread.currentThread().getName() + "\t mission is over" + myData.num);
	}
	
	
	/**
	 * 2 volatile 验证不是原子性
	 */
	public static void notAtomic(){
		MyData myData = new MyData();
		for (int i = 0; i < 20; i++) {
			//启动20个线程，每个线程自家1000次
			new Thread(() -> {
				for (int j = 0; j < 1000; j++) {
					myData.addPlus();//没有实现原子性
					myData.myAddAtomic();//使用原子整形的方式来实现原子性
				}
			},String.valueOf(i)).start();
		}
		//需要等待上面20个线程全部执行完毕，再看main方法取得最终结果是多少
		while(Thread.activeCount()>2) {
			//剩下俩个线程一个是GC 另一个是main
			Thread.yield();
		}
		System.out.println(Thread.currentThread().getName() + "\t int mission is over : " + myData.num);
		System.out.println(Thread.currentThread().getName() + "\t AtomicInteger mission is over : " + myData.atomicInteger);
	}

}


/**
 * 在多级环境中无法保证指令执行的顺序是按照代码写的顺序执行的，有很多不可测性
 * @author shiye
 *
 */
class ReSortSeqDemo{
	int a = 0;
	boolean flag = false;
	
	public void method01() {
		a = 1;  //语句1
		flag = true; //语句2
	}
	public void method02() {
		if(flag) {
			a = a +5;
			System.out.println("method02 方法提前了 请注意a : " + a);
		}
	}
}