最早接触到ThreadLocal是在阅读dianping的Cat-client,当时对它不是很理解,就搜索了一下,大概了解是一种解决线程安全问题的机制。现在再次阅读《实战java高并发程序设计》时,又重新对它有了更深一步的了解。
最早接触到ThreadLocal是在阅读dianping的Cat-client,当时对它不是很理解,就搜索了一下,大概了解是一种解决线程安全问题的机制。现在再次阅读《实战java高并发程序设计》时,又重新对它有了更深一步的了解。
并发程序很重要的主题就是解决多线程安全的问题,最常见的处理办法就是引入锁的机制;但是锁使得各个线程对临界区的使用效率变差,于是有了一种新的思路,即每个线程独立管理某个变量,变量的修改在线程中时独立的。就好比,以前锁的机制是100个人签到,只有一个签字薄;而现在ThreadLocal是每个人一张纸。
不过上面的场景,只是threadLocal的一个应用场景。还有个例子,是在城市里面倒车。小明去上班要先做公交车在做地铁,如果每次坐车都买票,那么时间效率很差。于是小明办理了一张通用的公交卡,公交车和地铁都可以刷。而小蓝小红也有这样的公交卡,它们的公交卡彼此之间是独立的。这就是ThreadLocal的作用!
总结来说,threadLocal有两点作用:
- 多个线程之间独立
- 单个线程对某个变量随时随地使用
那么它的原理时什么样的呢?
说白了,就是每个线程自己有一个Map,这个Map采用了线性探测法来存储变量。接下来主要阅读下代码吧:1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25public T get() {
Thread t = Thread.currentThread();
// 获取当前线程的localmap
ThreadLocalMap map = getMap(t);
if (map != null) {
// 用当前的变量作为key查询对象
ThreadLocalMap.Entry e = map.getEntry(this);
if (e != null) {
"unchecked") (
T result = (T)e.value;
return result;
}
}
// 如果不存在的话,初始化变量
return setInitialValue();
}
public void set(T value) {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null)
map.set(this, value);
else
createMap(t, value);
}
主要时那个getEntry方法:1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29private Entry getEntry(ThreadLocal<?> key) {
// 通过当前key的hashcode与列表的长度做 &操作,判断存储的位置
int i = key.threadLocalHashCode & (table.length - 1);
Entry e = table[i];
if (e != null && e.get() == key)
return e;
else
// 如果不存在的话,进入getEntryAfterMiss方法
// 这种情况,可能是key被回收掉了;也可能是hash冲突了
return getEntryAfterMiss(key, i, e);
}
private Entry getEntryAfterMiss(ThreadLocal<?> key, int i, Entry e) {
Entry[] tab = table;
int len = tab.length;
// 这里是典型的线性地址探测法,如果当前有值,👎
while (e != null) {
ThreadLocal<?> k = e.get();
if (k == key)
return e;
if (k == null)
expungeStaleEntry(i);
else
i = nextIndex(i, len);
e = tab[i];
}
return null;
}