ThreadLocal源码分析,java的引用类型

ThreadLocal 使用实例

使用ThreadLocal创建的对象只能被当前线程访问,每个线程保存一个对象的副本,在多线程操作时是线程安全的。然后通过重写initialValue()方法,可以给初始值。每次调用get方法,先检查当前线程是否有这个THreadLocal对象,如果没有调用initialValue方法,或者返回null
上代码:

public class ThreadLocalTest {
    public static void main(String[] args) throws InterruptedException {
        final ThreadLocalTest test = new ThreadLocalTest();

        test.set();
        System.out.println(test.getLong());
        System.out.println(test.getString());
        // 在这里新建了一个线程
        Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                test.set(); //
                System.out.println("Thread1==yield");
                try{
                    Thread.currentThread().yield();
                }catch (Exception e){}
                System.out.println(Thread.currentThread().getName()+"==="+test.getLong());
                System.out.println(Thread.currentThread().getName()+"==="+test.getString());
            }
        },"Thread1") ;
        thread1.start();

        System.out.println(test.getLong());
        System.out.println(test.getString());
    }

    ThreadLocal<Long> longLocal = new ThreadLocal<Long>();
    ThreadLocal<String> stringLocal = new ThreadLocal<String>(){
        @Override
        protected String initialValue() {
            return "";
        }
    };

    public void set() {
        longLocal.set(Thread.currentThread().getId());
        stringLocal.set(Thread.currentThread().getName());
    }

    public long getLong() {
        return longLocal.get();
    }

    public String getString() {
        return stringLocal.get();
    }

}

输出:

1
main
1
main
Thread1==yield
Thread1===11
Thread1===Thread1

我们可以发现每个ThreadLocal变量,被放在线程的一个map中,然后get的时候,key就是ThreadLocal变量本身。也就是应该是这么个map<ThreadLocal,Object>

InheritableThreadLocal 使用实例

首先InheritableThreadLocal,继承自ThreadLocal. 但是这个是父线程创建的THreadLocal可以在子线程中使用,也可以在线程本身中使用。
上代码:

public class InheritableThreadLocalTest {
  public static InheritableThreadLocal<String> inheritableThreadLocal =
          new InheritableThreadLocal<String>();
  public static ExecutorService executorService = Executors.newFixedThreadPool(1);

  public static void main(String[] args) {
      inheritableThreadLocal.set("xxxxx");
      executorService.submit(new Runnable() {
          @Override
          public void run() {
              System.out.println(Thread.currentThread().getName()+"==get  "+
                      inheritableThreadLocal.get()+" from main Thread" );
          }
      });
      try{
          Thread.sleep(1000);
      }catch (Exception e){}
      inheritableThreadLocal.set("xxx2");
      executorService.submit(new Runnable() {
          @Override
          public void run() {
              System.out.println(Thread.currentThread().getName()+"==get  "+
                      inheritableThreadLocal.get()+" from main Thread" );
          }
      });

      System.out.println(Thread.currentThread().getName()+"get==="+inheritableThreadLocal.get());
      try{
          Thread.sleep(2000);
      }catch (Exception e){}
      executorService.shutdown();
  }
}

结果输出:

pool-1-thread-1==get  xxxxx from main Thread
pool-1-thread-1==get  xxxxx from main Thread
mainget===xxx2

我们可以发现,线程池中第二次提交的任务,还是获取的xxxxx ,并没有获取到xxx2 ,因为线程池中只有一个线程,并没有销毁掉,所以也就不会去初始化 thread1 get的时候,get的是自己的threadLocals变量

ThreadLocal源码分析
先看类的结构,类内部,有一个静态内部类,ThreadLocalMap,就是Thread类的threadLocals 引用的这个map对象.

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);
    }
static class ThreadLocalMap {
static class Entry extends WeakReference<ThreadLocal<?>> {
            /** The value associated with this ThreadLocal. */
            Object value;

            Entry(ThreadLocal<?> k, Object v) {
                super(k);
                value = v;
            }
        }
private Entry[] table;
private int threshold; // Default to 0

  private Entry getEntry(ThreadLocal<?> key) {
            int i = key.threadLocalHashCode & (table.length - 1);
            Entry e = table[i];
            if (e != null && e.get() == key)
                return e;
            else
                return getEntryAfterMiss(key, i, e);
        }

private Entry getEntryAfterMiss(ThreadLocal<?> key, int i, Entry e) {
            Entry[] tab = table;
            int len = tab.length;

            while (e != null) {
                ThreadLocal<?> k = e.get();
                if (k == key)
                    return e;
                if (k == null)
                    expungeStaleEntry(i);
                else
                    i = nextIndex(i, len);
                e = tab[i];
            }
            return null;
        }
}

ThreadLocal核心主要是上述代码。首先set方法,先拿到当前线程的ThreadLocalMap,然后如果map!=null,就set进去。复杂的是get方法,在getEntry()时,如果没有命中的话,会触发expungeStaleEntry方法,回收key为null的Entry对象.由于Entry对象和ThreadLocal对象extends 软引用,当对象只有Softrefrence的时候,在内存不足的时候,会回收内存。

4种引用

Refrence 的子类
4种引用
我们都知道在Java中有4种引用,这四种引用从高到低分别为:

  1. StrongReference

这个引用在Java中没有相应的类与之对应,但是强引用比较普遍,例如:Object obj = new Object();这里的obj就是要给强引用,如果一个对象具有强引用,则垃圾回收器始终不会回收此对象。当内存不足时,JVM情愿抛出OOM异常使程序异常终止也不会靠回收强引用的对象来解决内存不足的问题。

  1. SoftReference

如果一个对象只有软引用,则在内存充足的情况下是不会回收此对象的,但是,在内部不足即将要抛出OOM异常时就会回收此对象来解决内存不足的问题。

  1. WeakReference
    WeakReference 基本与SoftReference 类似,只是回收的策略不同。
    只要 GC 发现一个对象只有弱引用,则就会回收此弱引用对象。但是由于GC所在的线程优先级比较低,不会立即发现所有弱引用对象并进行回收。只要GC对它所管辖的内存区域进行扫描时发现了弱引用对象就进行回收。
  2. PhantomReference

Reference

主要是负责内存的一个状态,当然它还和java虚拟机,垃圾回收器打交道。Reference类首先把内存分为4种状态Active,Pending,Enqueued,Inactive。

  • Active,一般来说内存一开始被分配的状态都是 Active,
  • Pending 大概是指快要被放进队列的对象,也就是马上要回收的对象,
  • Enqueued 就是对象的内存已经被回收了,我们已经把这个对象放入到一个队列中,方便以后我们查询某个对象是否被回收,
  • Inactive就是最终的状态,不能再变为其它状态。
    ReferenceQueue
    引用队列,在检测到适当的可到达性更改后,垃圾回收器将已注册的引用对象添加到队列中,ReferenceQueue实现了入队(enqueue)和出队(poll),还有remove操作,内部元素head就是泛型的Reference。
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,287评论 6 498
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,346评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 162,277评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,132评论 1 292
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,147评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,106评论 1 295
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,019评论 3 417
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,862评论 0 274
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,301评论 1 310
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,521评论 2 332
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,682评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,405评论 5 343
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,996评论 3 325
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,651评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,803评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,674评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,563评论 2 352

推荐阅读更多精彩内容

  • Java SE 基础: 封装、继承、多态 封装: 概念:就是把对象的属性和操作(或服务)结合为一个独立的整体,并尽...
    Jayden_Cao阅读 2,108评论 0 8
  • 从三月份找实习到现在,面了一些公司,挂了不少,但最终还是拿到小米、百度、阿里、京东、新浪、CVTE、乐视家的研发岗...
    时芥蓝阅读 42,236评论 11 349
  • 转自 www.jianshu.com/p/bd1bfc0c34b8 作为一个程序员,在找工作的过程中,都会遇到笔试...
    灬黑客灬阅读 4,419评论 1 118
  • 一、简介 并发编程中,当访问共享数据时,通常需要使用同步技术。但如果数据不发布(逸出)到线程以外,仅仅在单线程中被...
    邱simple阅读 3,440评论 3 12
  • 雨中诵读情 青椒百人团北京之行,我们有太多的感动和故事:有何永超老师的大爱,天天坚持推着轮椅上的吴桂芳老师;有赵琳...
    陕州嘻嘻阅读 429评论 4 6