網(wǎng)站首頁 編程語言 正文
引言
相信很多人對這個問題不陌生,但是大家回答的都比較簡單,如談到app啟動流程有人就會是app的生命周期去了,談到消息機(jī)制有人就會說looper循環(huán)消息進(jìn)行分發(fā),如果是面試可能面試官不會滿意,今天我們搞一篇完善的源碼解析來進(jìn)行闡述上面的問題
1、第一步了解 ThreadLocal
什么是ThreadLocal呢,專業(yè)的來講,ThreadLocal 是一個線程內(nèi)部的數(shù)據(jù)存儲類,通過它可以在指定的線程中存儲數(shù)據(jù),數(shù)據(jù)存儲以后,只有再指定線程中可以獲取到存儲的數(shù)據(jù),對于其他線程來說則無法獲取到數(shù)據(jù),是共享數(shù)據(jù)變量存儲,通俗的來講,就是保存每個線程的數(shù)據(jù),肯定大家都沒聽懂,沒事的,接下來我們通過代碼來解釋ThreadLocal的具體作用
首先看一個例子
public static void main(String[] args) throws InterruptedException { ThreadLocal<String> threadLocal = new ThreadLocal<String>(){ @Override protected String initialValue() { return "data--1"; } }; System.out.println("1主線程--> "+threadLocal.get()); Thread t1 = new Thread(()->{ }); t1.start(); threadLocal.set("data--2"); System.out.println("2主線程--> "+threadLocal.get()); Thread t2 = new Thread(()->{ System.out.println("線程2---> "+threadLocal.get()); }); t2.start(); Thread t3 = new Thread(()->{ threadLocal.set("data-->3"); System.out.println("線程3---> "+threadLocal.get()); }); t3.start(); System.out.println("3主線程--> "+threadLocal.get()); Thread.sleep(1000); }
打印結(jié)果
1主線程--> ?data--1
2主線程--> ?data--2
線程2---> ?data--1
3主線程--> ?data--2
線程3---> ?data-->3
從上面的例子我們可以看到,ThreadLocal保存一個String這個變量,這個變量初始化會有一個值,在接下來的線程種,每個線程都會擁有一個初始值,這個初始值在主線程中,一旦這個初始值發(fā)生改變,如果是在主線程種改變?nèi)邕M(jìn)行set,則后面的子線程獲取的都是這個改變后的值,但是如果子線程種也改變了這個值,則只在當(dāng)前子線程種有此值 沒其子線程還是獲取的主線程種那個值,我們來簡單畫個圖給大家
ThreadLocal種的三個重要方法
//默認(rèn)情況下initialValue是返回為空的 protected T initialValue() { return null; } //在get的時候如果沒有調(diào)用set方法 getMap(t);是返回為空的,所以,返回的是setInitialValue(),這些方法請看后面的介紹,而setInitialValue方法返回的其實(shí)就是初始值 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(); } //這個方法在在調(diào)用的時候?qū)嶋H上getMap(t)是為空的,所以就會調(diào)用createMap,這個方法會把當(dāng)前的線程作為值,保證getMap再調(diào)用就不會為空 public void set(T value) { Thread t = Thread.currentThread(); ThreadLocalMap map = getMap(t); if (map != null) map.set(this, value); else createMap(t, value); }
private T setInitialValue() { T value = initialValue(); Thread t = Thread.currentThread(); ThreadLocalMap map = getMap(t); if (map != null) map.set(this, value); else createMap(t, value); return value; } public void remove() { ThreadLocalMap m = getMap(Thread.currentThread()); if (m != null) m.remove(this); } ThreadLocalMap getMap(Thread t) { return t.threadLocals; } void createMap(Thread t, T firstValue) { t.threadLocals = new ThreadLocalMap(this, firstValue); }
簡單來講,就是自己有的,用自己的,自己沒有就用初始化的,初始化改變了,后面的也改變,但是自己設(shè)置的,還是用自己的,就這么簡單,好了,接下來進(jìn)行下一步
2、App的啟動流程
我們看下Android的源碼
//這是main函數(shù)的入口 public static void main(String[] args) { Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, "ActivityThreadMain"); SamplingProfilerIntegration.start(); // CloseGuard defaults to true and can be quite spammy. We // disable it here, but selectively enable it later (via // StrictMode) on debug builds, but using DropBox, not logs. CloseGuard.setEnabled(false); Environment.initForCurrentUser(); // Set the reporter for event logging in libcore EventLogger.setReporter(new EventLoggingReporter()); // Make sure TrustedCertificateStore looks in the right place for CA certificates final File configDir = Environment.getUserConfigDirectory(UserHandle.myUserId()); TrustedCertificateStore.setDefaultUserDirectory(configDir); Process.setArgV0("<pre-initialized>"); Looper.prepareMainLooper(); ActivityThread thread = new ActivityThread(); thread.attach(false); if (sMainThreadHandler == null) { sMainThreadHandler = thread.getHandler(); } if (false) { Looper.myLooper().setMessageLogging(new LogPrinter(Log.DEBUG, "ActivityThread")); } // End of event ActivityThreadMain. Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER); Looper.loop(); throw new RuntimeException("Main thread loop unexpectedly exited"); }
我們重點(diǎn)看下 Looper.prepareMainLooper();
這個方法
/** * Initialize the current thread as a looper, marking it as an * application's main looper. The main looper for your application * is created by the Android environment, so you should never need * to call this function yourself. See also: {@link #prepare()} */ public static void prepareMainLooper() { prepare(false); synchronized (Looper.class) { if (sMainLooper != null) { throw new IllegalStateException("The main Looper has already been prepared."); } sMainLooper = myLooper(); } }
我們再點(diǎn)擊去看,myLooper
/** * Return the Looper object associated with the current thread. Returns * null if the calling thread is not associated with a Looper. */ public static @Nullable Looper myLooper() { return sThreadLocal.get(); }
很驚訝的看見了 sThreadLocal
,這里是調(diào)用get方法
// sThreadLocal.get() will return null unless you've called prepare(). static final ThreadLocal<Looper> sThreadLocal = new ThreadLocal<Looper>();
這里我們可以看到ThreadLocal保存的是Looper這個對象
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)); }
這里調(diào)用了set方法,創(chuàng)建了一個全局唯一的Looper
private Looper(boolean quitAllowed) { mQueue = new MessageQueue(quitAllowed); mThread = Thread.currentThread(); }
創(chuàng)建了一個全局唯一的主線程消息隊列
3、Activity中創(chuàng)建Handler
- 創(chuàng)建一個handler,重寫handleMessage方法
private Handler handler = new Handler(){ @Override public void handleMessage(Message msg) { super.handleMessage(msg); } };
- 發(fā)送消息
Message message = new Message(); handler.sendMessage(message); //點(diǎn)擊去 public final boolean sendMessage(Message msg) { return sendMessageDelayed(msg, 0); } //點(diǎn)擊去 public final boolean sendMessageDelayed(Message msg, long delayMillis) { if (delayMillis < 0) { delayMillis = 0; } return sendMessageAtTime(msg, SystemClock.uptimeMillis() + delayMillis); }
//繼續(xù)看sendMessageAtTime public boolean sendMessageAtTime(Message msg, long uptimeMillis) { MessageQueue queue = mQueue; if (queue == null) { RuntimeException e = new RuntimeException( this + " sendMessageAtTime() called with no mQueue"); Log.w("Looper", e.getMessage(), e); return false; } return enqueueMessage(queue, msg, uptimeMillis); } private boolean enqueueMessage(MessageQueue queue, Message msg, long uptimeMillis) { msg.target = this; if (mAsynchronous) { msg.setAsynchronous(true); } return queue.enqueueMessage(msg, uptimeMillis); }
//我們看到了enqueueMessage,我們看這個queue在哪里獲取的 public Handler(Callback callback, boolean async) { if (FIND_POTENTIAL_LEAKS) { final Class<? extends Handler> klass = getClass(); if ((klass.isAnonymousClass() || klass.isMemberClass() || klass.isLocalClass()) && (klass.getModifiers() & Modifier.STATIC) == 0) { Log.w(TAG, "The following Handler class should be static or leaks might occur: " + klass.getCanonicalName()); } } mLooper = Looper.myLooper(); if (mLooper == null) { throw new RuntimeException( "Can't create handler inside thread that has not called Looper.prepare()"); } mQueue = mLooper.mQueue; mCallback = callback; mAsynchronous = async; }
到這里我們明白了,也就是再app啟動后那個唯一的Queue,好了我們整理下Handler的消息機(jī)制
hander發(fā)送消息的時候,調(diào)用sendMessage方法,handler種會講消息放到全局的消息隊列中queue.enqueueMessage(msg, uptimeMillis)
接著就會在MessageQueue種賦值全局消息
消息處理
消息消費(fèi)
原文鏈接:https://juejin.cn/post/7134701583891169294
相關(guān)推薦
- 2024-03-02 uniapp封裝公共的方法或者數(shù)據(jù)請求方法
- 2022-10-14 sklearn.linear_model.Perceptron詳解
- 2023-07-02 解密Python中的作用域與名字空間_python
- 2022-08-01 詳解Python圖像形態(tài)學(xué)處理(開運(yùn)算,閉運(yùn)算,梯度運(yùn)算)_python
- 2021-10-01 Linux里L(fēng)VM磁盤擴(kuò)容詳細(xì)步驟_Linux
- 2022-07-21 查看JVM系統(tǒng)參數(shù)的默認(rèn)值
- 2022-05-29 Linux系統(tǒng)通過Docker安裝SQL?Server數(shù)據(jù)庫_docker
- 2022-06-25 Docker核心組件之聯(lián)合文件系統(tǒng)詳解_docker
- 最近更新
-
- window11 系統(tǒng)安裝 yarn
- 超詳細(xì)win安裝深度學(xué)習(xí)環(huán)境2025年最新版(
- Linux 中運(yùn)行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎(chǔ)操作-- 運(yùn)算符,流程控制 Flo
- 1. Int 和Integer 的區(qū)別,Jav
- spring @retryable不生效的一種
- Spring Security之認(rèn)證信息的處理
- Spring Security之認(rèn)證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權(quán)
- redisson分布式鎖中waittime的設(shè)
- maven:解決release錯誤:Artif
- restTemplate使用總結(jié)
- Spring Security之安全異常處理
- MybatisPlus優(yōu)雅實(shí)現(xiàn)加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務(wù)發(fā)現(xiàn)-Nac
- Spring Security之基于HttpR
- Redis 底層數(shù)據(jù)結(jié)構(gòu)-簡單動態(tài)字符串(SD
- arthas操作spring被代理目標(biāo)對象命令
- Spring中的單例模式應(yīng)用詳解
- 聊聊消息隊列,發(fā)送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠(yuǎn)程分支