Android HandlerThread案例詳解
HandlerThread 顧名思義就是一種可以使用 Handler 的 Thread。日常開發(fā)中我們經(jīng)常會通過創(chuàng)建一個 Thread 去執(zhí)行任務(wù),有多個任務(wù)就多創(chuàng)建幾個線程實現(xiàn),這時候可能出現(xiàn)線程同步的問題。不過有時候我們并不需要很強的并發(fā)性,只需保證按照順序地執(zhí)行各個任務(wù)即可,有什么好辦法實現(xiàn)呢?第一反應(yīng)想到的可能是通過 Executors.newSingleThreadExecutor() 方法來創(chuàng)建一個 SingleThreadExecutor,來統(tǒng)一所有的任務(wù)到一個線程中,然后按順序執(zhí)行。其實,除了這個方法之外,HandlerThread 也可以實現(xiàn)。
簡單使用首先創(chuàng)建一個 HandlerThreadActivity
public class HandlerThreadActivity extends BaseActivity {private static final String TAG = 'HandlerThreadActivity'; private Button mStartBtn; private Handler mHandler; private HandlerThread mHandlerThread; @Override protected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_handler_thread);mStartBtn = findViewById(R.id.start_btn);mHandlerThread = new HandlerThread('THREAD_NAME');mHandlerThread.start();mHandler = new Handler(mHandlerThread.getLooper());mStartBtn.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) {mHandler.post(new Runnable() { @Override public void run() {Log.d(TAG, Thread.currentThread().getId() + ' ' + String.valueOf((Looper.myLooper() == Looper.getMainLooper())) + ' 任務(wù):' + this.hashCode());SystemClock.sleep(3000); }}); }}); } @Override protected void onDestroy() {super.onDestroy();mHandlerThread.quit(); }}
快速三擊按鈕,打印日志如下:
可以發(fā)現(xiàn),三次不同的任務(wù)按開始的順序執(zhí)行,而且是運行在子線程中,那到底是怎么實現(xiàn)的呢?
源碼解析public class HandlerThread extends Thread { int mPriority; int mTid = -1; Looper mLooper; private @Nullable Handler mHandler; public HandlerThread(String name) {super(name);mPriority = Process.THREAD_PRIORITY_DEFAULT; } public HandlerThread(String name, int priority) {super(name);mPriority = priority; } protected void onLooperPrepared() { } @Override public void run() {// 獲取線程 idmTid = Process.myTid();//構(gòu)建一個 LooperLooper.prepare();synchronized (this) { mLooper = Looper.myLooper(); notifyAll();}//設(shè)置線程優(yōu)先級Process.setThreadPriority(mPriority);onLooperPrepared();Looper.loop();// Looper 循環(huán)mTid = -1; } // 獲取當前線程的 Looper, public Looper getLooper() {if (!isAlive()) { return null;} synchronized (this) { while (isAlive() && mLooper == null) {try { wait();} catch (InterruptedException e) {} }}return mLooper; } /** * @return a shared {@link Handler} associated with this thread * @hide 方法隱藏掉,無法調(diào)用 */ @NonNull public Handler getThreadHandler() {if (mHandler == null) { mHandler = new Handler(getLooper());}return mHandler; } //線程退出方法,主要是調(diào)用 Looper.quit() 方法,不然一直在循環(huán) public boolean quit() {Looper looper = getLooper();if (looper != null) { looper.quit(); return true;}return false; } //同上,不過這個方法會把消息隊列中的已有消息處理完才會安全地退出 public boolean quitSafely() {Looper looper = getLooper();if (looper != null) { looper.quitSafely(); return true;}return false; } public int getThreadId() {return mTid; }}
通讀下來,如果熟悉 Handler 原理的同學大概就明白 HandlerThread 的機制了:
HandlerThread 運行 start() 方法,回調(diào) run() 方法。 在 run() 方法中通過 Looper.prepare() 來創(chuàng)建消息隊列,并通過 Looper.looper() 方法來開啟消息循環(huán)。 由于 Loop.loop() 是一個死循環(huán),導(dǎo)致 run() 也是無線循環(huán),因此當我們不需要使用 HandlerThread 的時候,要調(diào)用它的 quit() 方法或者 quiteSafely() 方法。到此這篇關(guān)于Android HandlerThread案例詳解的文章就介紹到這了,更多相關(guān)Android HandlerThread內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)!
相關(guān)文章:
