一个非线程安全的例子

package thread;

public class NotSafeThread implements Runnable{
    private int a=10;
    
    public void run() {
        // TODO Auto-generated method stub
        for (int i = 0; i < 5; i++) {

            try {
                if (Thread.currentThread().toString()
                        .equals("Thread[t2,5,main]")
                        && i == 2)
                    Thread.sleep(1000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

            System.out.println(Thread.currentThread().toString() + "   a="
                    + a++);
        }

    }
}

package thread;
public class TestThread {
    public static void main(String[] args) {
        NotSafeThread nst=new NotSafeThread();
        Thread t1=new Thread(nst,"t1");
        Thread t2=new Thread(nst,"t2");
        Thread t3=new Thread(nst,"t3");
        t1.start();
        t2.start();
        t3.start();
    }
}

ThreadLocal的简单介绍

第一个应用

public class SafaThread {
    private static ThreadLocal<Integer> counterContext=new ThreadLocal<Integer>();
    
    public static Integer getCounterContext(){
        if (counterContext.get()!=null)
            return counterContext.get();
        setCounterContext(10);
        return counterContext.get();
    }
    public static void setCounterContext(Integer value){
        counterContext.set(value);
    }

    public static Integer getCounterContextNext(){
        counterContext.set(getCounterContext()+1);
        return counterContext.get();
    }

}

package thread;

public class ThreadLocalTest extends Thread{
    public void run() {
        for (int i = 0; i < 5; i++)
            System.out.println(Thread.currentThread().getName()+"   a="+
            SafaThread.getCounterContextNext());
    }
    
    public static void main(String[] args) {
        ThreadLocalTest t=new ThreadLocalTest();
        Thread t1=new Thread(t);
        Thread t3=new Thread(t);
        Thread t2=new Thread(t);
        
        t1.start();
        t2.start();
        t3.start();
    }
}

    static class ThreadLocalMap {

        static class Entry extends WeakReference<ThreadLocal> {
            /** The value associated with this ThreadLocal. */
            Object value;

            Entry(ThreadLocal k, Object v) {
                super(k);
                value = http://www.mamicode.com/v;>

ThreadLocalMap里面还有一个静态类,也是醉了..静态类是Entry。
Entry里面存放的是当前的ThreadLocal和这个线程中的成员变量。
当前线程的成员变量?怎么来的?
看这个:
public class Thread implements Runnable {

    /* ThreadLocal values pertaining to this thread. This map is maintained
     * by the ThreadLocal class. */
    ThreadLocal.ThreadLocalMap threadLocals = null;
    ....//省略代码
    }
看到了吧,线程这个基类本身里面就有一个ThreadLocalMap。
好啦 现在我们开启debug模式。
System.out.println(Thread.currentThread().getName()+"   a="+
        SafaThread.getCounterContextNext());
ok,进去
    public static Integer getCounterContextNext(){
        counterContext.set(getCounterContext()+1);
        return counterContext.get();
    }
最先执行的是getCounterContext()。
    public static Integer getCounterContext(){
        if (counterContext.get()!=null)
            return counterContext.get();
        setCounterContext(10);
        return counterContext.get();
    }
我们看看counterContext(它本身是ThreadLocal<Integer>)的get方法。如下:
    public T get() {
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);   //标注1
        if (map != null) {
            ThreadLocalMap.Entry e = map.getEntry(this); //标注3
            if (e != null)
                return (T)e.value;
        }
        return setInitialValue();
    }
    ThreadLocalMap getMap(Thread t) {
        return t.threadLocals;
    }
当我们第一次调用SafaThread.getCounterContextNext()的时候,直到上面的标注1处,返回的map肯定为空。我们看看setInitialValue
    private T setInitialValue() {
        T value = http://www.mamicode.com/initialValue();     //标注2>至于creatMap里面的代码
    void createMap(Thread t, T firstValue) {
        t.threadLocals = new ThreadLocalMap(this, firstValue);
    }
我们再看看ThreadLocalMap的构造函数。你妹呀,你想累死老子,都最后一步了,自己看!
看看上面的标注2
    protected T initialValue() {
        return null;
    }
现在我们看看,看看什么?看ThreadLocal的set方法。中间的我不讲了。太累了。
    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一样是吧。
这下大家都明白了吧。
我说几个关键点
ThreadLocalMap里面有个Entry数组,数组里面放的元素由两部分组成
        static class Entry extends WeakReference<ThreadLocal> {
            /** The value associated with this ThreadLocal. */
            Object value;

            Entry(ThreadLocal k, Object v) {
                super(k);
                value = http://www.mamicode.com/v;>key是ThreadLocal,value是要存储的值。
key为什么不是当前线程?而是ThreadLocal呢?
自己想。想不明白再问我。
在上面的情况下,一个线程里的ThreadLocalMap的Entry的size只能是1。
为什么?看ThreadLocal的set方法。

一个问题
public class SafaThread {
    private static ThreadLocal<Integer> counterContext=new ThreadLocal<Integer>();
    private static ThreadLocal<Integer> counterContext2=new ThreadLocal<Integer>();
    ...//省略其他代码 本来有三个方法 现在就是六个
}
本来只有一个变量,我现在放两个。
会怎么样。
答案就是:
key为什么不是线程?而是ThreadLocal呢?
Entry各个元素的区别到底在哪?
标注3的this是什么?
亲 你懂了没?
好吧,我偷的一手好懒。

下一个应用
我们看看struts中是如何运用ThreadLocal的。
感谢glt

总结
ThreadLocal最适合使用的场景:
在同一个线程的不同开发层次共享数据
使用ThreadLocal的步骤
1建立一个类,在其中封装静态的ThreadLocal变量,使其成为一个数据共享环境
2在类中实现ThreadLoca变量的静态方法(设值与取值)

参考资料
先看a再看b
a:  http://lavasoft.blog.51cto.com/62575/51926/
b:  http://blog.csdn.net/lufeng20/article/details/24314381struts2技术内幕
c:  struts2技术内幕  4.1节
深入理解ThreadLocal