ThreadLocal原理解析
2017-05-19 13:35
274 查看
ThreadLocal从这个名字大概就能听出它是干啥的,差不多就是将一个变量绑定到一个线程上,解决一些并发问题并且使代码变得更优雅。
那它是怎么将变量绑定到线程上的呢?
我们先看Thread类源码,
Thread类里有一个ThreadLocalMap类,它是定义在ThreadLocal里的一个静态内部类。它类似一个map,每个ThreadLocal对象生成的哈希值作为键。
我们通过ThreadLocal获得当前线程的本地变量的过程大致是:先通过Thread.currentThread();获得当前线程,再获得这个线程内部的ThreadLocalMap,再以ThreadLocal自己为键获得本地变量的值。这个思想有点像访问者模式,多分派的思想,可以说设计的非常巧妙。
这里再提一个方法,
这个方法在get()方法被调用时,如果当前线程没有该本地变量需要生成一个时,可以覆盖该方法。
下面结合线程池举个栗子:
线程池使用可以看看这篇博客:http://cuisuqiang.iteye.com/blog/2019372
package ThreadLocal;
/**
* Created by 10033 on 2017/5/19.
*/
public class Session {
private boolean isclosed;
public Session() {
isclosed=false;
}
public boolean isClosed() {
return isclosed;
}
public void close() {
isclosed=true;
}
}
那它是怎么将变量绑定到线程上的呢?
我们先看Thread类源码,
/* ThreadLocal values pertaining to this thread. This map is maintained * by the ThreadLocal class. */ ThreadLocal.ThreadLocalMap threadLocals = null;
Thread类里有一个ThreadLocalMap类,它是定义在ThreadLocal里的一个静态内部类。它类似一个map,每个ThreadLocal对象生成的哈希值作为键。
我们通过ThreadLocal获得当前线程的本地变量的过程大致是:先通过Thread.currentThread();获得当前线程,再获得这个线程内部的ThreadLocalMap,再以ThreadLocal自己为键获得本地变量的值。这个思想有点像访问者模式,多分派的思想,可以说设计的非常巧妙。
这里再提一个方法,
protected T initialValue() { return null; }
这个方法在get()方法被调用时,如果当前线程没有该本地变量需要生成一个时,可以覆盖该方法。
下面结合线程池举个栗子:
线程池使用可以看看这篇博客:http://cuisuqiang.iteye.com/blog/2019372
package ThreadLocal;
/**
* Created by 10033 on 2017/5/19.
*/
public class Session {
private boolean isclosed;
public Session() {
isclosed=false;
}
public boolean isClosed() {
return isclosed;
}
public void close() {
isclosed=true;
}
}
package ThreadLocal; /** * Created by 10033 on 2017/5/19. */ public class SessionFactory { public static Session getSession() { return new Session(); } }
package ThreadLocal; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /** * Created by 10033 on 2017/5/19. */ public class ThreadLocalAndPoolTest { public ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3); public static void main(String[] args) { ThreadLocalAndPoolTest test=new ThreadLocalAndPoolTest(); for(int i=0;i<10;i++) { test.fixedThreadPool.execute(new MyThread()); } //关闭线程池 test.fixedThreadPool.shutdown(); } } class MyThread implements Runnable { public static ThreadLocal<Session> threadLocal=new ThreadLocal() { @Override protected Session initialValue() { return SessionFactory.getSession(); } }; @Override public void run() { System.out.println(Thread.currentThread().getName()+": "+threadLocal.get()); //每个线程用独自的变量 但用了线程池 所以当前线程结束时要清除变量 否则可能会有bug threadLocal.remove(); } }线程池结合线程本地变量时,要注意及时清除变量!!
相关文章推荐
- ThreadLocal原理解析(1):数据存取
- ThreadLocal---原理解析
- ThreadLocal原理解析
- android ThreadLocal的原理解析和用法
- ThreadLocal实现导图及其原理解析
- ThreadLocal原理解析(2):ThreadLocalMap源码解析
- Android消息机制之ThreadLocal原理解析
- ThreadLocal原理解析(2):ThreadLocalMap源码解析
- ThreadLocal原理解析(1):数据存取
- java基础解析系列(七)---ThreadLocal原理分析
- ThreadLocal原理深入解析
- ThreadLocal原理解析
- ThreadLocal 原理解析
- ThreadLocal使用及原理解析
- ThreadLocal原理解析
- ThreadLocal原理解析(1):数据存取
- ThreadLocal原理解析
- 图文解析TCP/IP 协议的结构与运行原理
- Vigor *** 备份功能原理解析
- 网站验证码的技术原理和实例解析