synchronized 保证三大特性

synchronized(锁对象) {
    // 受保护资源；
}

package juc.synchronized_test.prove;
?
import java.util.ArrayList;
import java.util.List;
?
/**
 * @author : 雪飞oubai
 * @date : 2020/4/9 11:27
 * 目标：演示原子性问题
 * 1、定义一个共享变量 number
 * 2、对number进行1000次 ++ 操作
 * 3、使用 5 个线程来进行
 */
public class Test02Atomicity {
    //1、定义一个共享变量 number
    private static int number = 0;
    private static Object obj = new Object();
?
    public static void main(String[] args) throws InterruptedException {
        Runnable increment = () -> {
            for (int i = 0; i < 10000; i++) {
                synchronized (obj) {
                    number++;
                }
            }
        };
        List<Thread> list = new ArrayList<>();
?
        for (int i = 0; i < 5; i++) {
            Thread t = new Thread(increment);
            t.start();
            list.add(t);
        }
        for (Thread thread : list) {
            thread.join();
        }
        System.out.println("number=" + number);
    }
}

package juc.synchronized_test.prove;
?
import java.util.concurrent.TimeUnit;
?
/**
 * @author : 雪飞oubai
 * @date : 2020/4/9 11:07
 * 目的：演示可见性问题
 * 1、创建一个贡献变量
 * 2、创建一条线程不断的读取共享变量
 * 3、创建一条线程修改共享变量
 */
public class Test01Visibility {
    // 多个线程都会访问的数据，我们称为线程的共享数据
    private static boolean flag = true;
    private static Object obj = new Object();
?
    public static void main(String[] args) throws InterruptedException {
        new Thread(() -> {
            while (flag) {
                synchronized (obj) {
                }
            }
        }).start();
?
        TimeUnit.SECONDS.sleep(1);
?
        new Thread(() -> {
            flag = false;
            System.out.println("时间到，线程2设置为false");
        }).start();
    }
}

int a = 1;
int b = a;

int a =  1;
int b = a;

int a = 1;
int b = a;
int a = 2;

int a = 1;
int b = 2;
int c = a + b;