四、ThreadLocal

2018-08-21  本文已影响0人  小绵羊你毛不多

ThreadLocal

定义

适用场景

适用于每个线程需要自己独立的实例,且该实例需要在多个方法中被使用,也就是变量在线程间隔离而在方法或类间共享的场景

//在每个线程内都构建session实例
public class TheadLocalTest {

    class SessionLocal{
        String status;
    }

   public SessionLocal createSession(){
        return new SessionLocal();
    }
//需要显式传递SessionLocal实例
   public String get(SessionLocal sessionLocal){
        return  sessionLocal.status;
    }
    //需要显式传递SessionLocal实例
    void setStatus(SessionLocal sessionLocal,String status){
        sessionLocal.status=status;
    }

    public static void main(String[] args) {
        new Thread(() -> {
            TheadLocalTest theadLocalTest = new TheadLocalTest();
            SessionLocal session = theadLocalTest.createSession();
            theadLocalTest.get(session);
            System.out.println(session.status);
            theadLocalTest.setStatus(session, "close");
            theadLocalTest.get(session);
            System.out.println(session.status);
        }).start();
    }
}

也可以实现需求,但是需要显式传递session对象,方法间耦合度较高

使用ThreadLocal实现

public class TheadLocalTest {
//创建一个ThreadLocal对象
    public static ThreadLocal<SessionLocal> session = new ThreadLocal<SessionLocal>();

    class SessionLocal {
        String status;
    }
//创建一个SessionLocal
    public void createSession() {
         session.set(new SessionLocal());
    }
//直接通过ThreadLocal获取,不用显式传递SessionLocal实例
    public String get() {
        SessionLocal sessionLocal = session.get();
        return sessionLocal.status;
    }
//直接通过ThreadLocal设置,不用显式传递SessionLocal实例
    void setStatus(String status) {
        session.get().status = status;
    }

    public static void main(String[] args) {
        new Thread(() -> {
            TheadLocalTest theadLocalTest = new TheadLocalTest();
            theadLocalTest.createSession();
            theadLocalTest.get();
            System.out.println(theadLocalTest.get());
            theadLocalTest.setStatus("close");
            theadLocalTest.get();
            System.out.println(theadLocalTest.get());
        }).start();
    }
}

实现原理

public class ThreadLocal<T> {
     ……
     //由静态内部类ThreadLocalMap提供Map
      static class ThreadLocalMap {
      //每个Entry都是一个对键的弱引用
          static class Entry  
                       extends WeakReference<ThreadLocal<?>> {
            Object value;
            //每个Entry都包含了一个对值的强引用
            Entry(ThreadLocal<?> k, Object v) {
                super(k);
                value = v;
            }
        }
      }
}

1. 使用弱引用的原因:当没有强引用指向ThreadLocal变量时,它可以被回收。从而导致ThreadLocal不能被回收而造成内存泄露。
2. 另外一种内存泄露:ThreadLocalMap维护ThreadLocal变量和具体映射,当ThreadLocal被回收,映射的键就变为null。ThreadLocalMap中的Entry无法被移除。从而使得实例被该Entry引用而无法被回收。
原理图

从上面代码也可以看出
Thread、ThreadLocal、ThreadLocalMap、Entry之间的关系:

image

内存泄露

image
  1. 实线代表强引用,虚线代表弱引用
  2. 虚线表示ThreadLocalMap是使用ThreadLocal的弱引用作为key的。弱引用的对想在GC时会被回收
  3. 如果一个ThreadLocal没有外部强引用(图中的ref)来引用它,系统GC的时候,ThreadLocal就会被回收,就会出现很多key为null的Entry,如果线程不结束,value就会一直被引用,从而Entry就不能被回收,造成内存泄漏
是弱引用导致的内存泄露吗?
优化

也可以参考这篇文章

上一篇 下一篇

猜你喜欢

热点阅读