您好,登錄后才能下訂單哦!
ThreadLocal
前言:
ThreadLocal很容易讓人望文生義,想當然地認為是一個“本地線程”。其實,ThreadLocal并不是一個Thread,ThreadLocal是一個線程內部的數據存儲類,通過它可以在指定的線程中存儲數據,數據存儲以后,只有在指定線程中可以獲取到存儲的數據,對于其它線程來說無法獲取到數據。設計初衷就是:提供線程內部的局部變量,在本線程內隨時可取,而隔離了其他線程。
private static void prepare(boolean quitAllowed) { if (sThreadLocal.get() != null) { throw new RuntimeException("Only one Looper may be created per thread"); } sThreadLocal.set(new Looper(quitAllowed)); }
這段代碼就是在初始化Looper的時候會執行到的方法,這里也可以看出,一個looper只能對應一個thread。
public void set(T value) { Thread currentThread = Thread.currentThread(); Values values = values(currentThread); if (values == null) { values = initializeValues(currentThread); } values.put(this, value); }
looper創建時調用了ThreadLocal類中的set方法,這里,首先獲取到當前的線程,然后,將線程通過values的方法得到當前線程的Values,而Values類是ThreadLocal中的一個嵌套類,用來存儲不同thread的信息。
/** * Gets Values instance for this thread and variable type. */ Values values(Thread current) { return current.localValues; }
在Thread類中有這么一段:
/** * Normal thread local values. */ ThreadLocal.Values localValues;
所以從上面我們了解到set方法把當前thread中的localValues獲取到,然后用得到的values將當前的this和傳進來的Looper進行put操作:
/** * Sets entry for given ThreadLocal to given value, creating an * entry if necessary. */ void put(ThreadLocal<?> key, Object value) { cleanUp(); // Keep track of first tombstone. That's where we want to go back // and add an entry if necessary. int firstTombstone = -1; for (int index = key.hash & mask;; index = next(index)) { Object k = table[index]; if (k == key.reference) { // Replace existing entry. table[index + 1] = value; return; } if (k == null) { if (firstTombstone == -1) { // Fill in null slot. table[index] = key.reference; table[index + 1] = value; size++; return; } // Go back and replace first tombstone. table[firstTombstone] = key.reference; table[firstTombstone + 1] = value; tombstones--; size++; return; } // Remember first tombstone. if (firstTombstone == -1 && k == TOMBSTONE) { firstTombstone = index; } } }
這段代碼的意思就是將傳進來的looper對象保存在了Values類中的table成員變量中,保存的下標是在[index+1]里,table是一個Object[]的數組。最后看看對應的get方法:
public T get() { // Optimized for the fast path. Thread currentThread = Thread.currentThread(); Values values = values(currentThread); if (values != null) { Object[] table = values.table; int index = hash & values.mask; if (this.reference == table[index]) { return (T) table[index + 1]; } } else { values = initializeValues(currentThread); } return (T) values.getAfterMiss(this); }
首先獲取到當前線程,然后去取當前線程的Values值,如果值不空,先拿table數組,再得到此values的下標,最后返回此下標對應的table[]值。所以ThreadLocal我自己的理解是:不同的線程擁有不同的Values值,這個值統一在ThreadLocal類的table數組中,也就是說每個線程有自己的副本,在自己的副本里面讀寫信息互補干擾!
時間過得好快,轉眼一年了。整整快了一年沒怎么寫東西,說多了都是借口,沒有及時整理和沉淀,今年間是有點想法把自己平日寫的小demo總結下的,但總是忘記弄,后續得多鞭策下自己,寫點東西相當于自己做個筆記,把知識框架化,不對的地方請大神們多多指教!
如有疑問請留言或者到本站社區交流討論,感謝閱讀,希望能幫助到大家,謝謝大家對本站的支持!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。