java线程封闭之栈封闭和ThreadLocal

 更新时间:2019年10月23日 09:12:21   作者:张小云的博客  
这篇文章主要介绍了java线程封闭之栈封闭和ThreadLocal,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

线程封闭

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

1、栈封闭

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

2、ThreadLocal

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

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

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()

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的时候一般都会选择重写实现这个方法。

 // 这里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());
  }  

结合这个小程序和上面的图就可以对threadLocal有一个大概的理解了。其他的方法如set、remove等方法都大同小异,可以结合图片去看源码,这里不再赘述。

关于内存泄漏的问题

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

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

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

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

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

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Java 3年面试经验告诉你Mybatis是如何进行分页的

    Java 3年面试经验告诉你Mybatis是如何进行分页的

    这篇文章主要介绍了Java 3年面试经验告诉你Mybatis是如何进行分页的,对于任何ORM框架,分页的实现逻辑无外乎两种,不管怎么包装,最终给到开发者的,只是使用上的差异而已,本文给大家讲解的很明白,感兴趣的朋友一起看看吧
    2022-09-09
  • RabbitMQ中的死信队列(Dead Letter Exchanges)详解

    RabbitMQ中的死信队列(Dead Letter Exchanges)详解

    这篇文章主要介绍了RabbitMQ中的死信队列(Dead Letter Exchanges)详解,当RabbitMQ出现死信,可能会导致业务逻辑错误,比如下订单后修改库存操作,在下单后因为某种原因,发送的消息未被签收,这时库存数据会出现不一致,需要的朋友可以参考下
    2023-12-12
  • Spring Boot整合Swagger测试api构建全纪录

    Spring Boot整合Swagger测试api构建全纪录

    这篇文章主要给大家介绍了关于Spring Boot整合Swagger测试api构建的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-01-01
  • Java多线程Atomic包操作原子变量与原子类详解

    Java多线程Atomic包操作原子变量与原子类详解

    这篇文章主要介绍了Java多线程Atomic包操作原子变量与原子类详解,简单介绍了Atomic,同时涉及java.util.concurrent中的原子变量,Atomic类的作用等相关内容,具有一定参考价值,需要的朋友可以了解下。
    2017-11-11
  • 基于断点续传下载原理的实现

    基于断点续传下载原理的实现

    下面小编就为大家带来一篇基于断点续传下载原理的实现。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-09-09
  • Java基于字符界面的简易收银台

    Java基于字符界面的简易收银台

    这篇文章主要为大家详细介绍了Java基于字符界面的简易收银台,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-06-06
  • 大厂面试常考:快速排序冒泡排序算法

    大厂面试常考:快速排序冒泡排序算法

    快速排序由于排序效率在同为O(N*logN)的几种排序方法中效率较高,因此经常被采用,再加上快速排序思想----分治法也确实实用,因此很多软件公司的笔试面试,包括像BAT、字节、美团等知名IT公司都喜欢考查快速排序原理和手写源码
    2021-08-08
  • 解决nacos项目启动报错:Connection refused: no further informa问题

    解决nacos项目启动报错:Connection refused: no further&

    这篇文章主要介绍了解决nacos项目启动报错:Connection refused: no further informa问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-04-04
  • Java中Reactor的反应器模式详解

    Java中Reactor的反应器模式详解

    这篇文章主要介绍了Java中Reactor的反应器模式详解,Reactor反应器模式有点儿类似事件驱动模式,当有事件触发时,事件源会将事件dispatch分发到handler处理器进行事件处理,反应器模式中的反应器角色类似于事件驱动模式中的dispatcher事件分发器角色,需要的朋友可以参考下
    2023-12-12
  • SpringBoot项目部署到腾讯云的实现步骤

    SpringBoot项目部署到腾讯云的实现步骤

    本文主要介绍了SpringBoot项目部署到腾讯云的实现步骤,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-01-01

最新评论