Java多线程与高并发(三):对象的安全发布与共享策略

面试官:你知道如何发布或共享一个对象吗?

发布对象:使一个对象能够被其他线程、其他作用域的代码所使用。

变量逸出原有作用域

<figcaption style="display: block; text-align: center; font-size: 1rem; line-height: 1.6; color: rgb(144, 144, 144); margin-top: 2px;"></figcaption>

import java.util.Arrays;

public class Main {
    private String[] strs = {"1", "2", "3"};

    public String[] getStrs() {
        return strs;
    }

    public static void main(String[] args) {
        Main m1 = new Main();
        System.out.println(Arrays.toString(m1.getStrs()));
        m1.getStrs()[0] = "4";
        System.out.println(Arrays.toString(m1.getStrs()));
    }
}

通过访问对象中的共有方法获取私有变量的值,然后更改内部数据,则导致变量逸出作用域。但是我们有时候就是想暴露私有成员变量出来让我们去修改,所以提供getter是没毛病的,不过要注意的是我们在编码的时候需要对仅仅需要发布的对象进行发布。

对象逸出

对象逸出:当一个对象还没构造完成,就使它被其他线程所见。

以下代码发布了一个未完成构造的对象到另一个对象中:

<figcaption style="display: block; text-align: center; font-size: 1rem; line-height: 1.6; color: rgb(144, 144, 144); margin-top: 2px;"></figcaption>

public class Main {

    public Main() {
        System.out.println(Main.this);
        System.out.println(Thread.currentThread());
        Thread t = new Thread(InnerClass::new);
        t.start();
    }

    class InnerClass {
        public InnerClass() {
            System.out.println(Main.this);
            System.out.println(Thread.currentThread());
        }
    }

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

this引用被线程t共享,故线程t的发布将导致Main对象的发布,由于Main对象被发布时可能还未构造完成,这将导致Main对象逸出(在构造函数中创建线程是可以的,但是不要在构造函数执行完之前启动线程)。

<figcaption style="display: block; text-align: center; font-size: 1rem; line-height: 1.6; color: rgb(144, 144, 144); margin-top: 2px;"></figcaption>

public class Main {
    private Thread t;

    private Main() {
        System.out.println(Main.this);
        System.out.println(Thread.currentThread());
        this.t = new Thread(InnerClass::new);
    }

    class InnerClass {
        public InnerClass() {
            System.out.println(Main.this);
            System.out.println(Thread.currentThread());
        }
    }

    public static Main getMainInstance() {
        Main main = new Main();
        main.t.start();
        return main;
    }

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

通过私有构造函数 + 工厂模式解决。

安全发布策略

安全地发布对象是保证对象在其他线程可见之前一定是完成初始化的。那么我们要做的就是控制初始化过程,首先就需要将构造器私有化,接下来就通过不同的方式来完成对象初始化。

将对象的引用在静态初始化函数中初始化

<figcaption style="display: block; text-align: center; font-size: 1rem; line-height: 1.6; color: rgb(144, 144, 144); margin-top: 2px;"></figcaption>

public class Singleton {
    private static Singleton instance = new Singleton();

    private Singleton() {
    }

    public static Singleton getInstance() {
        return instance;
    }
}

直接在静态变量后new出来或者在static代码块中初始化,通过JVM的单线程类加载机制来保证该对象在其他对象访问之前被初始化

将对象的初始化手动同步处理

<figcaption style="display: block; text-align: center; font-size: 1rem; line-height: 1.6; color: rgb(144, 144, 144); margin-top: 2px;"></figcaption>

public class Singleton {
    private static Singleton instance;

    private Singleton() {
    }

    public static synchronized Singleton getInstance() {
        if (instance == null) {
            instance = new Singleton();
        }
        return instance;
    }
}

使用volidate修饰变量

<figcaption style="display: block; text-align: center; font-size: 1rem; line-height: 1.6; color: rgb(144, 144, 144); margin-top: 2px;"></figcaption>

public class Singleton {
    private static volatile Singleton instance;

    private Singleton() {
    }

    public static Singleton getInstance() {
        if (instance == null) {
            synchronized (Singleton.class) {
                if (instance == null) {
                    instance = new Singleton();
                }
            }
        }
        return instance;
    }
}

为了实现懒汉式+线程安全,可能需要使用DCL双重检验锁来完成,那么instance = new Singleton();就涉及到同步问题,最终会导致另一个线程拿到了尚未初始化完成的对象。所以使用volidate来修饰。详细解释可参看上篇文章。

安全共享策略

安全共享是在多线程访问共享对象时,让对象的行为保持逻辑正常。

线程封闭

将对象封闭在一个线程内部,那么其他线程当然无法访问,则这些对象不可能涉及到共享问题,有以下方式:

  • Ad-hoc线程封闭:维护线程封闭完全由编程承担,不推荐
  • 局部变量封闭:局部变量的固有属性之一就是封闭在执行线程内,无法被外界引用,所以尽量使用局部变量可以减少逸出的发生
  • ThreadLocal:是一个能提供线程私有变量的工具类。基于每个Thread对象中保存了ThreadLocalMap对象,ThreadLocal类就在get和set方法中通过<ThreadLocal, value>键值对操作ThreadLocalMap,推荐。通常使用在传递每个线程(请求)的上下文。

<figcaption style="display: block; text-align: center; font-size: 1rem; line-height: 1.6; color: rgb(144, 144, 144); margin-top: 2px;"></figcaption>

public class ThreadLocalTest {
    private ThreadLocal<String> localString = new ThreadLocal<>();

    public static void main(String[] args) {
        ThreadLocalTest t = new ThreadLocalTest();
        Runnable runnable = () -> {
            t.localString.set("localString in thread: " + Thread.currentThread());
            System.out.println(t.localString.get());
        };
        new Thread(runnable).start();
        new Thread(runnable).start();
    }
}

以上代码表现,尽管是从在同一个对象中的同一个成员变量取值,也会因为线程不同的原因取到不同的值,因为set的时候ThreadLocal会根据线程来设置进对应的map中。

final

final的对象的状态只有一种状态,并且该状态由其构造器控制。如果一定要将发布对象,那么不可变的对象是首选,因为其一定是多线程安全的,可以放心地被用来数据共享。

但引用的变量的内容还是能被修改,仅仅保证了引用不能被修改,如下:

<figcaption style="display: block; text-align: center; font-size: 1rem; line-height: 1.6; color: rgb(144, 144, 144); margin-top: 2px;"></figcaption>

public class ImmutableExample1 {

    private final static Integer a = 1;
    private final static String b = "2";
    private final static Map<Integer, Integer> map = Maps.newHashMap();

    static {
        map.put(1, 2);
        map.put(3, 4);
        map.put(5, 6);
    }

    public static void main(String[] args) {
//        a = 2;
//        b = "3";
//        map = Maps.newHashMap();
        map.put(1, 3);
        log.info("{}", map.get(1));
    }
}

Collections.unmodifiableMap(map)则可以将可修改的map转换为不可修改的map,或者使用使用com.google.guava中的ImmutableXXX集合类可以的禁止对集合修改的操作:

<figcaption style="display: block; text-align: center; font-size: 1rem; line-height: 1.6; color: rgb(144, 144, 144); margin-top: 2px;"></figcaption>

public class ImmutableExample3 {

    private final static ImmutableList<Integer> list = ImmutableList.of(1, 2, 3);

    private final static ImmutableSet set = ImmutableSet.copyOf(list);

    private final static ImmutableMap<Integer, Integer> map = ImmutableMap.of(1, 2, 3, 4);

    private final static ImmutableMap<Integer, Integer> map2 = ImmutableMap.<Integer, Integer>builder()
            .put(1, 2).put(3, 4).put(5, 6).build();

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

使用线程安全的类

  • StringBuilder -> StringBuffer
  • SimpleDateFormat -> JodaTime
  • ArrayList -> Vector, Stack, CopyOnWriteArrayList
  • HashSet -> Collections.synchronizedSet(new HashSet()), CopyOnWriteArraySet
  • TreeSet -> Collections.synchronizedSortedSet(new TreeSet()), ConcurrentSkipListSet
  • HashMap -> HashTable, ConcurrentHashMap, Collections.synchronizedMap(new HashMap())
  • TreeMap -> ConcurrentSkipListMap, Collections.synchronizedSortedMap(new TreeMap())

最后

有需要java资料的同学,可以加群957734884了解一下

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,098评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,213评论 2 380
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 149,960评论 0 336
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,519评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,512评论 5 364
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,533评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,914评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,574评论 0 256
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,804评论 1 296
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,563评论 2 319
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,644评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,350评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,933评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,908评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,146评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,847评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,361评论 2 342

推荐阅读更多精彩内容