同一线程

在同一线程中，对象回收至Recycler$Stack中

实验代码

package test.recycler;import io.netty.util.Recycler;
import io.netty.util.concurrent.FastThreadLocalThread;import java.rmi.server.ExportException;
import java.util.ArrayList;
import java.util.List;/*** unreachable Recycler$DefaultHandle*/
public class RecycleNoRelease1 {private static final Recycler<User> RECYCLER = new Recycler<User>() {//没有对象的时候，新建一个对象， 会传入一个handler，在Recycler池里，所有的对象都会转成DefaultHandle对象@Overrideprotected User newObject(Handle<User> handle) {return new User(handle);}};private static ThreadLocal<Long> numLong = new ThreadLocal<Long>();private static class User {private final Recycler.Handle<User> handle;public long a1 = 1;//1kbpublic long a2 = 2;public long a3 = 1;//1kbpublic long a4 = 2;public long a5 = 1;//1kbpublic long a6 = 2;public long a7 = 1;//1kbpublic long a8 = 2;public User(Recycler.Handle<User> handle) {this.handle = handle;}public void recycle() {//通过handler进行对象的回收handle.recycle(this);}}public static void main(String[] args) throws InterruptedException {//        try {//            //此处添加延时是为了让我来得及打开JVisualVM去查看动态变化并使用jmap生成dump文件
//            Thread.sleep(20000);
//        } catch (Exception e) {//            e.printStackTrace();
//        }System.out.println("begin");FastThreadLocalThread thread = new FastThreadLocalThread(new Runnable() {public void run() {long nnn = 1024 * 32;List<User> list1 = new ArrayList<User>();for (int i = 0; i < nnn; ++i) {list1.add(RECYCLER.get());}for (int i = 0; i < nnn; ++i) {list1.get(i).recycle();}}});thread.start();thread.join();System.out.println("=======================over===================================");while (true) {try {Thread.sleep(1000);} catch (Exception e) {e.printStackTrace();}}}
}

通过debug发现，回收对象时会将对象存储至stack中

上面两张图说明线程的ThreadLocal里存储了592这个对象，而本次会回收的对象就是592

并不是每一次调用回收方法的时候对象都能回收到stack中，回收的过程中有一个判断
boolean dropHandle(DefaultHandle<?> handle) {if (!handle.hasBeenRecycled) {if (handleRecycleCount < interval) {handleRecycleCount++;// Drop the object.return true;}handleRecycleCount = 0;handle.hasBeenRecycled = true;}return false;}
如果上面的结果为true，对象必然不会进入stack中。如果为false，上层函数还会进行其他判断。
interval是间隔的意思。当运行RecycleInterval(github中的代码)时可以看到对象周期性的入stack

当线程结束时，592这种对象就会变成unreachable

线上曾经遇到DefaultHandle直接为unreachable，推测可能是jvm将DefaultHandle上一层对象（此例中为RecycleNoRelease1$User）回收了。但是jvm会只回收上一层对象而不回收DefaultHandle吗？这部分还需要做实验。

不同线程

实验代码

package test.recycler;import io.netty.util.Recycler;
import io.netty.util.concurrent.FastThreadLocalThread;import java.util.ArrayList;
import java.util.List;/*** thread用于创建对象，thread2用于回收对象。用于引发WeakOrderQueue$Link的unreachable*/
public class RecycleMultiThread {private static final Recycler<User> RECYCLER = new Recycler<User>() {//没有对象的时候，新建一个对象， 会传入一个handler，在Recycler池里，所有的对象都会转成DefaultHandle对象@Overrideprotected User newObject(Handle<User> handle) {return new User(handle);}};private static Object lock = new Object();private static class User {private final Recycler.Handle<User> handle;public long a1 = 1;//1kbpublic long a2 = 2;public long a3 = 1;//1kbpublic long a4 = 2;public long a5 = 1;//1kbpublic long a6 = 2;public long a7 = 1;//1kbpublic long a8 = 2;public User(Recycler.Handle<User> handle) {this.handle = handle;}public void recycle() {//通过handler进行对象的回收handle.recycle(this);}}public static void main(String[] args) throws InterruptedException {try {//此处添加延时是为了让我来得及打开JVisualVM去查看动态变化并使用jmap生成dump文件Thread.sleep(20000);} catch (Exception e) {e.printStackTrace();}System.out.println("begin");final List<User> list1 = new ArrayList<User>();FastThreadLocalThread thread = new FastThreadLocalThread(new Runnable() {public void run() {long nnn = 1024 * 32;for (int i = 0; i < nnn; ++i) {list1.add(RECYCLER.get());}try {System.out.println("thread lock begin");synchronized (RecycleMultiThread.class) {RecycleMultiThread.class.notify();//对象创建完毕RecycleMultiThread.class.wait();}System.out.println("thread lock over");} catch (Exception e) {e.printStackTrace();}}});FastThreadLocalThread thread2 = new FastThreadLocalThread(new Runnable() {public void run() {long nnn = 1024 * 32;synchronized (RecycleMultiThread.class) {try {RecycleMultiThread.class.wait();//等待对象创建完毕} catch (InterruptedException e) {e.printStackTrace();}}for (int i = 0; i < 1024 * 32; ++i) {list1.get(i).recycle();}try {System.out.println("thread2 notify");synchronized (RecycleMultiThread.class) {RecycleMultiThread.class.notify();}System.out.println("thread2 notify over");} catch (Exception e) {e.printStackTrace();}}});thread.start();thread2.start();thread.join();thread2.join();System.out.println("=======================over===================================");while (true) {try {Thread.sleep(1000);} catch (Exception e) {e.printStackTrace();}}}
}

回收至WeakOrderQueue中

查找上图中@0xffd8aa30的最短路径

为unreachable

此现象与线上系统的dump文件相似（线上dump文件直接就是WeakOrderQueue L i n k u n r e a c h a b l e ），据此推测线上老年代出现大量不可达对象的原因就在于线程退出时其 T h r e a d L o c a l 依旧在老年代占有大量空间，并且由于线程已经退出，所以 W e a k O r d e r Q u e u e Link unreachable），据此推测线上老年代出现大量不可达对象的原因就在于线程退出时其ThreadLocal依旧在老年代占有大量空间，并且由于线程已经退出，所以WeakOrderQueue Linkunreachable），据此推测线上老年代出现大量不可达对象的原因就在于线程退出时其ThreadLocal依旧在老年代占有大量空间，并且由于线程已经退出，所以WeakOrderQueueLink直接变成unreachable

netty Recycler（一）相关推荐

netty Recycler对象回收
netty Recycler对象回收相关类与接口 Recycler:对象重复使用 public abstract class Recycler<T> {private static fi ...
netty Recycler(二)——WeakOrderQueue和Stack
之前一直搞不清楚WeakOrderQueue的用途,"将别的线程的对象回收到本线程"还是"将别的线程的对象回收到别的线程"(前者是对的).所以研究了一下版本一 ...
netty Recycler(三)WeakOrderQueue unreachable
由于线上问题是由大量的WeakOrderQueue$Link对象引起的,而这些对象都是unreachable,为了研究线上问题的原因,尝试重新构建出WeakOrderQueue$Link的unreac ...
关于Netty中的Recycler对象池
1.对象池的背景 Netty本身作为通信用的框架,消息的创建和处理十分频繁,大多数的消息本身可循环使用的程度不高,大部分都是创建完传输后就被等待GC了.但是考虑到大部分消息只是消息部分内容有所差异,可 ...
抓到Netty一个隐藏很深的内存泄露Bug | 详解Recycler对象池的精妙设计与实现
本系列Netty源码解析文章基于 4.1.56.Final版本最近在 Review Netty 代码的时候,不小心用我的肉眼抓到了一个隐藏很深很深的内存泄露 Bug. 于是笔者将这个故事-哦不 -事 ...
冷知识：netty的Recycler对象池
在netty中Recycler用来实现对象池,以达到对象的循环利用,它是netty实现的一个轻量级对象回收站,具体的实现有:堆内存对应PooledHeapByteBuf,而直接内存对应的是Pooled ...
netty集成ssl完整参考指南（含完整源码）
虽然我们在内部rpc通信中使用的是基于认证和报文头加密的方式实现安全性,但是有些时候仍然需要使用SSL加密,可能是因为对接的三方系统需要,也可能是由于open的考虑.中午特地测了下netty下集成ss ...
netty权威指南学习笔记三——TCP粘包/拆包之粘包现象
TCP是个流协议,流没有一定界限.TCP底层不了解业务,他会根据TCP缓冲区的实际情况进行包划分,在业务上,一个业务完整的包,可能会被TCP底层拆分为多个包进行发送,也可能多个小包组合成一个大的数据包 ...
Java基础之《netty（28）—TCP粘包拆包原理》
一.基本介绍 1.TCP是面向连接的,面向流的,提供高可靠性服务.收发两端(客户端和服务器端)都要有一一成对的socket,因此,发送端为了将多个发给接收端的包,更有效的发给对方,使用了优化方法(Na ...

netty Recycler（一）

同一线程

不同线程

netty Recycler（一）相关推荐

最新文章

热门文章