一、ThreadLocal的简单使用
ThreadLocal是一个线程的局部变量,只有当前线程可以访问,所以是线程安全的。
邀你观看下边代码,你觉得会有问题吗?
//主要任务完成日期的转换private static final SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");public static class ParseDate implements Runnable{int i=0;public ParseDate(int i){this.i=i;}@Overridepublic void run() {try {Date t=sdf.parse("2015-03-29 19:29:"+i%60);System.out.println(i+":"+t);} catch (ParseException e) {e.printStackTrace();}}}public static void main(String[] args) {ExecutorService es=Executors.newFixedThreadPool(10);//通过线程执行不同的Runnable,但是Runnable使用的是同一个SimpleDateFormatfor(int i=0;i<1000;i++){es.execute(new ParseDate(i));}es.shutdown();}
如果你发现了问题,是不是考虑到了SimpleDateFormat 类的parse()方法不是线程安全的,所以程序运行过程中,可能会报错。
或许你会想到在parse方法前后加锁,这也是一种可行的方法。今天我们来学习使用新的技能ThreadLocal。
static ThreadLocal<SimpleDateFormat> t1=new ThreadLocal<SimpleDateFormat>();public static class ParseDate implements Runnable{int i=0;public ParseDate(int i){this.i=i;}@Overridepublic void run() {try {//如果当前线程没有SimpleDateFormat实例,则为当前线程创建。否则,直接获取。if(t1.get()==null){t1.set(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));}Date t=t1.get().parse("2015-03-29 19:29:"+i%60);System.out.println(i+":"+t);} catch (ParseException e) {e.printStackTrace();}}}
为每一个线程分配不同的对象,需要在应用层面保证。ThreadLocal起到了简单的容器作用。
二、ThreadLocal的实现原理
我们主要来学习ThreadLocal的set()和get()方法。
1、set()方法。
public void set(T value) {//获取当前线程Thread t = Thread.currentThread();//获取于当前线程有关的ThreadLocalMap对象实例ThreadLocalMap map = getMap(t);//如果不为空则设置值,如果为空则创建且设置值。if (map != null)map.set(this, value);elsecreateMap(t, value);}void createMap(Thread t, T firstValue) {t.threadLocals = new ThreadLocalMap(this, firstValue);}
ThreadLocalMap可以理解为一个map,它是定义在Thread内部的成员,但是ThreadLocal的静态内部类。
Thread类中有如下定义:
ThreadLocal.ThreadLocalMap threadLocals = null;
2、get():获取与当前线程相关的对象
public T get() {//获取当前线程Thread t = Thread.currentThread();//获取当前线程的mapThreadLocalMap map = getMap(t);if (map != null) {ThreadLocalMap.Entry e = map.getEntry(this);if (e != null) {@SuppressWarnings("unchecked")T result = (T)e.value;return result;}}return setInitialValue();}
三、ThreadLocal回收机制
1、Thread.exit()
变量维护在Thread类内部的(因为Thread类内部有ThreadLocalMap对象),所以线程不退出,对象的引用将一直存在。当线程退出后,Thread类会进行一些清理工作,其中,包括对ThreadLocalMap的清理。
private void exit() {....../* Speed the release of some of these resources */threadLocals = null;......}
2、ThreadLocalMap
//实现了ThreadLocal的弱引用static class Entry extends WeakReference<ThreadLocal<?>> {/** The value associated with this ThreadLocal. */Object value;Entry(ThreadLocal<?> k, Object v) {super(k);value = v;}}
ThreadLocal的外部引用被回收时候,那么ThreadLocalMap中的key就会变成null。当系统进行ThreadLocalMap清理时,就会自然将这些垃圾数据回收。