Chinaunix首页 | 论坛 | 博客
  • 博客访问: 2316410
  • 博文数量: 252
  • 博客积分: 5472
  • 博客等级: 大校
  • 技术积分: 3107
  • 用 户 组: 普通用户
  • 注册时间: 2011-09-17 18:39
文章分类

全部博文(252)

文章存档

2012年(96)

2011年(156)

分类: Java

2011-12-26 20:11:46

早在JDK 1.2的版本中就提供java.lang.ThreadLocal,ThreadLocal为解决多线程程序的并发问题提供了一种新的思路。使用这个工具类可以很简洁地编写出优美的多线程程序。

ThreadLocal很容易让人望文生义,想当然地认为是一个“本地线程”。其实,ThreadLocal并不是一个Thread,而是Thread的局部变量,也许把它命名为ThreadLocalVariable更容易让人理解一些。

当使用ThreadLocal维护变量时,ThreadLocal为每个使用该变量的线程提供独立的变量副本,所以每一个线程都可以独立地改变自己的副本,而不会影响其它线程所对应的副本。

从线程的角度看,目标变量就象是线程的本地变量,这也是类名中“Local”所要表达的意思。

主要是四个方法组成

initialValue(),get(),set(T),remove()

 

例子

Hibernate的文档时看到了关于使ThreadLocal管理多线程访问的部分。具体代码如下

 

  1. 1. public static final ThreadLocal session = new ThreadLocal();
  2. 2. public static Session currentSession() {
  3. 3. Session s = (Session)session.get();
  4. 4. //open a new session,if this session has none

  5. 5. if(s == null){
  6. 6. s = sessionFactory.openSession();
  7. 7. session.set(s);
  8. 8. }
  9.       return s;
  10. 9. }

1。初始化一个ThreadLocal对象,ThreadLocal有三个成员方法 get()、set()、initialvalue()。 
    如果不初始化initialvalue,则initialvalue返回null。 
3。session的get根据当前线程返回其对应的线程内部变量,也就是我们需要的net.sf.hibernate.Session(相当于对应每个数据库连接).多线程情况下共享数据库链接是不安全的。ThreadLocal保证了每个线程都有自己的s(数据库连接)。 
5。如果是该线程初次访问,自然,s(数据库连接)会是null,接着创建一个Session,具体就是行6。 
6。创建一个数据库连接实例 s 
7。保存该数据库连接s到ThreadLocal中。 
8。如果当前线程已经访问过数据库了,则从session中get()就可以获取该线程上次获取过的连接实例。

 

当要给线程初始化一个特殊值时,需要自己实现ThreadLocal的子类并重写该方法,通常使用一个内部匿名类对ThreadLocal进行子类化,EasyDBO中创建jdbc连接上下文就是这样做的:

  1. public class JDBCContext{
  2.  private static Logger logger = Logger.getLogger(JDBCContext.class);
  3.  private DataSource ds;
  4.  protected Connection connection;
  5.  private boolean isValid = true;
  6.  private static ThreadLocal jdbcContext;

  7.  private JDBCContext(DataSource ds){
  8.   this.ds = ds;
  9.   createConnection();
  10.  }
  11.  public static JDBCContext getJdbcContext(javax.sql.DataSource ds)
  12.  {
  13.   if(jdbcContext==null)jdbcContext=new JDBCContextThreadLocal(ds);
  14.   JDBCContext context = (JDBCContext) jdbcContext.get();
  15.   if (context == null) {
  16.    context = new JDBCContext(ds);
  17.   }
  18.   return context;
  19.  }

  20.  private static class JDBCContextThreadLocal extends ThreadLocal {
  21.   public javax.sql.DataSource ds;
  22.   public JDBCContextThreadLocal(javax.sql.DataSource ds)
  23.   {
  24.    this.ds=ds;
  25.   }
  26.   protected synchronized Object initialValue() {
  27.    return new JDBCContext(ds);
  28.   }
  29.  }
  30. }

 

使用单例模式,不同的线程调用getJdbcContext()获得自己的jdbcContext,都是通过JDBCContextThreadLocal 内置子类来获得JDBCContext对象的线程局部变量

 

 

一、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

阅读(3602) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~