java高并发中什么是发布对象

这篇文章给大家介绍java高并发中什么是发布对象，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。

发布对象

发布对象：是指使一个对象能够被当前范围之外的代码所使用。

对象逸出：一种错误的发布。当一个对象还没有构造完成时，就使它被其他线程所见。

我们经常需要发布一些对象例如通过类的非私有方法返回对象的引用，或者通过共有静态变量发布对象。

简单例子：

@Slf4j
@NotThreadSafe
public class UnsafePublish {
    private String[] states = {"a", "b", "c"};
    public String[] getStates() {
        return states;
    }

    public static void main(String[] args) {
        UnsafePublish  unsafePublish = new UnsafePublish();
        log.info("{}", Arrays.toString(unsafePublish.getStates()));
        unsafePublish.getStates()[0] = "d";
        log.info("{}", Arrays.toString(unsafePublish.getStates()));
    }
}

输出：

15:42:12.937 [main] INFO com.vincent.example.publish.UnsafePublish - [a, b, c]
15:42:12.942 [main] INFO com.vincent.example.publish.UnsafePublish - [d, b, c]

为什么要做这个例子？UnsafePublish通过getState()方法发布了一个属性，在类的任何外部线程都可以访问这个属性，这样发布对象是不安全的，因为我们无法确定其他线程会不会修改这个属性，从而其他线程访问这个属性时，它的值是不确定的，这样发布的对象就是线程不安全的。

对象逸出

先看一个例子：

@Slf4j
@NotThreadSafe
@NotRecommend
public class Escape {
    private int thisCannBeEscape = 0;
    public Escape() {
        new InnerClass();
    }
    private class InnerClass {
        public InnerClass() {
            log.info("{}",Escape.this.thisCannBeEscape);
        }
    }

    public static void main(String[] args) {
        new Escape();
    }
}

这个例子中定义了一个内部类InnerClass，这个内部类的中引用了外部类的一个引用，有可能在对象没有正确被构造之前就被发布，有可能有不安全的因素在里面。

安全的发布对象

• 在静态初始化函数中初始化一个对象引用

• 将对象的引用保存到volatile类型域或者AtomicReference对象中

• 将对象的引用保存到某个正确构造对象的final类型域中

• 将对象的引用保存到一个由锁保护的域中

懒汉模式 

/**
 * 懒汉模式
 * 单例的实例在第一次使用时进行创建
 */
public class SingletonExample1 {
    //私有构造函数
    private SingletonExample1(){

    }
    //单例对象
    private static SingletonExample1 instance = null;
    //静态工厂方法
    public static SingletonExample1 getInstance(){
        if(instance == null){
            instance = new SingletonExample1();
        }
        return instance;
    }
}

 上面这段代码在单线程的情况下没有问题，在多线程的情况下会有问题，问题出现在代码if(instance ==null){instance = new SingletonExample1();}return instance;部分。两个线程可以同时访问这段代码，因此这段代码有可能会被调用两次，这样两个线程拿到的实例可能是不一样的。这样写是线程不安全的。

懒汉模式-线程安全

@ThreadSafe
@NotRecommend
public class SingletonExample3 {
    //私有构造函数
    private SingletonExample3(){

    }
    //单例对象
    private static SingletonExample3 instance = null;
    //静态工厂方法
    public static synchronized SingletonExample3 getInstance(){
        if(instance == null){
            instance = new SingletonExample3();
        }
        return instance;
    }
}

这样的懒汉模式是线程安全，但是却带来了性能上的开销。而这个开销是我们不希望的。因此并不推荐这种写法。

懒汉模式-双重同步锁单例模式

/**
 * 懒汉模式 -> 双重同步锁单例模式
 * 单例的实例在第一次使用时进行创建
 */
@NotThreadSafe
@ThreadSafe
@NotRecommend
public class SingletonExample4 {
    //私有构造函数
    private SingletonExample4(){

    }
    //单例对象
    private static SingletonExample4 instance = null;

    //正常的执行步骤
    //1.memory = allcate() 分配对象的内存空间
    //2.ctorInstance()初始化对象
    //3.instance = memory 设置instance指向刚分配的内存

    // JVM 和CPU优化,发生了指令重排
    //1.memory = allcate() 分配对象的内存空间
    //3.instance = memory 设置instance指向刚分配的内存
    //2.ctorInstance()初始化对象

    //静态工厂方法
    public static SingletonExample4 getInstance(){
        if(instance == null){ //双重检测机制
            synchronized (SingletonExample4.class) { //同步锁
                if (instance == null) {
                    instance = new SingletonExample4();
                }
            }
        }
        return instance;
    }
}

正常的执行步骤
1.memory = allcate() 分配对象的内存空间
2.ctorInstance()初始化对象
3.instance = memory 设置instance指向刚分配的内存
 上面的步骤在单线程的情况下没有问题，而在多线程情况下JVM 和CPU优化,发生了指令重排
1.memory = allcate() 分配对象的内存空间
3.instance = memory 设置instance指向刚分配的内存
2.ctorInstance()初始化对象

发生指令重排导致双重检测机制线程不安全。因此可以限制不让CPU发生指令重排。可以使用volatile关键字限制指令重排。

private static volatile SingletonExample5 instance = null;

这样就可以实现线程安全了。

因此volatile关键字有两个使用场景。1.状态标示量。2.双重检测。这里就是一个双重检测的应用。

饿汉模式

/**
 * 饿汉模式
 * 单例的实例在类装载时进行创建
 */
@ThreadSafe
public class SingletonExample2 {
    //私有构造函数
    private SingletonExample2(){

    }
    //单例对象
    private static SingletonExample2 instance = new SingletonExample2();
    //静态工厂方法
    public static SingletonExample2 getInstance(){
        return instance;
    }
}

如果单例类的构造函数中，没有过多的操作处理，饿汉模式还可以接受。饿汉模式有什么不足呢？如果构造函数中存在过多的处理，会导致这个类在加载的过程中特别慢，因此可能存在性能问题，如果使用饿汉模式的话只进行类的加载却没有实际的调用的话，会造成资源的浪费。因此使用饿汉模式时一定要考虑两个问题，1.私有构造函数中没有太多的处理。2.这个类肯定会被使用，不会带来资源的浪费。饿汉模式属于线程安全的。

饿汉模式2

@ThreadSafe
public class SingletonExample6 {
    //私有构造函数
    private SingletonExample6(){

    }
    static {
        instance = new SingletonExample6();
    }
    //单例对象
    private static SingletonExample6 instance = null;
    //静态工厂方法
    public static SingletonExample6 getInstance(){
        return instance;
    }

    public static void main(String[] args) {
        System.out.println(getInstance());
        System.out.println(getInstance());
    }
}

这时打印出来的值为null

需要把private static SingletonExample6 instance = null;代码写在static语句块之前：

/**
 * 饿汉模式
 * 单例的实例在类装载时进行创建
 */
@ThreadSafe
public class SingletonExample6 {
    //私有构造函数
    private SingletonExample6(){

    }
    //单例对象
    private static SingletonExample6 instance = null;
    static {
        instance = new SingletonExample6();
    }

    //静态工厂方法
    public static SingletonExample6 getInstance(){
        return instance;
    }

    public static void main(String[] args) {
        System.out.println(getInstance());
        System.out.println(getInstance());
    }
}

当我们在写静态属性和静态代码块时要注意顺序。

枚举模式

/**
 * 饿汉模式
 * 单例的实例在类装载时进行创建
 */
@ThreadSafe
@Recommend
public class SingletonExample7 {
    //私有构造函数
    private SingletonExample7(){

    }
    public static SingletonExample7 getInstance(){
        return Singleton.INSTANCE.getInstance();
    }
    private enum Singleton {
        INSTANCE;
        private SingletonExample7 singleton;

        // JVM保证这个构造方法绝对只调用一次
        Singleton() {
            singleton = new SingletonExample7();
        }
        public SingletonExample7 getInstance() {
            return singleton;
        }

    }

}

枚举模式相比于懒汉模式在安全性方面更容易保证，其次相比于饿汉模式可以在实际调用时才初始化，而在后续使用时也可以取到里面的值。不会造成资源浪费。

关于java高并发中什么是发布对象就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。