RefenceQueue的源码解析,以及WeakHashMap的源码分析

Java RefenceQueue WeakHashMap


首先介绍Java中的四种引用:

  1. 强引用:如Object c = new Object() 这种引用。如果一个对象有强应用,那么这个对象就不会被释放!即使内存不够时候,JVM会给出OutOfMemory异常。
  2. 软引用:SoftReference,软引用的对象,会在JVM内存不够的情况下被JVM回收。
  3. 弱引用:WeakReference,弱引用,在下一次GC的时候,会被GC清理。
  4. 虚引用:PhantomReference,形同虚设的引用,设置这个引用的对象,没法通过虚引用获得,这个引用设置一般也就是为了GC时候的一个提醒。

上面的SoftReference和WeakReference和PhantomReference,都是Reference的子类,我们来看看这个类的源码:

Reference的四种状态:

  1. Active:新建的Reference对象是处于这个状态的,(queue可能有,next为null)。
  2. Pending:等待被ReferenceHandler放入ReferenceQueue,如果Reference的Queue不存在,那么就不会处于这个状态,会被直接回收。(queue不为空,next=this)
  3. Enqueued:已经被加入ReferenceQueue的Reference对象,如果没有提供Queue,那么永远不会处于这个状态。如果从Queue中移出,就处于InActive状态。(queue = ReferenceQueue.Enqueued,next=ReferenceQueque的下一个元素。如果只有Queue中只有一个,那么就是this)
  4. InActive:这是最终的状态,一旦处于这个状态,就再也不会更改了。(queue = NULL,next = this)

private T referent : 属性,这个属性的是泛型T,代表,引用的具体指向对象。
volatile ReferenceQueue<? super T> queue:Reference的Queue对象。
Reference next : 这个属性和Queue一起组成了四种状态的标志。
Reference<T> discovered:这个字段是虚拟机使用的,用来标识,下一个GC的Reference对象。
Reference<Object> pending : 这个字段代表,等待被处理的Reference的对象,这个对象一般被ReferenceHandler线程所消费!

内部类 ReferenceHandler :

private static class ReferenceHandler extends Thread

public void run() {
            while (true) {
                tryHandlePending(true);
            }
}

继承自Thread,提供了一个很特别的run方法,死循环运行tryHandlePending方法。

 static boolean tryHandlePending(boolean waitForNotify) {
        Reference<Object> r;
        Cleaner c;
        try {
            synchronized (lock) { //加锁,确保读取到的是最新的pending对象
                if (pending != null) {
                    r = pending;  //r表示正在处理的Reference对象!
                    // 'instanceof' might throw OutOfMemoryError sometimes
                    // so do this before un-linking 'r' from the 'pending' chain...
                    c = r instanceof Cleaner ? (Cleaner) r : null;
                    // unlink 'r' from 'pending' chain
                    pending = r.discovered; // 将下一个GC的对象放入pending
                    r.discovered = null;    / 将discovered去除。
                } else {
                    // The waiting on the lock may cause an OutOfMemoryError
                    // because it may try to allocate exception objects.
                    if (waitForNotify) {
                        lock.wait();        //如果没有等待处理的Reference对象,就进入等待,这个由JVM唤醒的
                    }
                    // retry if waited
                    return waitForNotify;
                }
            }
        } catch (OutOfMemoryError x) {
            // Give other threads CPU time so they hopefully drop some live references
            // and GC reclaims some space.
            // Also prevent CPU intensive spinning in case 'r instanceof Cleaner' above
            // persistently throws OOME for some time...
            Thread.yield();
            // retry
            return true;
        } catch (InterruptedException x) {
            // retry
            return true;
        }

        // Fast path for cleaners
        if (c != null) {
            c.clean();
            return true;
        }

        ReferenceQueue<? super Object> q = r.queue;     //取出Reference的Queue
        if (q != ReferenceQueue.NULL) q.enqueue(r);         //如果Queue不为NULL,就做入队的操作。
        return true;
    }

需要注意的是:ReferenceHandler这个线程是在Reference类被加载的时候,启动的!优先级最高,后台线程!

至此Reference的我们就分析完毕了!我们明白了,Reference是通过Reference的Handler,不断的将GC标记的Reference放入Queue中的!

我们再来看下ReferenceQueue的源码:

ReferenceQueue<Object> NULL:给没有设置Queue的Reference对象设置一个默认的Queue。但是无法做入队的操作。
ReferenceQueue<Object> ENQUEUED:对已经放入Queue的Reference对象,将其的Queue设置为ENQUEUED。
Reference<? extends T> head:队列的头。其实ReferenceQueue是个链表。

从上面的ReferenceHandler中我们看到,线程会不断的执行Queue的enqueue对象:下面解析这个方法的源码:

boolean enqueue(Reference<? extends T> r) { /* Called only by Reference class */
        synchronized (lock) {
            // Check that since getting the lock this reference hasn't already been
            // enqueued (and even then removed)
            ReferenceQueue<?> queue = r.queue;  
            if ((queue == NULL) || (queue == ENQUEUED)) {  //如果queue是NULL或者ENQUEUED就不做处理。
                return false;
            }
            assert queue == this;
            r.queue = ENQUEUED;     //将原来的Reference对象的Queue设置为ENQUEUED
            r.next = (head == null) ? r : head; //将当前处理的Reference设置为队列的头部
            head = r;
            queueLength++;
            if (r instanceof FinalReference) {
                sun.misc.VM.addFinalRefCount(1);
            }
            lock.notifyAll();   //唤醒阻塞的方法,如remove方法。
            return true;
        }
    }

Queue中,还有一些方法,我们一个个解析:
poll方法,最终调用的是 reallyPoll 方法:检测队列是否为空,不为空就处理头部元素,返回头部元素,或者null。

remove方法,最终调用remove(timeout)方法!如果timeout为0,表示如果没有元素会一直等待!如果大于0,如果队列为空就等待一段时间。

Reference和ReferenceQueue的源码,讲解结束!总结下就是,ReferenceQueue的作用就是在Reference的内部元素被GC回收的时候,会把Reference加入到Queue中,然后我们通过监听Queue的元素,可以得到元素被回收的事件,针对这个事件,我们可以做其他事情。

WeakHashMap中,比较常用的使用了Reference的知识,下面我们来看看它的源码:

WeakHashMap的源码分析:

首先我们要知道WeakHashMap和普通的Map的不同:

  1. WeakHashMap的元素是会变化的。

  2. WeakHashMap的Entry的Key是WeakReference,所以在Key,可以被回收的时候,可以得到相应的通知!

  3. WeakHashMap 在 put,get和Size操作的时候都会执行expungeStaleEntries(去除多余的Entry)的方法,将无用的Key的对应的Entry移除掉!

  4. 在我们使用WeakHashMap的时候需要注意的是,尽量的防止,Key和Value使用同一个对象!如String是一个不变的对象,如果设置了一个“GOOD”的Key,也设置了一个“GOOD”的Value,String的对象是会被缓存的,所以其实Key和Value此时都是一个对象!但是Value是强引用,所以这个Key也永远无法被标记清除,就失去了WeakHashMap的意义了。在使用String作为WeakHashMap的Key的时候一定要小心,最好使用new String()包装一层,否则String会使用的是String缓冲池的数据,导致WeakHashMap的泄露!如果某些情况,Key必须和Value 相同,那么可以有两种方法解决!:第一种,从Key中深Copy元素,产生Value,此时Key和Value,是不同的元素!第二种,对Value也使用一个WeakReference!

WeakHashMap的大体思路是,Key是一个WeakHashMap,当Key可以回收的时候,我们就通过Key找到相应的Entry,然后移除Value。当每次Put,GET,Size相关操作的时候,就会去检查是否有相应的Key可以回收。

我们直接来看WeakHashMap里最重要的检测回收的方法:

private void expungeStaleEntries() {
        for (Object x; (x = queue.poll()) != null; ) {  //通过poll方法,不断轮询Queue的元素
            synchronized (queue) {
                @SuppressWarnings("unchecked")
                    Entry<K,V> e = (Entry<K,V>) x;
                int i = indexFor(e.hash, table.length);     //通过hash找到index
                // WeakHashMap和HashMap是一样的,都有BuUket的概念,Buket之下是链表的概念dou'yo
                Entry<K,V> prev = table[i];     
                Entry<K,V> p = prev;
                while (p != null) {
                    Entry<K,V> next = p.next;
                    if (p == e) {
                        if (prev == e)
                            table[i] = next;    
                            // p == e && pre == e 那么久表示是第一个元素
                        else
                            prev.next = next;   //不是第一个元素
                        // Must not null out e.next;
                        // stale entries may be in use by a HashIterator
                        //上面的作用就是删除链表中的e这个元素。
                        
                        e.value = null; // Help GC //将e的Value设置为null
                        size--; 
                        break;
                    }
                    prev = p;
                    p = next;
                }
            }
        }
    }
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,294评论 6 493
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,493评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,790评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,595评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,718评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,906评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,053评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,797评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,250评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,570评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,711评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,388评论 4 332
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,018评论 3 316
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,796评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,023评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,461评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,595评论 2 350

推荐阅读更多精彩内容