java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > java多线程Synchronized

java多线程Synchronized实现可见性原理解析

作者:阳光下的米雪

这篇文章主要介绍了java多线程Synchronized实现可见性原理,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

Synchronized实现可见性原理

可见性

要实现共享变量的可见性,必须保证两点:

Java语言层面支持的可见性的实现方式

synchronized实现可见性

synchronized能够实现:

JMM关于synchronized的两条规定:

线程解锁前对共享变量的修改在下次加锁时对其他线程可见

线程执行互斥代码的过程

重排序:

代码书写的顺序与实际执行的顺序不同,指令重排序是编译器或处理器为了提高程序性能而做得优化

在这里插入图片描述

as-if-serial

as-if-serial:无论如何重排序,程序执行的结果应该与代码顺序执行的结果一致(Java编译器、运行时和处理器都会保证Java在单线程下遵循as-if-serial语义)

在这里插入图片描述

public class SynchronizedTest {
    /**
     * 共享变量
     */
    private boolean ready = false;
    private int result = 0;
    private int number = 1;

    /**
     * 写操作
     */
    public void write(){
        ready = true;//1.1
        number = 2;//1.2
    }
    /**
     * 读操作
     */
    public void read(){
        if(ready){//2.1
            result=number*3;//2.2
        }
        System.out.println("result的值为:"+result);
    }
    /**
     * 内部线程类
     */
    private class ReadWriteThread extends Thread{
        //根据构造方法中传入的flag参数,确定线程执行读操作还是写操作
        private boolean flag;
        public ReadWriteThread(boolean flag){
            this.flag=flag;
        }

        @Override
        public void run() {
            if(flag){
                //构造方法中传入true,执行写操作
                write();
            }else{
                //构造方法中传入false,执行读操作
                read();
            }
        }
    }

    public static void main(String[] args) {
        SynchronizedTest synchronizedTest = new SynchronizedTest();
        //启动线程执行写操作
        synchronizedTest.new ReadWriteThread(true).start();
        //启动线程执行读操作
        synchronizedTest.new ReadWriteThread(false).start();
    }
}

导致共享变量在线程间不可见的原因

1.线程的交叉执行
eg:上述程序执行步骤为1.1-》2.1-》2.2-》1.2

在这里插入图片描述

eg:上述程序执行步骤为1.2-》2.1-》2.2-》1.1

在这里插入图片描述

2.重排序结合线程交叉执行
eg: 2.1和2.2重排序后

int mid = number*3;
if(ready){
	result=mid;
}

共享变量更新后的值没有在工作内存与主内存间及时更新

安全性代码

public class SynchronizedTest {
    /**
     * 共享变量
     */
    private boolean ready = false;
    private int result = 0;
    private int number = 1;

    /**
     * 写操作
     */
    public synchronized void write(){
        ready = true;//1.1
        number = 2;//1.2
    }
    /**
     * 读操作
     */
    public synchronized void read(){
        if(ready){//2.1
            result=number*3;//2.2
        }
        System.out.println("result的值为:"+result);
    }
    /**
     * 内部线程类
     */
    private class ReadWriteThread extends Thread{
        //根据构造方法中传入的flag参数,确定线程执行读操作还是写操作
        private boolean flag;
        public ReadWriteThread(boolean flag){
            this.flag=flag;
        }

        @Override
        public void run() {
            if(flag){
                //构造方法中传入true,执行写操作
                write();
            }else{
                //构造方法中传入false,执行读操作
                read();
            }
        }
    }

    public static void main(String[] args) {
        SynchronizedTest synchronizedTest = new SynchronizedTest();
        //启动线程执行写操作
        synchronizedTest.new ReadWriteThread(true).start();
        //启动线程执行读操作
        synchronizedTest.new ReadWriteThread(false).start();
    }
}

在这里插入图片描述

到此这篇关于java多线程Synchronized实现可见性原理的文章就介绍到这了,更多相关java多线程Synchronized内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:
阅读全文