在閱讀JTA源碼的時(shí)候,看到事務(wù)管理器的是有,遇到這樣一段代碼。
// 此處 transactionHolder 用于將 Transaction 所代表的事務(wù)對象關(guān)聯(lián)到線程上
private static ThreadLocal<TransactionImpl> transactionHolder
= new ThreadLocal<TransactionImpl>();
//TransacationMananger 必須維護(hù)一個(gè)全局對象,因此使用單實(shí)例模式實(shí)現(xiàn)
private static TransactionManagerImpl singleton = new TransactionManagerImpl();
private TransactionManagerImpl(){
}
public static TransactionManagerImpl singleton(){
return singleton;
}
public void begin() throws NotSupportedException, SystemException {
//XidImpl 實(shí)現(xiàn)了 Xid 接口,其作用是唯一標(biāo)識一個(gè)事務(wù)
XidImpl xid = new XidImpl();
// 創(chuàng)建事務(wù)對象,并將對象關(guān)聯(lián)到線程
TransactionImpl tx = new TransactionImpl(xid);
transactionHolder.set(tx);
}
其中的TheadLocal引起了我的注意。
通過查閱資料得知。
TheadLocal,是一種用來處理并發(fā)的方式。
應(yīng)用場景:
在多個(gè)線程同時(shí)使用一個(gè)變量的時(shí)候,多個(gè)線程會對同一個(gè)變量的值都產(chǎn)生影響,這是在高并發(fā)情況下經(jīng)常出現(xiàn)的問題。
我們常用的處理方式是加“同步鎖”,使用synchronized 方法來保證同一時(shí)間段只能有一個(gè)線程能使用該變量。
這只是一種處理方式,還有一種處理方式,拷貝多份變量,讓每一個(gè)線程使用的都是自己獨(dú)有的一個(gè)對象。
下面簡單介紹一個(gè)ThreadLocal。
TheadLocal的大概含義就是:維護(hù)了一個(gè)Map,讓線程作為Map的key,讓我們使用的變量作為Map的value,從而實(shí)現(xiàn)了每個(gè)線程單獨(dú)享用自己的變量。
ThreadLocal 最主要使用的就四個(gè)方法:
1. protected T initialValue() {
return null;
}
這個(gè)是最最重要的,同時(shí)我們也注意到它是一個(gè)protected方法,也就是專門用來被子類繼承的。(注意,protected方法,不能被類自己的對象,也不能被子類的對象直接調(diào)用。)
這個(gè)方法的會被內(nèi)部的get()方法調(diào)用在于,當(dāng)我們使用 get方法獲取當(dāng)前線程內(nèi)的變量發(fā)現(xiàn)為Null的時(shí)候,就會調(diào)用這個(gè)方法。(這也相當(dāng)于懶加載的一個(gè)實(shí)際應(yīng)用。)
2.get()方法的代碼如下,該方法獲取線程獨(dú)享的變量。
public T get() {
Thread t = Thread.currentThread();
ThreadLocalMap 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();
}
3.set()方法,這是用來改變當(dāng)前線程的變量的值用的,和HasHmap中的put(key,value)方法類似,只不過由于key都是當(dāng)前的線程,所以就省略了。
代碼如下:
public void set(T value) {
Thread t = Thread.currentThread();
ThreadLocalMap map = getMap(t);
if (map != null)
map.set(this, value);
else
createMap(t, value);
}
4.remove()方法
銷毀當(dāng)前線程里的value值。不用的時(shí)候銷毀,這樣也就能省一些資源。
代碼如下:
public void remove() {
ThreadLocalMap m = getMap(Thread.currentThread());
if (m != null)
m.remove(this);
}
關(guān)于為什么這里能夠真正的釋放掉變量的內(nèi)存,這里其實(shí)很有意思。
看代碼的時(shí)候我們發(fā)現(xiàn),這個(gè)Map中所保存的entru對象是一個(gè)弱引用。
static class Entry extends WeakReference<ThreadLocal<?>> {
/** The value associated with this ThreadLocal. */
Object value;
Entry(ThreadLocal<?> k, Object v) {
super(k);
value = v;
}
}
這也算是我第一次看見弱引用的使用實(shí)例。
http://blog.csdn.net/lufeng20/article/details/24314381
這篇文章有一個(gè)例子,可以幫助理解ThreaLocal。
ps:關(guān)于 強(qiáng)引用 、軟引用、弱引用、虛引用的知識,請參考JVM虛擬機(jī)。