3

Java线程封闭

 3 years ago
source link: https://segmentfault.com/a/1190000038834821
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
neoserver,ios ssh client

把对象封装到一个线程里,只有一个线程可以看到该对象,那么就算这个对象不是线程安全的,也不会出现任何线程问题,因为它只能在一个线程中被访问。

  • Ad-hoc线程封闭:程序控制实现,非常脆弱,最糟糕,忽略。
  • 堆栈封闭:简单的说就是局部变量,无并发问题。多线程访问同一个方法时,方法中的局部变量会被拷贝一份到线程栈中。方法的局部变量不是被多线程共享的,不会出现线程安全问题,能用局部变量就不要用全局变量,全局变量容易发生并发问题,注意全局变量不是全局常量。
  • ThreadLocal线程封闭:Java中提供一个ThreadLocal类来实现线程封闭,这个类使线程中的某个值与保存值的对象关联起来

ThreadLocal

ThreadLocal类提供的方法

image-20210105141906919

核心的五个操作:创建,创建并赋初始值,赋值,取值,删除

private final static ThreadLocal<Object> threadLocal = new ThreadLocal<Object>;
  • 创建并赋初始值
private final static ThreadLocal<String> threadLocal=new ThreadLocal<String>(){
        @Override
        protected String initialValue() {
            return "入门小站";
        }
};
threadLocal.set("入门小站");
threadLocal.get();
threadLocal.remove();

首先ThreadLocal是一个泛型类,保证可以接受任何类型的对象。

一个线程内可以存在多个ThreadLocal,ThreadLocal内部维护了一个Map,这个Map不是HashMap,而是ThreadLocal实现的一个ThreadLocalMap的静态内部类。我们使用的get(),set()方法其实是调用了这个ThreadLocalMap类对应的get(),set()

public T get() {
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null) {
            ThreadLocalMap.Entry e = map.getEntry(this);
            if (e != null) {
                @SuppressWarnings("unchecked")
                T result = (T)e.value;
                return result;
            }
        }
        return setInitialValue();
    }
    

public void set(T value) {
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null)
            map.set(this, value);
        else
            createMap(t, value);
}

调用ThreadLocal的set方法时,先获取当前的线程Thread t = Thread.currentThread();,然后获取当前线程维护的ThreadLocalMap。如果ThreadLocalMap不存在则初始化。

ThreadLocalMapmap.set(this, value);第一个参数是this,this指的是当前的ThreadLocal,就是上面代码里面的threadLocal变量。

最终的变量是放在当前线程的ThreadLocalMap中,并不是存在ThreadLocal上,ThreadLocal可以理解成传递关系的。

内存泄漏问题

image-20210105172630930

ThreadLocalMap中使用的keyThreadLocal的弱引用,弱引用的特点是,如果这个对象只存在弱引用,那么在下一次垃圾回收的时候必然会被清理掉。

所以ThreadLocal没有被强引用的情况下,在垃圾回收的时候会被清理掉,但是value却是强引用,不会被清理,这样的话就出出现keynullvalue

ThreadLocalMap实现中已经考虑了这个情况,在调用set,get,remove方法的时候会清理掉keynull的记录。如果出现了内存泄漏,那就是说在keynull后,没有手动调用remove方法,并且之后也不再调用set,get,remove方法。

内存泄漏解决方案

将ThreadLocal变量定义成private static的,这样的话ThreadLocal的生命周期就更长,由于一直存在ThreadLocal的强引用,所以ThreadLocal也就不会被回收,也就能保证任何时候都能根据ThreadLocal的弱引用访问到Entry的value值,然后remove它,防止内存泄露。

如何保证两个同时实例化的ThreadLocal对象有不同的threadLocalHashCode属性

在ThreadLocal类中,还包含了一个static修饰的AtomicInteger([əˈtɒmɪk]提供原子操作的Integer类)成员变量(即类变量)和一个static final 修饰的常量(作为两个相邻nextHashCode的差值)。由于nextHashCode是类变量,所以每一次调用ThreadLocal类都可以保证nextHashCode被更新到新的值,并且下一次调用ThreadLocal类这个被更新的值仍然可用,同时AtomicInteger保证了nextHashCode自增的原子性。

ThreadLocal应用

Web项目公共参数从controller层传递到service层,再从service层传递到mapper层,或者从service层传递到其他的工具类当中。为了避免参数复杂的传递,在controller中将已经封装好的参数放入ThreadLocal中,在其他层调用时直接通过ThreadLocal对象获取。在方法结束时,定义拦截器(HandlerInterceptorAdapter)(或者Filter)进行ThreadLocal的remove方法。

在需要登录的系统中用户信息常常存在Sessiontoken。比如我们要从Session中获取用户信息需要在接口参数中加上HttpServletRequest对象,然后调用 getSession方法,且每一个需要用户信息的接口都要加上这个参数,才能获取Session,比较麻烦。

这个时候我们就可以用ThreadLocal,在拦截器(HandlerInterceptorAdapter)(或者Filter)中解析获取用户信息,然后保存到ThreadLocal,业务逻辑直接在ThreadLocal中获取就可以了。

【关注微信公众号:【入门小站】解锁更多知识点】
image


About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK