threadlocal底层实现_ioc的底层实现原理

threadlocal底层实现_ioc的底层实现原理ThreadLocal作用:提供线程内的局部变量,不同的线程之间不会相互干扰,这种变量在线程的生命周期内起作用,减少同一个线程内多个函数或组件之间一些公共变量传递的复杂性。package com.mupack;public class App{ private String content; public void setContent(String content) { this.content = content; } public Stri

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

ThreadLocal

作用
提供线程内的局部变量,不同的线程之间不会相互干扰,这种变量在线程的生命周期内起作用,减少同一个线程内多个函数或组件之间一些公共变量传递的复杂性。

package com.mupack;

public class App
{ 
   
    private String content;

    public void setContent(String content) { 
   
        this.content = content;
    }
    public String getContent() { 
   
        return content;
    }
    public static void main(String[] args) throws Exception { 
   
        App app = new App();
        for(int i = 0;i < 5; i ++){ 
   
            Thread thread = new Thread(new Runnable(){ 
   

                @Override
                public void run() { 
   
                    app.setContent(Thread.currentThread().getName() + "的数据");
                    System.out.println("--------------------");
                    System.out.println(Thread.currentThread().getName() + "-------->" + app.getContent());
                }
            });
            thread.setName("线程" + i);
            thread.start();
        }
    }
}

在这里插入图片描述


换成ThreadLocal后

package com.mupack;

public class App
{ 
   
    ThreadLocal<String> t1 = new ThreadLocal<>();
    public void setContent(String content) { 
   
        t1.set(content);
    }
    public String getContent() { 
   
        return t1.get();
    }
    public static void main(String[] args) throws Exception { 
   
        App app = new App();
        for(int i = 0;i < 5; i ++){ 
   
            Thread thread = new Thread(new Runnable(){ 
   

                @Override
                public void run() { 
   
                    app.setContent(Thread.currentThread().getName() + "的数据");
                    System.out.println("--------------------");
                    System.out.println(Thread.currentThread().getName() + "-------->" + app.getContent());
                }
            });
            thread.setName("线程" + i);
            thread.start();
        }
    }
}

在这里插入图片描述


ThreadLocal典型应用场景
Mapper层需要处理异常以判断事务是否回滚,所有的数据库操作都需要用到一个connection,这个时候可以把connection和当前线程关联起来。


强软弱虚引用


5. 强引用:最常见的引用

Object o = new Object()

当没有印用指向new Object的时候,new Object()会被垃圾回收器回收

6. 软引用

package com.mupack;

import java.lang.ref.SoftReference;

import jdk.management.resource.internal.inst.ThreadRMHooks;

public class App
{ 
   
    public static void main(String[] args) throws Exception { 
   
        SoftReference<byte[]> softReference = new SoftReference<byte[]>(new byte[1024 * 1024 * 10]);
        //有值
        System.out.println(softReference.get());
        System.gc();
        //等一下垃圾回收,这个时候jvm内存充足,不会回收软引用。
        try { 
   
            Thread.sleep(500);
        } catch (Exception e) { 
   
            //TODO: handle exception
            e.printStackTrace();
        }
        //有值
        System.out.println(softReference.get());
        //这时候再定义一个数组,heap将装不下,这时候系统会垃圾回收,先回收一次,如果还不够,则把软引用也回收了。
        byte[] b = new byte[1024 * 1024 * 15];
        System.out.println(softReference.get());
    }
}

软引用实例:
当我们手动把jvm虚拟机内存调成20M,一开始定义一个10M数组,Heap够用,当时当第二次定义一个15M数组的时候,Heap不够用,所以垃圾回收器回收软引用。

3. 弱引用

package com.mupack;

import java.lang.ref.SoftReference;
import java.lang.ref.WeakReference;

import jdk.management.resource.internal.inst.ThreadRMHooks;

public class App
{ 
   
    public static void main(String[] args) throws Exception { 
   
        WeakReference<M> m = new WeakReference<>(new M());
        //有值
        System.out.println(m.get());
        System.gc();
        //没值
        System.out.println(m.get());

    }
}

弱引用遭遇到垃圾回收器(gc)就会被回收。

4. 虚引用

当一个虚引用被回收的时候,他会把信息传递到队列中去。虚引用其实并没有引用对象,只是当被回收的时候传递一个消息而已。

package com.mupack;

import java.lang.ref.PhantomReference;
import java.lang.ref.ReferenceQueue;
import java.lang.ref.SoftReference;
import java.lang.ref.WeakReference;
import java.util.List;
import java.util.Queue;

import jdk.management.resource.internal.inst.ThreadRMHooks;

public class App { 
   
    static private Queue QUEUE;
    static private List LIST;

    public static void main(String[] args) throws Exception { 
   
        PhantomReference<M> phantomReference = new PhantomReference<M>(new M(), (ReferenceQueue<? super M>) QUEUE);
        new Thread(() -> { 
   
            while(true){ 
   
                LIST.add(new byte[1024 * 1024]);
                try { 
   
                    Thread.sleep(1000);
                } catch (Exception e) { 
   
                    //TODO: handle exception
                    e.printStackTrace();
                    Thread.currentThread().interrupt();
                }
                //一直打印null
                System.out.println(phantomReference.get());
            }
        }).start();
        

    }
}

在这里插入图片描述
DirectByteBuffer是JVM内存中的一片内存,用来指向对外内存(操作系统管理的内存),操作系统管理的内存JVM垃圾处理器不能回收,所以当DirectByteBuffer回收后,会在队列中有相应的记录,之后JVM会去处理对外内存。(JVM是C++写的所以能够处理操作系统内存)。


各种引用用途

  1. 强引用:最常用的一种引用
  2. 软引用:适合做缓存,比如内存中一张图片,当内存不够用的时候先把图片移动出去,当内存充足的时候再把图片load进来
  3. 弱引用:为了解决某些地方的内存泄露问题。
  4. 虚引用:主要是应用在与系统内存区域交互的时候,比如从网络中下载的数据,如果没有虚引用,我们需要先把数据加载到JVM内存才能让JVM管理,现在有了虚引用,直接用JVM中的DirectByteBuffer内存区域指向系统内存,当DirectByteBuffer回收后,会通知队列,这时候JVM垃圾回收器就知道去系统内存请理相应的系统内存空间

ThreadLocal底层

每个ThreadLocal对应一个ThreadLocalMap(ThreadLocal内部类),每一个ThreadLocal中存储多个Entry,每个Entry的key为ThreadLocal对象,value为响应的值

public Class Thread{ 
   
		...
	    ThreadLocal.ThreadLocalMap threadLocals = null;
	    ...
}

1. get()方法

public T get() { 
   
		//获取当前线程
        Thread t = Thread.currentThread();
        //获取Thread中的Map
        ThreadLocalMap map = getMap(t);
        if (map != null) { 
   
        	//获取Entry
            ThreadLocalMap.Entry e = map.getEntry(this);
            if (e != null) { 
   
                @SuppressWarnings("unchecked")
                T result = (T)e.value;
                return result;
            }
        }
        //当Thread中没有ThreadLocalMap或者ThreadLocalMap中找不到响应的key时执行初始化
        return setInitialValue();
    }

2. initialValue()方法

private T setInitialValue() { 
   
		//获取一个初始值,默认为null
        T value = initialValue();
        //获取当前线程
        Thread t = Thread.currentThread();
        //获取当前线程的Map
        ThreadLocalMap map = getMap(t);
        if (map != null)
        	//如果Map存在,则设置
            map.set(this, value);
        else
        	//如果Map不存在,则创建一个Map,并且赋值
            createMap(t, value);
        return value;
    }

3. set()方法

    public void set(T value) { 
   
    	//获取当前线程
        Thread t = Thread.currentThread();
        //获取当前线程的Map
        ThreadLocalMap map = getMap(t);
        //同上
        if (map != null)
            map.set(this, value);
        else
            createMap(t, value);
    }

4. remove()方法

public void remove() { 
   
		//获取当前线程的Map
         ThreadLocalMap m = getMap(Thread.currentThread());
         if (m != null)
         	//移除Map中的key,value
             m.remove(this);
     }

ThreadLocal中的内存泄露问题

Entry对象实际是一个弱引用,如果一个对象只有弱引用的时候,那当垃圾回收器遇见他的时候它就会被回收。

//Entry继承弱引用类
static class Entry extends WeakReference<ThreadLocal<?>> { 
   
            /** The value associated with this ThreadLocal. */
            Object value;

            Entry(ThreadLocal<?> k, Object v) { 
   
            	//调用父接口,令弱引用指向ThreadLocal变量
                super(k);
                value = v;
            }
        }

在这里插入图片描述
若是强引用,当tl = null之后,Thread线程对象还是会一直存在,这时会形成一个引用链(Thread->ThreadLocalMap->Entry->ThreadLocal),导致ThreadLocal仍然释放不了,所以ThreadLocal应该使用弱引用,当tl = null后垃圾回收器一遇见ThreadLocal就直接回收掉ThreadLocal。但是这样仍然会存在内存泄漏问题,即ThreadLocal被回收之后,key不存在,导致value无法被访问到,所以正确的用法应该是不用ThreadLocal的时候手动remove掉。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/168805.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • 安装cloudsim[通俗易懂]

    安装cloudsim[通俗易懂]1.CloudSim介绍       2009年,墨尔本大学的网格实验室和Gridbus项目宣布推出云计算仿真软件,称为CloudSim。它是在离散事件模拟包SimJava上开发的函数库,可在Windows和Linux系统上跨平台运行,CloudSim继承了GridSim的编程模型,支持云计算的研究和开发,并提供了以下新的特点:(1)支持大型云计算的基础设施的建模与仿真;(2)一

    2022年10月9日
    0
  • leetcode-55跳跃游戏[通俗易懂]

    leetcode-55跳跃游戏[通俗易懂]给定一个非负整数数组 nums ,你最初位于数组的 第一个下标 。数组中的每个元素代表你在该位置可以跳跃的最大长度。判断你是否能够到达最后一个下标。示例 1:输入:nums = [2,3,1,1,4]输出:true解释:可以先跳 1 步,从下标 0 到达下标 1, 然后再从下标 1 跳 3 步到达最后一个下标。示例 2:输入:nums = [3,2,1,0,4]输出:false解释:无论怎样,总会到达下标为 3 的位置。但该下标的最大跳跃长度是 0 , 所以永远不可能到达最后一个下标

    2022年8月9日
    5
  • docker 启动容器出现 Exited[通俗易懂]

    有时候在启动容器的时候,启动没报错,但是在执行dockerps-a时发现刚启动的容器状态为Exited(1),这个时候查看日志dockerlogs-f-t–tail20容器ID,发现报chown:changingownershipof’.’:Permissiondenied提示没有权限,这个时候将容器删除,在执行容器启动的命令中加入–privi…

    2022年4月17日
    1.3K
  • 学习verilog的经典好教材与资料

    夏宇闻系列的:VerilongHDL入门(第3版)巴斯克(BHASKERJ.)、夏宇闻、甘伟北京航空航天大学出版社(2008-09出版)Verilog数字系统设计教程(第2版)夏宇间北京航空航天大学出版社(2008-06出版)VerilogHDL数字设计与综合(第2版)SamirPalnitkar(帕尔尼卡)、夏宇闻、胡燕祥、刁岚松电子工业出版社(2009-0

    2022年4月12日
    584
  • Java构造函数调用顺序问题

    Java构造函数调用顺序问题java构造代码调用顺序研究。

    2022年6月22日
    24
  • 机器学习:随机梯度下降法

    机器学习:随机梯度下降法1.梯度下降  1)什么是梯度下降?      因为梯度下降是一种思想,没有严格的定义,所以用一个比喻来解释什么是梯度下降。         简单来说,梯度下降就是从山顶找一条最短的路走到山脚最低的地方。但是因为选择方向的原因,我们找到的的最低点可能不是真正的最低点。如图所示,黑线标注的路线所指的方向并不是真正的地方。    既然是选择一个方向下山,那么这个方向怎么选…

    2022年9月11日
    0

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号