多線程與一致性
為了提高我們程序的性能珊拼，很多時候我們都會使用多線程以解決各種場景璃弄，但隨之而來的是多線程帶來的數(shù)據(jù)一致性問題該如何解決絮宁。
如何解決一致性問題？
- 排隊：如果多個線程操作‘同一份數(shù)據(jù)’科贬，那就排個隊吧资溃，一個一個來武翎，這樣后面一個線程總能得到最新的修改值，例如操作系統(tǒng)中的鎖溶锭，管程宝恶，屏障等都是這種排隊機(jī)制。<ins style="box-sizing: border-box;">缺點是：性能低趴捅。</ins>
- 投票：投票的機(jī)制就是多個人同時決策一件事垫毙，這個就涉及到了算法，往往會產(chǎn)生很多其他問題驻售，比如欺詐
- 避免：直觀意思就是避免多個線程之間產(chǎn)生一致性問題露久，那該如何去做呢更米？例如git欺栗，ThreadLocal正是采用的這種避免的方式來完成多線程的執(zhí)行
ThreadLocal定義：
定義：ThreadLocal提供了線程局部變量，一個線程局部變量在多個線程中分別由獨立的值（副本）征峦。
提問：既然是每個線程獨有的迟几，為什么不直接在調(diào)用線程的時候，在相應(yīng)的線程方法里聲明這個局部變量呢栏笆？
答：同一個線程可能會調(diào)用到很多不同的類和方法类腮，這樣就要在不同的地方用到這個變量，自己去實現(xiàn)蛉加，代價太大蚜枢，用ThreadLocal更加方便缸逃，且線程安全。
線程模型
對應(yīng)每個線程來說都有自己的獨占數(shù)據(jù)厂抽，這些數(shù)據(jù)事進(jìn)行來分配的需频，每個線程都有一個ThreadLocalMap對象，它本身是一個hash表筷凤，里面會放一些線程的局部變量昭殉，而ThreadLocal的核心也是這個ThreadLocalMap。
4種核心應(yīng)用場景
1.資源持有：
例如有三個不同的類藐守，在一次web請求中調(diào)用這三個類挪丢，但是用戶是一個，那么用戶數(shù)據(jù)就可以保存在一個線程里卢厂。 如圖：
2.線程一致：
例如JDBC事務(wù)乾蓬，我們每次對數(shù)據(jù)庫操作都會走getConnection，jdbc保證只要你是同一個線程過來的請求足淆，不管是哪一個part巢块，都返回的是同一個連接，就是使用ThreadLocal來做的巧号，達(dá)到維護(hù)一致性的目的族奢。Mybatis使用SqlSessionManager保證了我們同一個線程取出來的連接總是同一個。它是如何做到的呢丹鸿？其實很簡單越走，就是內(nèi)部使用了一個ThreadLocal。
3.線程安全：
如果一個線程的調(diào)用鏈路比較長靠欢，中間出現(xiàn)異常廊敌，那我們可以把出錯信息放在ThreadLocal里，然后在后續(xù)的鏈路中使用這個值门怪，可以達(dá)到多線程在處理這個場景的時候保證線程安全骡澈。
4.并發(fā)計算：
例如一個大的任務(wù)，拆分成多個小任務(wù)掷空，分別計算肋殴，最后再進(jìn)行結(jié)果匯總，那么我們可以把每個線程的計算結(jié)果放進(jìn)ThreadLocal中坦弟，最后進(jìn)行匯總計算护锤。 實現(xiàn)案例：比如需要統(tǒng)計一段時間內(nèi)某個接口的調(diào)用量
線程不安全實現(xiàn)：
@RestController
@RequestMapping("orders")
public class OrderController {
private Integer count = 0;
@GetMapping("/visit")
public Integer visit() throws InterruptedException {
count++;
Thread.sleep(100);
return 0;
}
@GetMapping("/stat")
public Integer stat() {
return count;
}
}
count++操作，首先我們是從內(nèi)存里面讀取原來的值酿傍，放在了線程本地內(nèi)存里烙懦。然后進(jìn)行 +1 操作，再寫回到內(nèi)存里赤炒。這個時候如果多個線程操作的話氯析，有可能線程A這邊還沒來得及寫亏较，線程B那邊讀取的是原來的值。這樣子的話就會造成數(shù)據(jù)不一致的問題掩缓。結(jié)果就會比預(yù)期的小宴杀。 結(jié)果明顯是count的值與我們所期望的值不一致
如何解決？
當(dāng)然方法很多拾因，比如加鎖旺罢，但今天我們要用ThreadLocal實現(xiàn)
@RestController
@RequestMapping("orders")
public class OrderController {
private static final ThreadLocal<Integer> TL = ThreadLocal.withInitial(() -> 0);
@GetMapping("/visit")
public Integer visit() throws InterruptedException {
Thread.sleep(100);
TL.set(TL.get() + 1);
return 0;
}
@GetMapping("/stat")
public Integer stat() {
return TL.get();
}
}
這樣即可達(dá)到我們的計數(shù)目的。
還有很多方法可以實現(xiàn)绢记，比如我們經(jīng)常用的原子類Automatic或者synchronized等扁达，他們的實現(xiàn)思想不同，加鎖和原子類使用的是【排隊】思想蠢熄，而ThreadLocal使用的是【避免】思想跪解，效率更高。
刮痧ThreadLocal源碼
API： ThreadLocal已經(jīng)支持泛型签孔，該類的類名已經(jīng)變?yōu)門hreadLocal<T>叉讥。API方法也相應(yīng)進(jìn)行了調(diào)整，新版本的API方法分別是void set(T value)饥追、T get()以及T initialValue()图仓。
1.set：
public void set(T value) {
//(1)獲取當(dāng)前線程（調(diào)用者線程）
Thread t = Thread.currentThread();
//(2)以當(dāng)前線程作為key值，去查找對應(yīng)的線程變量但绕，找到對應(yīng)的map
ThreadLocalMap map = getMap(t);
//(3)如果map不為null救崔，就直接添加本地變量，key為當(dāng)前線程捏顺，值為添加的本地變量值
if (map != null)
map.set(this, value);
//(4)如果map為null六孵，說明首次添加，需要首先創(chuàng)建出對應(yīng)的map
else
createMap(t, value);
}
ThreadLocalMap getMap(Thread t) {
return t.threadLocals; //獲取線程自己的變量threadLocals幅骄，并綁定到當(dāng)前調(diào)用線程的成員變量threadLocals上
}
void createMap(Thread t, T firstValue) {
t.threadLocals = new ThreadLocalMap(this, firstValue);
}
createMap方法不僅創(chuàng)建了threadLocals劫窒，同時也將要添加的本地變量值添加到了threadLocals中。
先拿到當(dāng)前的線程拆座，然后通過它去拿到一個Map主巍，如果這個Map存在，就把value塞進(jìn)去懂拾，否則就創(chuàng)建一個新的煤禽。
2.get：
public T get() {
//(1)獲取當(dāng)前線程
Thread t = Thread.currentThread();
//(2)獲取當(dāng)前線程的threadLocals變量
ThreadLocalMap map = getMap(t);
//(3)如果threadLocals變量不為null铐达，就可以在map中查找到本地變量的值
if (map != null) {
ThreadLocalMap.Entry e = map.getEntry(this);
if (e != null) {
@SuppressWarnings("unchecked")
T result = (T)e.value;
return result;
}
}
//(4)執(zhí)行到此處岖赋，threadLocals為null，調(diào)用該更改初始化當(dāng)前線程的threadLocals變量
return setInitialValue();
}
private T setInitialValue() {
//protected T initialValue() {return null;}
T value = initialValue();
//獲取當(dāng)前線程
Thread t = Thread.currentThread();
//以當(dāng)前線程作為key值瓮孙，去查找對應(yīng)的線程變量唐断，找到對應(yīng)的map
ThreadLocalMap map = getMap(t);
//如果map不為null选脊，就直接添加本地變量，key為當(dāng)前線程脸甘，值為添加的本地變量值
if (map != null)
map.set(this, value);
//如果map為null恳啥，說明首次添加，需要首先創(chuàng)建出對應(yīng)的map
else
createMap(t, value);
return value;
}
先通過getMap方法拿到當(dāng)前線程對應(yīng)的Map丹诀，然后從里面取出value钝的。如果沒有value，就調(diào)用ThreadLocal提供的初始化方法铆遭，初始化一個值硝桩。
3.remove：
public void remove() {
ThreadLocalMap m = getMap(Thread.currentThread());
if (m != null) {
m.remove(this);
}
}
private void remove(ThreadLocal<?> key) {
Entry[] tab = table;
int len = tab.length;
int i = key.threadLocalHashCode & (len-1);
for (Entry e = tab[i];
e != null;
e = tab[i = nextIndex(i, len)]) {
if (e.get() == key) {
e.clear();
expungeStaleEntry(i);
return;
}
}
}
我們在開發(fā)一個多線程的程序時，往往會使用線程池枚荣。而線程池的功能就是線程的復(fù)用碗脊。那如果線程池和ThreadLocal在一起就可能會造成問題，所以使用完ThreadLocal橄妆，顯式調(diào)用一下remove方法衙伶。
ThreadLocal不支持繼承性，ThreadLocal類是不能提供子線程訪問父線程的本地變量的害碾，而InheritableThreadLocal類則可以做到這個功能
public class InheritableThreadLocal<T> extends ThreadLocal<T> {
protected T childValue(T parentValue) {
return parentValue;
}
ThreadLocalMap getMap(Thread t) {
return t.inheritableThreadLocals;
}
void createMap(Thread t, T firstValue) {
t.inheritableThreadLocals = new ThreadLocalMap(this, firstValue);
}
}
關(guān)注微信公眾號：晏子噠噠
在刮痧技術(shù)路上矢劲，我們一同成長
