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() {
// 獲取線程 id
mTid = Process.myTid();
//構(gòu)建一個 Looper
Looper.prepare();
synchronized (this) {
mLooper = Looper.myLooper();
notifyAll();
}
//設(shè)置線程優(yōu)先級
Process.setThreadPriority(mPriority);
onLooperPrepared();
Looper.loop();
// Looper 循環(huán)
mTid = -1;
}
// 獲取當(dāng)前線程的 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 原理的同學(xué)大概就明白 HandlerThread 的機制了:
- HandlerThread 運行 start() 方法馆揉,回調(diào) run() 方法业舍。
- 在 run() 方法中通過 Looper.prepare() 來創(chuàng)建消息隊列,并通過 Looper.looper() 方法來開啟消息循環(huán)升酣。
- 由于 Loop.loop() 是一個死循環(huán)舷暮,導(dǎo)致 run() 也是無線循環(huán),因此當(dāng)我們不需要使用 HandlerThread 的時候噩茄,要調(diào)用它的 quit() 方法或者 quiteSafely() 方法下面。
結(jié)束語
這就是 HandlerThread 的大概原理啦,它在 Android 中的一個具體的使用場景是 IntentService绩聘,有興趣了解 IntentService 的可以點擊這里沥割。
慣例附上--->Demo源碼<---