简介

如果咱们在多线程中引入了共享变量,那么咱们就须要考虑一下多线程下线程平安的问题了。那么咱们在编写代码的过程中,须要留神哪些线程平安的问题呢?

一起来看看吧。

留神线程平安办法的重写

大家都做过办法重写,咱们晓得办法重写是不会查看办法修饰符的,也就是说,咱们能够将一个synchronized的办法重写成为非线程平安的办法:

public class SafeA {    public synchronized void doSomething(){    }}
public class UnsafeB extends SafeA{    @Override    public void doSomething(){    }}

咱们在实现子类性能的时候,肯定要放弃办法的线程安全性。

构造函数中this的溢出

this是什么呢?依据JLS的标准,当用作次要表达式时,关键字this示意一个值,该值是对其调用实例办法的对象或正在结构的对象的援用。

那么问题来了,因为this可能示意正在结构的对象,那么意味着,如果对象还没有构建结束,而this又能够被内部拜访的话,就会造成内部对象拜访到还未结构胜利对象的问题。

咱们来具体看一下this溢出都会产生在哪些状况:

public class ChildUnsafe1 {    public static ChildUnsafe1 childUnsafe1;    int age;    ChildUnsafe1(int age){        childUnsafe1 = this;        this.age = age;    }}

下面是一个非常简单的this溢出的状况,在构造函数的过程中,将this赋值给了一个public对象,将会导致this还没有被初始化结束就被其余对象拜访。

那么咱们调整一下程序是不是就能够了呢?

public class ChildUnsafe2 {    public static ChildUnsafe2 childUnsafe2;    int age;    ChildUnsafe2(int age){        this.age = age;        childUnsafe2 = this;    }}

下面咱们看到,this的赋值被放到了构造方法的最初面,是不是就能够防止拜访到未初始化结束的对象呢?

答案是否定的,因为java会对代码进行重排序,所以childUnsafe2 = this的地位是不定的。

咱们须要这样批改:

public class Childsafe2 {    public volatile static Childsafe2 childUnsafe2;    int age;    Childsafe2(int age){        this.age = age;        childUnsafe2 = this;    }}

加一个volatile描述符,禁止重排序,完满解决。

咱们再来看一个父子类的问题,还是下面的Childsafe2,咱们再为它写一个子类:

public class ChildUnsafe3 extends Childsafe2{    private Object obj;    ChildUnsafe3(int age){       super(10);       obj= new Object();    }    public void doSomething(){        System.out.println(obj.toString());    }}

下面的例子有什么问题呢?因为父类在调用构造函数的时候,曾经裸露了this变量,所以可能会导致ChildUnsafe3中的obj还没有被初始化的时候,内部程序就调用了doSomething(),这个时候obj还没有被初始化,所以会抛出NullPointerException。

解决办法就是不要在构造函数中设置this,咱们能够新创建一个办法,在结构函数调用结束之后,再进行设置。

不要在类初始化的时候应用后盾线程

如果在类初始化的过程中,应用后盾过程,有可能会造成死锁,咱们思考上面的状况:

public final class ChildFactory {    private static int age;    static {        Thread ageInitializerThread = new Thread(()->{            System.out.println("in thread running");            age=10;        });        ageInitializerThread.start();        try {            ageInitializerThread.join();        } catch (InterruptedException ie) {            throw new AssertionError(ie);        }    }    public static int getAge() {        if (age == 0) {            throw new IllegalStateException("Error initializing age");        }        return age;    }    public static void main(String[] args) {        int age = getAge();    }}

下面的类应用了一个static的block,在这个block中,咱们启动一个后盾过程来设置age这个字段。

为了保障可见性,static变量必须在其余线程运行之前初始化结束,所以ageInitializerThread须要期待main线程的static变量执行结束之后能力运行,然而咱们又调用了ageInitializerThread.join()办法,主线程又须要反过来期待ageInitializerThread的执行结束。

最终导致了循环期待,造成了死锁。

最简略的解决办法就是不应用后盾过程,间接在static block中设置:

public final class ChildFactory2 {    private static int age;    static {            System.out.println("in thread running");            age=10;    }    public static int getAge() {        if (age == 0) {            throw new IllegalStateException("Error initializing age");        }        return age;    }    public static void main(String[] args) {        int age = getAge();    }}

还有一种方法就是应用ThreadLocal将初始化变量保留在线程本地。

public final class ChildFactory3 {    private static final ThreadLocal<Integer> ageHolder = ThreadLocal.withInitial(() -> 10);    public static int getAge() {        int localAge = ageHolder.get();        if (localAge == 0) {            throw new IllegalStateException("Error initializing age");        }        return localAge;    }    public static void main(String[] args) {        int age = getAge();    }}

本文的代码:

learn-java-base-9-to-20/tree/master/security

本文已收录于 http://www.flydean.com/java-security-code-line-threadsafe/

最艰深的解读,最粗浅的干货,最简洁的教程,泛滥你不晓得的小技巧等你来发现!

欢送关注我的公众号:「程序那些事」,懂技术,更懂你!