本文作者:包子也沉默

线程封闭之栈封闭和ThreadLocal

包子也沉默 3年前 (2019-10-23) ( 10-23 ) 729 0条评论
摘要: 的方式来实现,在上面的图中,我用虚线来表示弱引用,弱引用的意思是在JVM进行垃圾回收的时候这个引用会被回收(无论内存足够与否);试想一下,如果使用强引用并且栈中的引用消失了,那么在线程结束之前这个threadLocal对象不会被回收且无法访问,也就是造成内存泄漏。 3、Java四种引用的简要概述  上面在ThreadLocal提到了弱引用,这里顺便简单的说下Java中的四种引用。强引用:指new出

线程封闭

  在多线程的环境中,我们经常使用锁来保证线程的安全,但是对于每个线程都要用的资源使用锁的话那么程序执行的效率就会受到影响,这个时候可以把这些资源变成线程封闭的形式。

了弱引用,这里顺便简单的说下Java中的四种引用。强引用:指new出来的对象,一般没有特别申明的对象都是强引用。这种对象只有在GCroots找不到它的时候才会被回收。软引用(SoftReference

 1、栈封闭

  所谓的栈封闭其实就是使用局部变量存放资源,我们知道局部变量在内存中是存放在虚拟机栈中,而栈又是每个线程私有独立的,所以这样可以保证线程的安全。

vlet.mvc.support.DefaultHandlerExceptionResolverorg.springframework.web.servlet.RequestToViewNameTra

 2、ThreadLocal

  我们先看ThreadLocal和线程Thread的关系图。

,那SpringMvc是怎么做的呢?源码如下:@OverrideprotectedfinalvoiddoPost(HttpServletRequestrequest,HttpServletRespon

  

 

eption{//未放入value直接调用getSystem.err.println("invokegetbeforeanyset:"+threadLocal.get());threadLocal.s

结合图片去看源码,这里不再赘述。  关于内存泄漏的问题    1、在threadLocal的get、set、remove方法中,其对本身可能发生的内存泄漏都做了处理,逻辑上面也提到如果对应entry为

get());}).start();TimeUnit.SECONDS.sleep(1);//证明threadLocal中的value不在线程中共享System.err.println("afterth

 

eption{//未放入value直接调用getSystem.err.println("invokegetbeforeanyset:"+threadLocal.get());threadLocal.s

结合图片去看源码,这里不再赘述。  关于内存泄漏的问题    1、在threadLocal的get、set、remove方法中,其对本身可能发生的内存泄漏都做了处理,逻辑上面也提到如果对应entry为

get());}).start();TimeUnit.SECONDS.sleep(1);//证明threadLocal中的value不在线程中共享System.err.println("afterth

   再看下ThreadLocal的操作,以get为例

M进行垃圾回收的时候这个引用会被回收(无论内存足够与否);试想一下,如果使用强引用并且栈中的引用消失了,那么在线程结束之前这个threadLocal对象不会被回收且无法访问,也就是造成内存泄漏。 3、

public T get() {
        // 当前线程
        Thread t = Thread.currentThread();
   // 拿到当前线程的threadLocalMap,即上图中的map引用
        ThreadLocalMap map = getMap(t);
        if (map != null) {
            // 拿到当前ThreadLocal为Key对应的Entry,里面做了防止内存泄漏的处理
            ThreadLocalMap.Entry e = map.getEntry(this);
            if (e != null) {
                @SuppressWarnings("unchecked")
                T result = (T)e.value;
                return result;
            }
        }
        // 如果为null设置默认值
        return setInitialValue();
    }

  如上面get方法的源码所示,在调用threadLocal.get()方法的时候,threadLocal拿到当前线程中ThreadLocalMap中以threadLocal自身为key对应的entry,在这个getEntry方法中里面做了内存泄漏的处理,大概处理逻辑就是如果threadLocal对应的Entry为null的话,让这个entry的value为null并且map中threadLocal对应下标置null,如果不为null的话返回,否则的话则调用默认值方法setInitialValue()

roller来处理用户的请求呢?*todo这一步就是通过处理器映射器完成的*todo说白了,通过处理器映射器我们可以找到那个处理当前请求的特定的组件,我们称它为handler*todo但是这之间存在一

 private T setInitialValue() {
        T value = initialValue();
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null)
            map.set(this, value);
        else
            createMap(t, value);
        return value;
    }

  // 默认null实现
 protected T initialValue() {
        return null;
  }

  setInitialValue()方法逻辑比较简单,这里不多赘述,值得注意的是里面调用的initialValue(),并没有任何的实现,所以我们使用threadLocal的时候一般都会选择重写实现这个方法。

initialValue(){returnnull;}  setInitialValue()方法逻辑比较简单,这里不多赘述,值得注意的是里面调用的initialValue(),并没有任何的实现,所以我

 // 这里main方法测试,所以用static修饰,会延长threadLocal的生命周期,有内存泄漏的风险,一般作为成员变量就足够了
public
static ThreadLocal<String> threadLocal = new ThreadLocal<String>(){ @Override protected String initialValue() { return "init string from initialValue method"; } }; public static void main(String[] args) throws InterruptedException { // 未放入value直接调用get System.err.println("invoke get before any set:" + threadLocal.get()); threadLocal.set("test"); System.err.println("before thread start : " + threadLocal.get()); new Thread(() -> { // 对相同的threadLocal对象放入值 threadLocal.set("test in thread"); System.err.println("In thread[" + Thread.currentThread().getName() + "] threadLocal value : " + threadLocal.get()); }).start(); TimeUnit.SECONDS.sleep(1); // 证明threadLocal中的value不在线程中共享 System.err.println("after thread value : " + threadLocal.get()); }
result:
  
  结合这个小程序和上面的图就可以对threadLocal有一个大概的理解了。其他的方法如set、remove等方法都大同小异,可以结合图片去看源码,这里不再赘述。

  关于内存泄漏的问题

    1、在threadLocal的get、set、remove方法中,其对本身可能发生的内存泄漏都做了处理,逻辑上面也提到如果对应entry为null,将其value置null,将map中对应下标引用置null。

nHandlerExceptionResolver,org.springframework.web.servlet.mvc.annotation.ResponseStatusExceptionReso

    2、而对于threadLocal中这个对象的泄漏来说,则是采用弱引用的方式来实现,在上面的图中,我用虚线来表示弱引用,弱引用的意思是在JVM进行垃圾回收的时候这个引用会被回收(无论内存足够与否);试想一下,如果使用强引用并且栈中的引用消失了,那么在线程结束之前这个threadLocal对象不会被回收且无法访问,也就是造成内存泄漏。

接看它的中文翻译就是处理器映射器是不好理解的,其实也没有特别难懂,就是一个映射器嘛,映射什么呢?就是映射用户的请求与后端程序员编写的Controller之间的关系,再直白一点,就是一个用户的请求经过了

 3、Java四种引用的简要概述

  上面在ThreadLocal提到了弱引用,这里顺便简单的说下Java中的四种引用。

let的service()方法说起了,大家都知道这个方法会在Serlvet每一次收到请求时就会被回调一次,再回想我们原来是怎么变成来着?但是后来我们都直接实现HttpServlet接口,然后重写他们的

  1. 强引用:指new出来的对象,一般没有特别申明的对象都是强引用。这种对象只有在GCroots找不到它的时候才会被回收。
  2. 软引用(SoftReference的子类):GC后内存不足的情况将只有这种引用的对象回收。
  3. 弱引用(WeakReference的子类):GC时回收只有此引用的对象(无论内存是否不足)。
  4. 虚引用(PhantomReference子类):没有特别的功能,类似一个追踪符,配合引用队列来记录对象何时被回收。(实际上这四种引用都可以配合引用队列使用,只要在构造方法中传入需要关联的引用队列就行,在对象调用finalize方法的时候会被写入到队列当中)

 

eption{//未放入value直接调用getSystem.err.println("invokegetbeforeanyset:"+threadLocal.get());threadLocal.s

结合图片去看源码,这里不再赘述。  关于内存泄漏的问题    1、在threadLocal的get、set、remove方法中,其对本身可能发生的内存泄漏都做了处理,逻辑上面也提到如果对应entry为

get());}).start();TimeUnit.SECONDS.sleep(1);//证明threadLocal中的value不在线程中共享System.err.println("afterth

若有不正之处,望指出!

nnomatchingbeansarefoundintheDispatcherServletcontext.#Notmeanttobecustomizedbyapplicationdevelopers

文章版权声明:除非注明,否则均为本站原创文章,转载或复制请以超链接形式并注明出处。
分享到:
赞 (0

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏

发表评论

快捷回复:

评论列表 (有 0条评论, 729人围观) 参与讨论