JAVA多线程之ThreadLocal类

这篇文章提到了Threadlocal，NC里面就是用它来实现加锁及多线程操作

?

首先，ThreadLocal 不是用来解决共享对象的多线程访问问题的，一般情况下，通过ThreadLocal.set() 到线程中的对象是该线程自己使用的对象，其他线程是不需要访问的，也访问不到的。各个线程中访问的是不同的对象。

另外，说ThreadLocal使得各线程能够保持各自独立的一个对象，并不是通过ThreadLocal.set()来实现的，而是通过每个线程中的new 对象 的操作来创建的对象，每个线程创建一个，不是什么对象的拷贝或副本。通过ThreadLocal.set()将这个新创建的对象的引用保存到各线程的自己的一个map中，每个线程都有这样一个map，执行ThreadLocal.get()时，各线程从自己的map中取出放进去的对象，因此取出来的是各自自己线程中的对象，ThreadLocal实例是作为map的key来使用的。

如果ThreadLocal.set()进去的东西本来就是多个线程共享的同一个对象，那么多个线程的ThreadLocal.get()取得的还是这个共享对象本身，还是有并发访问问题。

下面来看一个hibernate中典型的ThreadLocal的应用：

Java代码

private?static?final?ThreadLocal?threadSession?=?new?ThreadLocal(); ????public?static?Session?getSession()?throws?InfrastructureException?{ ??????Session?s?=?(Session)?threadSession.get(); ??????try?{ ??????????if?(s?==?null)?{ ??????????????s?=?getSessionFactory().openSession(); ??????????????threadSession.set(s); ??????????} ??????}?catch?(HibernateException?ex)?{ ??????????throw?new?InfrastructureException(ex); ??????} ??????return?s; ??}??

?

可以看到在getSession()方法中，首先判断当前线程中有没有放进去session，如果还没有，那么通过sessionFactory().openSession()来创建一个session，再将session set到线程中，实际是放到当前线程的ThreadLocalMap这个map中，这时，对于这个session的唯一引用就是当前线程中的那个ThreadLocalMap（下面会讲到），而threadSession作为这个值的key，要取得这个session可以通过threadSession.get()来得到，里面执行的操作实际是先取得当前线程中的ThreadLocalMap，然后将threadSession作为key将对应的值取出。这个session相当于线程的私有变量，而不是public的。
显然，其他线程中是取不到这个session的，他们也只能取到自己的ThreadLocalMap中的东西。要是session是多个线程共享使用的，那还不乱套了。
试想如果不用ThreadLocal怎么来实现呢？可能就要在action中创建session，然后把session一个个传到service和dao中，这可够麻烦的。或者可以自己定义一个静态的map，将当前thread作为key，创建的session作为值，put到map中，应该也行，这也是一般人的想法，但事实上，ThreadLocal的实现刚好相反，它是在每个线程中有一个map，而将ThreadLocal实例作为key，这样每个map中的项数很少，而且当线程销毁时相应的东西也一起销毁了，不知道除了这些还有什么其他的好处。

总之，ThreadLocal不是用来解决对象共享访问问题的，而主要是提供了保持对象的方法和避免参数传递的方便的对象访问方式。归纳了两点：
1。每个线程中都有一个自己的ThreadLocalMap类对象，可以将线程自己的对象保持到其中，各管各的，线程可以正确的访问到自己的对象。
2。将一个共用的ThreadLocal静态实例作为key，将不同对象的引用保存到不同线程的ThreadLocalMap中，然后在线程执行的各处通过这个静态ThreadLocal实例的get()方法取得自己线程保存的那个对象，避免了将这个对象作为参数传递的麻烦。

当然如果要把本来线程共享的对象通过ThreadLocal.set()放到线程中也可以，可以实现避免参数传递的访问方式，但是要注意get()到的是那同一个共享对象，并发访问问题要靠其他手段来解决。但一般来说线程共享的对象通过设置为某类的静态变量就可以实现方便的访问了，似乎没必要放到线程中。

ThreadLocal的应用场合，我觉得最适合的是按线程多实例（每个线程对应一个实例）的对象的访问，并且这个对象很多地方都要用到。

下面来看看ThreadLocal的实现原理（jdk1.5源码）

Java代码

public?class?ThreadLocal<T>?{ ??????/** ??????*?ThreadLocals?rely?on?per-thread?hash?maps?attached?to?each?thread ??????*?(Thread.threadLocals?and?inheritableThreadLocals).??The?ThreadLocal ??????*?objects?act?as?keys,?searched?via?threadLocalHashCode.??This?is?a ??????*?custom?hash?code?(useful?only?within?ThreadLocalMaps)?that?eliminates ??????*?collisions?in?the?common?case?where?consecutively?constructed ??????*?ThreadLocals?are?used?by?the?same?threads,?while?remaining?well-behaved ??????*?in?less?common?cases. ??????*/??????private?final?int?threadLocalHashCode?=?nextHashCode(); ????????/** ??????*?The?next?hash?code?to?be?given?out.?Accessed?only?by?like-named?method. ??????*/??????private?static?int?nextHashCode?=?0; ????????/** ??????*?The?difference?between?successively?generated?hash?codes?-?turns ??????*?implicit?sequential?thread-local?IDs?into?near-optimally?spread ??????*?multiplicative?hash?values?for?power-of-two-sized?tables. ??????*/??????private?static?final?int?HASH_INCREMENT?=?0x61c88647; ????????/** ??????*?Compute?the?next?hash?code.?The?static?synchronization?used?here ??????*?should?not?be?a?performance?bottleneck.?When?ThreadLocals?are ??????*?generated?in?different?threads?at?a?fast?enough?rate?to?regularly ??????*?contend?on?this?lock,?memory?contention?is?by?far?a?more?serious ??????*?problem?than?lock?contention. ??????*/??????private?static?synchronized?int?nextHashCode()?{ ??????????int?h?=?nextHashCode; ??????????nextHashCode?=?h?+?HASH_INCREMENT; ??????????return?h; ??????} ????????/** ??????*?Creates?a?thread?local?variable. ??????*/??????public?ThreadLocal()?{ ??????} ????????/** ??????*?Returns?the?value?in?the?current?thread's?copy?of?this?thread-local ??????*?variable.??Creates?and?initializes?the?copy?if?this?is?the?first?time ??????*?the?thread?has?called?this?method. ??????* ??????*?@return?the?current?thread's?value?of?this?thread-local ??????*/??????public?T?get()?{ ??????????Thread?t?=?Thread.currentThread(); ??????????ThreadLocalMap?map?=?getMap(t); ??????????if?(map?!=?null) ??????????????return?(T)map.get(this); ????????????//?Maps?are?constructed?lazily.??if?the?map?for?this?thread ??????????//?doesn't?exist,?create?it,?with?this?ThreadLocal?and?its ??????????//?initial?value?as?its?only?entry. ??????????T?value?=?initialValue(); ??????????createMap(t,?value); ??????????return?value; ??????} ????????/** ??????*?Sets?the?current?thread's?copy?of?this?thread-local?variable ??????*?to?the?specified?value.??Many?applications?will?have?no?need?for ??????*?this?functionality,?relying?solely?on?the?{@link?#initialValue} ??????*?method?to?set?the?values?of?thread-locals. ??????* ??????*?@param?value?the?value?to?be?stored?in?the?current?threads'?copy?of ??????*????????this?thread-local. ??????*/??????public?void?set(T?value)?{ ??????????Thread?t?=?Thread.currentThread(); ??????????ThreadLocalMap?map?=?getMap(t); ??????????if?(map?!=?null) ??????????????map.set(this,?value); ??????????else??????????????createMap(t,?value); ??????} ????????/** ??????*?Get?the?map?associated?with?a?ThreadLocal.?Overridden?in ??????*?InheritableThreadLocal. ??????* ??????*?@param??t?the?current?thread ??????*?@return?the?map ??????*/??????ThreadLocalMap?getMap(Thread?t)?{ ??????????return?t.threadLocals; ??????} ????????/** ??????*?Create?the?map?associated?with?a?ThreadLocal.?Overridden?in ??????*?InheritableThreadLocal. ??????* ??????*?@param?t?the?current?thread ??????*?@param?firstValue?value?for?the?initial?entry?of?the?map ??????*?@param?map?the?map?to?store. ??????*/??????void?createMap(Thread?t,?T?firstValue)?{ ??????????t.threadLocals?=?new?ThreadLocalMap(this,?firstValue); ??????} ????????....... ????????/** ??????*?ThreadLocalMap?is?a?customized?hash?map?suitable?only?for ??????*?maintaining?thread?local?values.?No?operations?are?exported ??????*?outside?of?the?ThreadLocal?class.?The?class?is?package?private?to ??????*?allow?declaration?of?fields?in?class?Thread.??To?help?deal?with ??????*?very?large?and?long-lived?usages,?the?hash?table?entries?use ??????*?WeakReferences?for?keys.?However,?since?reference?queues?are?not ??????*?used,?stale?entries?are?guaranteed?to?be?removed?only?when ??????*?the?table?starts?running?out?of?space. ??????*/??????static?class?ThreadLocalMap?{ ????????........ ????????} ????}??

?

可以看到ThreadLocal类中的变量只有这3个int型：

Java代码

private?final?int?threadLocalHashCode?=?nextHashCode(); ??private?static?int?nextHashCode?=?0; ??private?static?final?int?HASH_INCREMENT?=?0x61c88647;??

?

而作为ThreadLocal实例的变量只有 threadLocalHashCode 这一个，nextHashCode 和HASH_INCREMENT 是ThreadLocal类的静态变量，实际上HASH_INCREMENT是一个常量，表示了连续分配的两个ThreadLocal实例的threadLocalHashCode值的增量，而nextHashCode 的表示了即将分配的下一个ThreadLocal实例的threadLocalHashCode 的值。

可以来看一下创建一个ThreadLocal实例即new ThreadLocal()时做了哪些操作，从上面看到构造函数ThreadLocal()里什么操作都没有，唯一的操作是这句：

Java代码

private?final?int?threadLocalHashCode?=?nextHashCode();??

?

那么nextHashCode()做了什么呢：

Java代码

private?static?synchronized?int?nextHashCode()?{ ??????int?h?=?nextHashCode; ??????nextHashCode?=?h?+?HASH_INCREMENT; ??????return?h; ??}??

?

就是将ThreadLocal类的下一个hashCode值即nextHashCode的值赋给实例的threadLocalHashCode，然后nextHashCode的值增加HASH_INCREMENT这个值。

因此ThreadLocal实例的变量只有这个threadLocalHashCode，而且是final的，用来区分不同的ThreadLocal实例，ThreadLocal类主要是作为工具类来使用，那么ThreadLocal.set()进去的对象是放在哪儿的呢？

看一下上面的set()方法，两句合并一下成为

Java代码

ThreadLocalMap?map?=?Thread.currentThread().threadLocals;??

?

这个ThreadLocalMap 类是ThreadLocal中定义的内部类，但是它的实例却用在Thread类中：

Java代码

public?class?Thread?implements?Runnable?{ ??????...... ????????/*?ThreadLocal?values?pertaining?to?this?thread.?This?map?is?maintained ??????*?by?the?ThreadLocal?class.?*/??????ThreadLocal.ThreadLocalMap?threadLocals?=?null;?? ??????...... ??}??

?

再看这句：

Java代码

if?(map?!=?null) ??????map.set(this,?value);??

?

也就是将该ThreadLocal实例作为key，要保持的对象作为值，设置到当前线程的ThreadLocalMap 中，get()方法同样大家看了代码也就明白了，ThreadLocalMap 类的代码太多了，我就不帖了，自己去看源码吧。