JAVA语言中ThreadLocal的用法
吕益平 2018-05-09 来源 : 阅读 962 评论 0

摘要:JAVA语言中ThreaLocal的JDK文档中说明:ThreadLocal instances are typically private static fields in classes that wish to associate state with a thread。如果我们希望通过某个类将状态(例如用户ID、事务ID)与线程关联起来,那么通常在这个类中定义private static类型的ThreadLocal 实例。希望对大家JAVA语言的学习有所帮助。

用法一:在关联数据类中创建private static ThreadLocal

       ThreaLocal的JDK文档中说明:ThreadLocal instances are typically private static fields in classes that wish to associate state with a thread。如果我们希望通过某个类将状态(例如用户ID、事务ID)与线程关联起来,那么通常在这个类中定义private static类型的ThreadLocal 实例。

例如,在下面的类中,私有静态 ThreadLocal 实例(serialNum)为调用该类的静态 SerialNum.get() 方法的每个线程维护了一个“序列号”,该方法将返回当前线程的序列号。(线程的序列号是在第一次调用 SerialNum.get() 时分配的,并在后续调用中不会更改。)

public class SerialNum {
     // The next serial number to be assigned
     private static int nextSerialNum = 0;
 
     private static ThreadLocal serialNum = new ThreadLocal() {
         protected synchronized Object initialValue() {
             return new Integer(nextSerialNum++);
         }
     };
 
     public static int get() {
         return ((Integer) (serialNum.get())).intValue();
     }
 }

 

例:

public class ThreadContext {     private String userId;   private Long transactionId;     private static ThreadLocal threadLocal = new ThreadLocal(){     @Override         protected ThreadContext initialValue() {             return new ThreadContext();         }     };   public static ThreadContext get() {     return threadLocal.get();   }
   public String getUserId() {     return userId;   }   public void setUserId(String userId) {     this.userId = userId;   }   public Long getTransactionId() {     return transactionId;   }   public void setTransactionId(Long transactionId) {     this.transactionId = transactionId;   }   }

 

 

用法二:在Runnable中创建ThreadLocal

   还有一种用法是在线程类内部创建ThreadLocal,基本步骤如下:

1、在多线程的类(如ThreadDemo类)中,创建一个ThreadLocal对象threadXxx,用来保存线程间需要隔离处理的对象xxx。
2、在ThreadDemo类中,创建一个获取要隔离访问的数据的方法getXxx(),在方法中判断,若ThreadLocal对象为null时候,应该new()一个隔离访问类型的对象,并强制转换为要应用的类型。
3、在ThreadDemo类的run()方法中,通过调用getXxx()方法获取要操作的数据,这样可以保证每个线程对应一个数据对象,在任何时刻都操作的是这个对象。 

 

public class ThreadLocalTest implements Runnable{
     
     ThreadLocal
studenThreadLocal = new ThreadLocal
();
 
     @Override
     public void run() {
         String currentThreadName = Thread.currentThread().getName();
         System.out.println(currentThreadName + " is running...");
         Random random = new Random();
         int age = random.nextInt(100);
         System.out.println(currentThreadName + " is set age: "  + age);
         Studen studen = getStudent(); //通过这个方法,为每个线程都独立的new一个student对象,每个线程的的student对象都可以设置不同的值
         studen.setAge(age);
         System.out.println(currentThreadName + " is first get age: " + studen.getAge());
         try {
             Thread.sleep(500);
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
         System.out.println( currentThreadName + " is second get age: " + studen.getAge());
         
     }
     
     private Studen getStudent() {
         Studen studen = studenThreadLocal.get();
         if (null == studen) {
             studen = new Studen();
             studenThreadLocal.set(studen);
         }
         return studen;
     }
 
     public static void main(String[] args) {
         ThreadLocalTest t = new ThreadLocalTest();
         Thread t1 = new Thread(t,"Thread A");
         Thread t2 = new Thread(t,"Thread B");
         t1.start();
         t2.start();
     }
     
 }
 
 class Studen{
     int age;
     public int getAge() {
         return age;
     }
     public void setAge(int age) {
         this.age = age;
     }
     
 }


 

 

用法三:在Util类中创建ThreadLocal

这是上面用法的扩展,即把ThreadLocal的创建放到工具类中。

【例】例如Hibernate的工具类:

public class HibernateUtil {     private static Log log = LogFactory.getLog(HibernateUtil.class);     private static final SessionFactory sessionFactory;     //定义SessionFactory       static {         try {             // 通过默认配置文件hibernate.cfg.xml创建SessionFactory             sessionFactory = new Configuration().configure().buildSessionFactory();         } catch (Throwable ex) {             log.error("初始化SessionFactory失败!", ex);             throw new ExceptionInInitializerError(ex);         }     }      //创建线程局部变量session,用来保存Hibernate的Session     public static final ThreadLocal session = new ThreadLocal();       /**      * 获取当前线程中的Session      * @return Session      * @throws HibernateException      */     public static Session currentSession() throws HibernateException {         Session s = (Session) session.get();         // 如果Session还没有打开,则新开一个Session         if (s == null) {             s = sessionFactory.openSession();             session.set(s);         //将新开的Session保存到线程局部变量中         }         return s;     }       public static void closeSession() throws HibernateException {         //获取线程局部变量,并强制转换为Session类型         Session s = (Session) session.get();         session.set(null);         if (s != null)             s.close();     } }

希望这篇文章可以帮助到你,总之同学们,IT资讯尽在职坐标。

本文由 @职坐标 发布于职坐标。未经许可,禁止转载。
喜欢 | 0 不喜欢 | 0
看完这篇文章有何感觉?已经有0人表态,0%的人喜欢 快给朋友分享吧~
评论(0)
后参与评论
本文作者 联系TA

熟悉企业软件开发的产品设计及开发

  • 57
    文章
  • 12660
    人气
  • 85%
    受欢迎度

已有47人表明态度,85%喜欢该老师!

进入TA的空间
求职秘籍 直通车
  • 索取资料 索取资料 索取资料
  • 答疑解惑 答疑解惑 答疑解惑
  • 技术交流 技术交流 技术交流
  • 职业测评 职业测评 职业测评
  • 面试技巧 面试技巧 面试技巧
  • 高薪秘笈 高薪秘笈 高薪秘笈
TA的其他文章 更多>>
java语言实现栈的顺序存储与链式存储
经验技巧 100% 的用户喜欢
一天天都在说hadoop,到底什么才是hadoop呢?
经验技巧 57% 的用户喜欢
WEB前端之div css 层级
经验技巧 100% 的用户喜欢
WEB前端之div css 绝对定位
经验技巧 100% 的用户喜欢
Java语言之Java Socket NIO示例
经验技巧 67% 的用户喜欢
其他海同师资 更多>>
孔庆琦
孔庆琦 联系TA
对MVC模式和三层架构有深入的研究
周鸣君
周鸣君 联系TA
擅长Hadoop/Spark大数据技术
范佺菁
范佺菁 联系TA
擅长Java语言,只有合理的安排和管理时间你才能做得更多,行得更远!
金延鑫
金延鑫 联系TA
擅长与学生或家长及时有效沟通
程光淼
程光淼 联系TA
精通C、C++等语言、智能芯片开发
经验技巧30天热搜词 更多>>

您输入的评论内容中包含违禁敏感词

我知道了

助您圆梦职场 匹配合适岗位
验证码手机号,获得海同独家IT培训资料
选择就业方向:
人工智能物联网
大数据开发/分析
人工智能Python
Java全栈开发
WEB前端+H5

请输入正确的手机号码

请输入正确的验证码

获取验证码

您今天的短信下发次数太多了,明天再试试吧!

提交

我们会在第一时间安排职业规划师联系您!

您也可以联系我们的职业规划师咨询:

小职老师的微信号:z_zhizuobiao
小职老师的微信号:z_zhizuobiao

版权所有 职坐标-一站式IT培训就业服务领导者 沪ICP备13042190号-4
上海海同信息科技有限公司 Copyright ©2015 www.zhizuobiao.com,All Rights Reserved.
 沪公网安备 31011502005948号    

©2015 www.zhizuobiao.com All Rights Reserved

208小时内训课程