β

在 dubbo 中使用 Threadlocal 的相关问题

Harries Blog™ 20 阅读

最近进入项目组 开发 ,偶尔翻阅别人 代码 时,看到如下 注释

在 dubbo 中使用 Threadlocal 的相关问题

注:该ThreadLocalUtil 就是内部使用 ThreadLocal 内部静态变量。

刚看到时完全不解,不知道其为什么这么说。当同事跟我解释原因,豁然开朗。细想,我们在工作使用中,如果不注意很容易就忽略这个问题。 在解释这个问题先,我们先来查看 ThreadLocal。

ThreadLocal

ThreadLocal 提供 线程 局部(thread-local)变量,为每个线程创建单独的变量副本,这样在 多线程 环境的下,由于每个线程都有单独的变量,不会因为变量共享导致的 并发 问题。当然相关问题我可以们使用 同步 机制解决该问题。

同步机制跟 ThreadLocal 区别

使用同步机制,多线程环境共享同一变量,这需要我们在使用时显示加 ,保证变量在同一 时间 只有一个线程能使用,相当于采用时间策略换取线程 安全

使用 ThreadLocal,每个线程拥有自己独立变量副本,相当于采用 空间 策略换取线程安全。

我们从代码查看下两种方式的区别。现在假如我们需要当前一个时间工具类,如下:

private final static SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    public static String getDateStr(Date date) {
        return format.format(date);
    }

查看上面 Demo,我们很容易可以看出上面方法由于是 SimpleDateFormat 不是线程安全,从而导致 getDateStr 方法非线程安全。

现在我们使用同步对其改造。

private final static SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    public static synchronized String getDateStrSync(Date date) {
        return format.format(date);
    }

这样使用显示加锁,避免多线程环境下线程安全。但是这种方式可能在 高并发 情况影响效率。

下面使用 ThreadLocal 对其改造。

private final static ThreadLocal<SimpleDateFormat> formatLocal = new ThreadLocal<SimpleDateFormat>() {
        protected synchronized SimpleDateFormat initialValue() {
            return new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        }
    };


    public static String getDateByLocal(Date date){
        return formatLocal.get().format(date);
    }

使用 ThreadLocal,将共享变量变成独享变量,保证线程安全。但是该种方案增加创建对象的开销。

综上,如何选择上述两种方式,需要结合当前业务方式选择。

讲完 ThreadLocal,我们来看下的 dubbo 的线程 模型

dubbo 线程模型

dubbo 默认采用单一 长连接 线程池 方式处理调用。

在 dubbo 中使用 Threadlocal 的相关问题

默认采取 Dispatcher=all 的分发策略,所有消息都派发到线程池,包括请求,响应,连接事件,断开事件,心跳等。线程池在缺省 配置 为固定大小线程池,启动时建立线程,不关闭,一直持有。默认为100个线程。

分析在 Dubbo 中使用 ThreadLocal

在 Dubbo 中使用 ThreadLocal ,如果采用默认的设置,每次 Dubbo 调用结束,Dubbo 处理响应线程并不会被销毁, 而是归还到线程池中。而从 ThreadLocal 源码 可以看出,每次我们设置的值其实会存在位于 Thread 中 ThreadLocalMap 变量中。

在 dubbo 中使用 Threadlocal 的相关问题

这就导致,下次如果 Dubbo 处理响应恰好继续使用到这个线程,该线程就能调用到上次响应中设置在 ThreadLocal 设置的值。这就引起内存泄露,可能还会导致业务上异常。其实并不止在 Dubbo 中,该案例还会发生在 web 项目中,只要相关使用线程池的,都有可能发生。

原文

https ://juejin.im/post/5b41d1d3e51d45195534556a

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。 PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处: Harries Blog™ » 在 dubbo 中使用 Threadlocal 的相关问题

作者:Harries Blog™
追心中的海,逐世界的梦
原文地址:在 dubbo 中使用 Threadlocal 的相关问题, 感谢原作者分享。

发表评论