热门标签 | HotTags
当前位置:  开发笔记 > 运维 > 正文

深入解析Java中ThreadLocal线程类的作用和用法

ThreadLocal为解决多线程程序的并发问题提供了一种新的思路,ThreadLocal并不是一个Thread,而是Thread的局部变量,本文就来深入解析Java中ThreadLocal线程类的作用和用法.

ThreadLocal与线程成员变量还有区别,ThreadLocal该类提供了线程局部变量。这个局部变量与一般的成员变量不一样,ThreadLocal的变量在被多个线程使用时候,每个线程只能拿到该变量的一个副本,这是Java API中的描述,通过阅读API源码,发现并非副本,副本什么概念?克隆品? 或者是别的样子,太模糊。
 
准确的说,应该是ThreadLocal类型的变量内部的注册表(Map)发生了变化,但ThreadLocal类型的变量本身的确是一个,这才是本质!
 
下面就做个例子:
 
一、标准例子
 
定义了MyThreadLocal类,创建它的一个对象tlt,分别给四个线程使用,结果四个线程tlt变量并没有出现共用现象,二是各用各的,这说明,四个线程使用的是tlt的副本(克隆品)。

 
/** 
* 使用了ThreadLocal的类 
*/ 
public class MyThreadLocal { 
    //定义了一个ThreadLocal变量,用来保存int或Integer数据 
    private ThreadLocal tl = new ThreadLocal() { 
        @Override 
        protected Integer initialValue() { 
            return 0; 
        } 
    }; 

    public Integer getNextNum() { 
        //将tl的值获取后加1,并更新设置t1的值 
        tl.set(tl.get() + 1); 
        return tl.get(); 
    } 
}

 

/** 
* 测试线程 
*/ 
public class TestThread extends Thread { 
    private MyThreadLocal tlt = new MyThreadLocal(); 

    public TestThread(MyThreadLocal tlt) { 
        this.tlt = tlt; 
    } 

    @Override 
    public void run() { 
        for (int i = 0; i <3; i++) { 
            System.out.println(Thread.currentThread().getName() + "\t" + tlt.getNextNum()); 
        } 
    } 
}

 

/** 
* ThreadLocal测试 
*/ 
public class Test { 
    public static void main(String[] args) { 
        MyThreadLocal tlt = new MyThreadLocal(); 
        Thread t1 = new TestThread(tlt); 
        Thread t2 = new TestThread(tlt); 
        Thread t3 = new TestThread(tlt); 
        Thread t4 = new TestThread(tlt); 
        t1.start(); 
        t2.start(); 
        t3.start(); 
        t4.start(); 

    } 
}

 
可以看出,三个线程各自独立编号,互不影响:

Thread-0 1 
Thread-1 1 
Thread-0 2 
Thread-1 2 
Thread-0 3 
Thread-1 3 
Thread-2 1 
Thread-3 1 
Thread-2 2 
Thread-3 2 
Thread-2 3 
Thread-3 3 


Process finished with exit code 0

 
tlt对象是一个,废话tl对象也是一个,因为组合关系是一对一的。但是tl对象内部的Map随着线程的增多,会创建很多Integer对象。只是Integer和int已经通用了。所以感觉不到Integer的对象属性。
 
二、不用ThreadLocal
 
假如不用ThreadLocal,只需要将MyThreadLocal类重新定义为:


/** 
* 使用了ThreadLocal的类 
*/ 
public class MyThreadLocal { 
    private Integer t1 = 0; 
    public Integer getNextNum(){ 
        return t1=t1+1; 
    } 



//    定义了一个ThreadLocal变量,用来保存int或Integer数据 
//    private ThreadLocal tl = new ThreadLocal() { 
//        @Override 
//        protected Integer initialValue() { 
//            return 0; 
//        } 
//    }; 
// 
//    public Integer getNextNum() { 
//        //将tl的值获取后加1,并更新设置t1的值 
//        tl.set(tl.get() + 1); 
//        return tl.get(); 
//    } 
}

 
然后运行测试:

Thread-2 1 
Thread-2 2 
Thread-1 4 
Thread-1 6 
Thread-3 3 
Thread-3 9 
Thread-3 10 
Thread-1 8 
Thread-0 7 
Thread-0 11 
Thread-0 12 
Thread-2 5 

Process finished with exit code 0

 
从这里可以看出,四个线程共享了tlt变量,结果每个线程都直接修改tlt的属性。
 
三、自己实现个ThreadLocal
 

package com.lavasoft.test2; 

import java.util.Collections; 
import java.util.HashMap; 
import java.util.Map; 

/** 
* 使用了ThreadLocal的类 
*/ 
public class MyThreadLocal { 

    //定义了一个ThreadLocal变量,用来保存int或Integer数据 
    private com.lavasoft.test2.ThreadLocal tl = new com.lavasoft.test2.ThreadLocal() { 
        @Override 
        protected Integer initialValue() { 
            return 0; 
        } 
    }; 

    public Integer getNextNum() { 
        //将tl的值获取后加1,并更新设置t1的值 
        tl.set(tl.get() + 1); 
        return tl.get(); 
    } 
} 

class ThreadLocal { 
    private Map map = Collections.synchronizedMap(new HashMap()); 

    public ThreadLocal() { 
    } 

    protected T initialValue() { 
        return null; 
    } 

    public T get() { 
        Thread t = Thread.currentThread(); 
        T obj = map.get(t); 
        if (obj == null && !map.containsKey(t)) { 
            obj = initialValue(); 
            map.put(t, obj); 
        } 
        return obj; 
    } 

    public void set(T value) { 
        map.put(Thread.currentThread(), value); 
    } 

    public void remove() { 
        map.remove(Thread.currentThread()); 
    } 
}

 
运行测试:

Thread-0 1 
Thread-0 2 
Thread-0 3 
Thread-2 1 
Thread-2 2 
Thread-3 1 
Thread-2 3 
Thread-3 2 
Thread-1 1 
Thread-3 3 
Thread-1 2 
Thread-1 3 

Process finished with exit code 0

 
很意外,这个山寨版的ThreadLocal也同样运行很好,实现了JavaAPI中ThreadLocal的功能。
 
四、透过现象看本质
 
其实从程序角度看,tlt变量的确是一个,毫无疑问的。但是为什么打印出来的数字就互不影响呢?
是因为使用了Integer吗?-----不是。
原因是:protected T initialValue()和get(),因为每个线程在调用get()时候,发现Map中不存在就创建。调用它的时候,就创建了一个新变量,类型为T。每次都新建,当然各用个的互不影响了。
为了看清本质,将Integer换掉,重写部分类:
 

package com.lavasoft.test2; 

import java.util.Collections; 
import java.util.HashMap; 
import java.util.Map; 

/** 
* 使用了ThreadLocal的类 
*/ 
public class MyThreadLocal { 

    //定义了一个ThreadLocal变量,用来保存int或Integer数据 
    //    private ThreadLocal tl = new ThreadLocal() { 
    private com.lavasoft.test2.ThreadLocal tl = new com.lavasoft.test2.ThreadLocal() { 
        @Override 
        protected Bean initialValue() { 
            return new Bean(); 
        } 
    }; 

    @Override 
    public String toString() { 
        return "MyThreadLocal{" + 
                "tl=" + tl + 
                '}'; 
    } 

    public Bean getBean() { 
        return tl.get(); 
    } 

} 

class ThreadLocal { 
    private Map map = Collections.synchronizedMap(new HashMap()); 

    public ThreadLocal() { 
    } 

    protected T initialValue() { 
        return null; 
    } 

    public T get() { 
        Thread t = Thread.currentThread(); 
        T obj = map.get(t); 
        if (obj == null && !map.containsKey(t)) { 
            obj = initialValue(); 
            map.put(t, obj); 
        } 
        return obj; 
    } 

    public void set(T value) { 
        map.put(Thread.currentThread(), value); 
    } 

    public void remove() { 
        map.remove(Thread.currentThread()); 
    } 
}

 

package com.lavasoft.test2; 

/** 
* 测试Bean 
*/ 
public class Bean { 
    private String id = "0"; 
    private String name = "none"; 

    public Bean() { 
    } 

    public Bean(String id, String name) { 
        this.id = id; 
        this.name = name; 
    } 

    public String getId() { 
        return id; 
    } 

    public void setId(String id) { 
        this.id = id; 
    } 

    public String getName() { 
        return name; 
    } 

    public void setName(String name) { 
        this.name = name; 
    } 

    public String showinfo() { 
        return "Bean{" + 
                "id='" + id + '\'' + 
                ", name='" + name + '\'' + 
                '}'; 
    } 
}

 

package com.lavasoft.test2; 

/** 
* 测试线程 
*/ 
public class TestThread extends Thread { 
    private MyThreadLocal tlt = new MyThreadLocal(); 

    public TestThread(MyThreadLocal tlt) { 
        this.tlt = tlt; 
    } 

    @Override 
    public void run() { 
        System.out.println(">>>>>:" + tlt); 
        for (int i = 0; i <3; i++) { 
            System.out.println(Thread.currentThread().getName() + "\t" +tlt.getBean()+"\t"+tlt.getBean().showinfo()); 
        } 
    } 
}

 
然后运行测试:

>>>>>:MyThreadLocal{tl=com.lavasoft.test2.MyThreadLocal$1@1de3f2d} 
>>>>>:MyThreadLocal{tl=com.lavasoft.test2.MyThreadLocal$1@1de3f2d} 
>>>>>:MyThreadLocal{tl=com.lavasoft.test2.MyThreadLocal$1@1de3f2d} 
>>>>>:MyThreadLocal{tl=com.lavasoft.test2.MyThreadLocal$1@1de3f2d} 
Thread-1 com.lavasoft.test2.Bean@291aff Bean{id='0', name='none'} 
Thread-2 com.lavasoft.test2.Bean@fe64b9 Bean{id='0', name='none'} 
Thread-3 com.lavasoft.test2.Bean@186db54 Bean{id='0', name='none'} 
Thread-2 com.lavasoft.test2.Bean@fe64b9 Bean{id='0', name='none'} 
Thread-2 com.lavasoft.test2.Bean@fe64b9 Bean{id='0', name='none'} 
Thread-0 com.lavasoft.test2.Bean@291aff Bean{id='0', name='none'} 
Thread-3 com.lavasoft.test2.Bean@186db54 Bean{id='0', name='none'} 
Thread-3 com.lavasoft.test2.Bean@186db54 Bean{id='0', name='none'} 
Thread-1 com.lavasoft.test2.Bean@291aff Bean{id='0', name='none'} 
Thread-0 com.lavasoft.test2.Bean@291aff Bean{id='0', name='none'} 
Thread-0 com.lavasoft.test2.Bean@291aff Bean{id='0', name='none'} 
Thread-1 com.lavasoft.test2.Bean@291aff Bean{id='0', name='none'} 


Process finished with exit code 0

 
从打印结果很清楚的看到,MyThreadLocal的tlt对象的确是一个,tlt对象里的ThreadLocal的tl对象也是一个,但是,将t1t给每个线程用的时候,线程会重新创建Bean对象加入到ThreadLocal的Map中去使用。


关于ThreadLocal的几个误区:
一、ThreadLocal是java线程的一个实现

ThreadLocal的确是和java线程有关,不过它并不是java线程的一个实现,它只是用来维护本地变量。针对每个线程,提供自己的变量版本,主要是为了避免线程冲突,每个线程维护自己的版本。彼此独立,修改不会影响到对方。

二、ThreadLocal是相对于每个session的

ThreadLocal顾名思义,是针对线程。在java web编程上,每个用户从开始到会话结束,都有自己的一个session标识。但是ThreadLocal并不是在会话层上。其实,Threadlocal是独立于用户session的。它是一种服务器端行为,当服务器每生成一个新的线程时,就会维护自己的ThreadLocal。

对于这个误解,个人认为应该是开发人员在本地基于一些应用服务器测试的结果。众所周知,一般的应用服务器都会维护一套线程池,也就是说,对于每次访问,并不一定就新生成一个线程。而是自己有一个线程缓存池。对于访问,先从缓存池里面找到已有的线程,如果已经用光,才去新生成新的线程。

所以,由于开发人员自己在测试时,一般只有他自己在测,这样服务器的负担很小,这样导致每次访问可能是共用同样一个线程,导致会有这样的误解:每个session有一个ThreadLocal

三、ThreadLocal是相对于每个线程的,用户每次访问会有新的ThreadLocal

理论上来说,ThreadLocal是的确是相对于每个线程,每个线程会有自己的ThreadLocal。但是上面已经讲到,一般的应用服务器都会维护一套线程池。因此,不同用户访问,可能会接受到同样的线程。因此,在做基于TheadLocal时,需要谨慎,避免出现ThreadLocal变量的缓存,导致其他线程访问到本线程变量

四、对每个用户访问,ThreadLocal可以多用

可以说,ThreadLocal是一把双刃剑,用得来的话可以起到非常好的效果。但是,ThreadLocal如果用得不好,就会跟全局变量一样。代码不能重用,不能独立测试。因为,一些本来可以重用的类,现在依赖于ThreadLocal变量。如果在其他没有ThreadLocal场合,这些类就变得不可用了。个人觉得ThreadLocal用得很好的几个应用场合,值得参考

1、存放当前session用户:quake want的jert

2、存放一些context变量,比如webwork的ActionContext

3、存放session,比如Spring hibernate orm的session


推荐阅读
  • 优化联通光猫DNS服务器设置
    本文详细介绍了如何为联通光猫配置DNS服务器地址,以提高网络解析效率和访问体验。通过智能线路解析功能,域名解析可以根据访问者的IP来源和类型进行差异化处理,从而实现更优的网络性能。 ... [详细]
  • CentOS 7 磁盘与文件系统管理指南
    本文详细介绍了磁盘的基本结构、接口类型、分区管理以及文件系统格式化等内容,并提供了实际操作步骤,帮助读者更好地理解和掌握 CentOS 7 中的磁盘与文件系统管理。 ... [详细]
  • 创建第一个 MUI 移动应用项目
    本文将详细介绍如何使用 HBuilder 创建并运行一个基于 MUI 框架的移动应用项目。我们将逐步引导您完成项目的搭建、代码编写以及真机调试,帮助您快速入门移动应用开发。 ... [详细]
  • 深入理解 SQL 视图、存储过程与事务
    本文详细介绍了SQL中的视图、存储过程和事务的概念及应用。视图为用户提供了一种灵活的数据查询方式,存储过程则封装了复杂的SQL逻辑,而事务确保了数据库操作的完整性和一致性。 ... [详细]
  • 梦幻西游挖图奇遇:70级项链意外触发晶清诀,3000W轻松到手
    在梦幻西游中,挖图是一项备受欢迎的活动,无论是小宝图还是高级藏宝图,都吸引了大量玩家参与。通常情况下,小宝图的数量保证了稳定的收益,但特技装备的出现往往能带来意想不到的惊喜。本文讲述了一位玩家通过挖图获得70级晶清项链的故事,最终实现了3000W的游戏币逆袭。 ... [详细]
  • 本文探讨了 RESTful API 和传统接口之间的关键差异,解释了为什么 RESTful API 在设计和实现上具有独特的优势。 ... [详细]
  • 本文详细介绍了Java编程语言中的核心概念和常见面试问题,包括集合类、数据结构、线程处理、Java虚拟机(JVM)、HTTP协议以及Git操作等方面的内容。通过深入分析每个主题,帮助读者更好地理解Java的关键特性和最佳实践。 ... [详细]
  • 如何配置Unturned服务器及其消息设置
    本文详细介绍了Unturned服务器的配置方法和消息设置技巧,帮助用户了解并优化服务器管理。同时,提供了关于云服务资源操作记录、远程登录设置以及文件传输的相关补充信息。 ... [详细]
  • 网络攻防实战:从HTTP到HTTPS的演变
    本文通过一系列日记记录了从发现漏洞到逐步加强安全措施的过程,探讨了如何应对网络攻击并最终实现全面的安全防护。 ... [详细]
  • MQTT技术周报:硬件连接与协议解析
    本周开发笔记重点介绍了在新项目中使用MQTT协议进行硬件连接的技术细节,涵盖其特性、原理及实现步骤。 ... [详细]
  • UNP 第9章:主机名与地址转换
    本章探讨了用于在主机名和数值地址之间进行转换的函数,如gethostbyname和gethostbyaddr。此外,还介绍了getservbyname和getservbyport函数,用于在服务器名和端口号之间进行转换。 ... [详细]
  • 邮件(带附件,模拟文件上传,跨服务器)发送核心代码1.测试邮件发送附件接口***测试邮件发送附件*@parammultipartFile*@return*@RequestMappi ... [详细]
  • 360SRC安全应急响应:从漏洞提交到修复的全过程
    本文详细介绍了360SRC平台处理一起关键安全事件的过程,涵盖从漏洞提交、验证、排查到最终修复的各个环节。通过这一案例,展示了360在安全应急响应方面的专业能力和严谨态度。 ... [详细]
  • 本文深入探讨了Linux系统中网卡绑定(bonding)的七种工作模式。网卡绑定技术通过将多个物理网卡组合成一个逻辑网卡,实现网络冗余、带宽聚合和负载均衡,在生产环境中广泛应用。文章详细介绍了每种模式的特点、适用场景及配置方法。 ... [详细]
  • 本文探讨了在不使用服务器控件的情况下,如何通过多种方法获取并修改页面中的HTML元素值。除了常见的AJAX方式,还介绍了其他可行的技术方案。 ... [详细]
author-avatar
菁菁da小姐认_194
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有