Netty源码—七、内存释放

摘要:
调用本机方法以应用内存初始化清理器publicstaticByteBufferallocateDirect(intcapacity){returnnewDirectByteBuffer(capacity;att=null;

Netty本身在内存分配上支持堆内存和直接内存,我们一般选用直接内存,这也是默认的配置。所以要理解Netty内存的释放我们得先看下直接内存的释放。

Java直接内存释放

我们先来看下直接内存是怎么使用的

ByteBuffer.allocateDirect(capacity)

申请的过程是其实就是创建一个DirectByteBuffer对象的过程,DirectByteBuffer对象只相当于一个holder,包含一个address,这个是直接内存的指针。

  • 调用native方法申请内存
  • 初始化cleaner
public static ByteBuffer allocateDirect(int capacity) {
    return new DirectByteBuffer(capacity);
}

DirectByteBuffer(int cap) {                   // package-private
    // 省略中间代码...
    // 创建一个cleaner,最后会调用Deallocator.run来释放内存
    cleaner = Cleaner.create(this, new Deallocator(base, size, cap));
    att = null;
}

Cleaner这个类继承自PhantomReference,也就是所谓的虚引用,这种类型引用的特点是:

  • 使用get方法不能获取到对象
  • 只要引用的对象除了PhantomReference之外没有其他引用了,JVM随时可以将PhantomReference引用的对象回收。

JVM在回前会将将要被回收的对象放在一个队列中,由于Cleaner继承自PhantomReference,队列的实现是使用cleaner的

private static final ReferenceQueue<Object> dummyQueue = new ReferenceQueue<>();

这个队列在PhantomReference的父类Reference中使用到了,Reference这个类在初始化的时候会启动一个线程来调用cleaner.clean方法,在Reference的静态代码块中启动线程

// java.lang.ref.Reference
static {
    ThreadGroup tg = Thread.currentThread().getThreadGroup();
    for (ThreadGroup tgn = tg;
         tgn != null;
         tg = tgn, tgn = tg.getParent());
    Thread handler = new ReferenceHandler(tg, "Reference Handler");
    /* If there were a special system-only priority greater than
         * MAX_PRIORITY, it would be used here
         */
    handler.setPriority(Thread.MAX_PRIORITY);
    handler.setDaemon(true);
    // 启动ReferenceHandler线程
    handler.start();
	// 省略中间代码...
}

该线程的主要作用就是调用tryHandlePending

// java.lang.ref.Reference#tryHandlePending
static boolean tryHandlePending(boolean waitForNotify) {
        Reference<Object> r;
        Cleaner c;
        try {
            synchronized (lock) {
                if (pending != null) {
                    r = pending;
                    // '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;
                    r.discovered = null;
                } else {
                    // The waiting on the lock may cause an OutOfMemoryError
                    // because it may try to allocate exception objects.
                    if (waitForNotify) {
                        lock.wait();
                    }
                    // 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) {
            // 调用clean方法
            c.clean();
            return true;
        }

        ReferenceQueue<? super Object> q = r.queue;
        if (q != ReferenceQueue.NULL) q.enqueue(r);
        return true;
}

System.gc不能回收堆外内存,但是会回收已经没有使用了DirectByteBuffer对象,该对象被回收的时候会将cleaner对象放入队列中,在Reference的线程中调用clean方法来回收堆外内存 。cleaner.run执行的是传入参数的thunk.run方法,这里thunk是Deallocator,所以最后执行的Deallocator.run方法

public void run() {
    if (address == 0) {
        // Paranoia
        return;
    }
    // 释放内存
    unsafe.freeMemory(address);
    address = 0;
    Bits.unreserveMemory(size, capacity);
}

所以最后通过unsafe.freeMemory释放了申请到的内存。

总结一下,在申请内存的时候调用的是java.nio.ByteBuffer#allocateDirect

会new DirectByteBuffer,通过Cleaner.create创建Cleaner,同时传入Deallocator作为Runnable参数,在Cleaner.clean的时候会调用该Deallocator.run来处理

Cleaner继承自PhantomReference,包含一个ReferenceQueue,在DirectByteBuffer不再使用的时候,该对象是处于Java堆的,除了该PhantomReference引用了DirectByteBuffer外,没有其他引用的时候,jvm会把cleaner对象放入ReferenceQueue队列中。

PhantomReference继承了Reference,Reference会启动一个线程(java.lang.ref.Reference.ReferenceHandler#run)去调用队列中的cleaner.clean方法。

Netty内存释放

Netty使用的直接内存的释放方式和JDK的释放方式略有不同。Netty开始释放内存的时候是调用free方法的时候

io.netty.buffer.PoolArena#free
io.netty.buffer.PoolArena.DirectArena#destroyChunk

最终释放内存的方法有两种

  1. 利用反射获取unsafe,调用Unsafe#freeMemory
  2. 利用反射获取DirectByteBuffer#cleaner,通过反射调用cleaner.clean方法

两种不同的方式依赖的条件不同,使用场景也不同

使用反射调用cleaner.clean

要满足以下条件之一的时候使用这种方式

  1. 没有可使用的直接内存
  2. 不能获取unsafe
  3. directBuffer没有传入long、int的构造方法

使用unsafe

不能使用上面这种方式的都使用unsafe

免责声明:文章转载自《Netty源码—七、内存释放》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇使用mysqldump导入不成功解决方法anyproxy-windows平台安装和抓手机app上https请求下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

程序员快速阅读,绝对不是神话

       你的时间很多吗?还是经常不够用?        程序员快速阅读,绝对不是神话,不仅是程序员而且是每一个人都能快速阅读。21世纪是信息爆炸的时代,在信息的大潮中,没有快速阅读引领你的脚步,你一定会被这个时代淹没。        下面跟随我的脚步进入快速阅读的天地: 快速阅读的科学原理: 1、传统的阅读是目光在每一个字间跳跃的点式阅读,大脑对信息...

解决studio 3T时间到期的两种方法

解决studio 3T时间到期的两种方法 此教程并非真正破解,而是通过重置studio 3t的试用时间解决的。 第一种方法 按住运win 和 r 键输入 regedit 找到以下路径HKEY_USERSS-1-5-21-xxxxxxxxxxxxxxSOFTWAREJavaSoftPrefs3tmongochefenterprise 将除了 inst...

Android常见问题1:窗体泄露(1)

  今天学习对话框AlertDialog,写一个Demo,需求是:只有一个Activitty,在这个Activity中只有一个按钮Button,当点击按钮Button时,弹出对话框,提示是否关闭该Activity,退出程序(只有一个界面). MainActivity源码: 1 package com.my.day22_my_dialog1; 2 3...

springboot+shrio简易登录登出和用户权限认证。

源码:https://github.com/huangshengz/myJavaDemo本例子参考:https://www.cnblogs.com/HowieYuan/p/9259638.html本例子验证主要有两个类,一个是自定义的拦截类ShiroConfig,在这里我们自定义了很多需要的操作。例如:角色权限路径,登录路径等,一些具体的含义如下: * a...

ThinkPHP6 核心分析:系统服务

什么是系统服务?系统服务是对于程序要用到的类在使用前先进行类的标识的绑定,以便容器能够对其进行解析(通过服务类的 register 方法),还有就是初始化一些参数、注册路由等(不限于这些操作,主要是看一个类在使用之前的需要,进行一些配置,使用的是服务类的 boot 方法)。以下面要介绍到的 ModelService 为例,ModelService类提供服务...

NSURLSession的基本使用

一、简单说明   在iOS9.0之后,以前使用的NSURLConnection过期,苹果推荐使用NSURLSession来替换NSURLConnection完成网路请求相关操作。   NSURLSession的使用非常简单,先根据会话对象创建一个请求Task,然后执行该Task即可。   NSURLSessionTask本身是一个抽象类,在使用的时候,通常...