這期內(nèi)容當中小編將會給大家?guī)碛嘘P(guān)Android中HandlerThread如何使用,文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。
專注于為中小企業(yè)提供成都網(wǎng)站設(shè)計、做網(wǎng)站服務(wù),電腦端+手機端+微信端的三站合一,更高效的管理,為中小企業(yè)麻山免費做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都,凝聚了一批互聯(lián)網(wǎng)行業(yè)人才,有力地推動了上千余家企業(yè)的穩(wěn)健成長,幫助中小企業(yè)通過網(wǎng)站建設(shè)實現(xiàn)規(guī)模擴充和轉(zhuǎn)變。
一.HandlerThread的使用步驟
1.創(chuàng)建實例對象
HandlerThread handlerThread = new HandlerThread("downloadImage");
參數(shù)的作用主要是標記當前線程的名字,可以任意字符串。
2.啟動HandlerThread線程
//必須先開啟線程 handlerThread.start();
到此,我們就構(gòu)建完一個循環(huán)線程。那么我們怎么將一個耗時的異步任務(wù)投放到HandlerThread線程中去執(zhí)行呢?接下來看下面步驟:
3.構(gòu)建循環(huán)消息處理機制
/** * 該callback運行于子線程 */ class ChildCallback implements Handler.Callback { @Override public boolean handleMessage(Message msg) { //在子線程中進行相應(yīng)的網(wǎng)絡(luò)請求 //通知主線程去更新UI mUIHandler.sendMessage(msg1); return false; } }
構(gòu)建異步handler
/** * 該callback運行于子線程 */ class ChildCallback implements Handler.Callback { @Override public boolean handleMessage(Message msg) { //在子線程中進行相應(yīng)的網(wǎng)絡(luò)請求 //通知主線程去更新UI mUIHandler.sendMessage(msg1); return false; } }
第3步是構(gòu)建一個可以用于異步操作的handler,并將前面創(chuàng)建的HandlerThread的Looper對象和Callback接口類作為參數(shù)傳遞給當前的handler,這樣當前的異步handler就擁有了HandlerThread的Looper對象,而其中的handlerMessage方法來處理耗時任務(wù),Looper+Handler+MessageQueue+Thread異步循環(huán)機制構(gòu)建完成。下面我們來看一個使用案例
二.HandlerThread的使用案例
package com.zejian.handlerlooper; import android.app.Activity; import android.graphics.Bitmap; import android.graphics.BitmapFactory; import android.os.Bundle; import android.os.Handler; import android.os.HandlerThread; import android.os.Message; import android.widget.ImageView; import com.zejian.handlerlooper.model.ImageModel; import com.zejian.handlerlooper.util.LogUtils; import java.io.BufferedInputStream; import java.io.IOException; import java.net.HttpURLConnection; import java.net.URL; /** * Created by zejian on 16/3/5. */ public class HandlerThreadActivity extends Activity { /** * 圖片地址集合,圖片來自網(wǎng)絡(luò). */ private String url[]={ "http://img.my.csdn.net/uploads/201407/26/1406383299_1976.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383291_6518.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383291_8239.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383290_9329.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383290_1042.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383275_3977.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383265_8550.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383264_3954.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383264_4787.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383264_8243.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383248_3693.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383243_5120(1).jpg", "http://img.my.csdn.net/uploads/201407/26/1406383242_3127.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383242_9576.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383242_1721.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383219_5806.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383214_7794.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383213_4418.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383213_3557.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383210_8779.jpg", "http://img.my.csdn.net/uploads/201407/26/1406383172_4577.jpg" }; private ImageView imageView; private Handler mUIHandler = new Handler(){ @Override public void handleMessage(Message msg) { LogUtils.e("次數(shù):"+msg.what); ImageModel model = (ImageModel) msg.obj; imageView.setImageBitmap(model.bitmap); } }; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_handler_thread); imageView= (ImageView) findViewById(R.id.image); //創(chuàng)建異步HandlerThread HandlerThread handlerThread = new HandlerThread("downloadImage"); //必須先開啟線程 handlerThread.start(); //子線程Handler Handler childHandler = new Handler(handlerThread.getLooper(),new ChildCallback()); for(int i=0;i<10;i++){ //每個1秒去更新圖片 childHandler.sendEmptyMessageDelayed(i,1000*i); } } /** * 該callback運行于子線程 */ class ChildCallback implements Handler.Callback { @Override public boolean handleMessage(Message msg) { //在子線程中進行網(wǎng)絡(luò)請求 Bitmap bitmap=downloadUrlBitmap(url[msg.what]); ImageModel imageModel=new ImageModel(); imageModel.bitmap=bitmap; imageModel.url=url[msg.what]; Message msg1 = new Message(); msg1.what = msg.what; msg1.obj =imageModel; //通知主線程去更新UI mUIHandler.sendMessage(msg1); return false; } } private Bitmap downloadUrlBitmap(String urlString) { HttpURLConnection urlConnection = null; BufferedInputStream in = null; Bitmap bitmap=null; try { final URL url = new URL(urlString); urlConnection = (HttpURLConnection) url.openConnection(); in = new BufferedInputStream(urlConnection.getInputStream(), 8 * 1024); bitmap=BitmapFactory.decodeStream(in); } catch (final IOException e) { e.printStackTrace(); } finally { if (urlConnection != null) { urlConnection.disconnect(); } try { if (in != null) { in.close(); } } catch (final IOException e) { e.printStackTrace(); } } return bitmap; } }
思路分析:在這個案例中,我們創(chuàng)建了兩個Handler,一個用于更新UI線程的mUIHandler和一個用于異步下載圖片的childHandler。最終的結(jié)果是childHandler會每個隔1秒鐘通過sendEmptyMessageDelayed方法去通知ChildCallback的回調(diào)函數(shù)handleMessage方法去下載圖片并告訴mUIHandler去更新UI界面。運行截圖如下:
到此,HandlerThread的基本使用我們都有所了解了,接下來我們掰掰HandlerThread源碼,挖挖其實現(xiàn)原理。
三.HandlerThread源碼解析
HandlerThread的源碼不多只有140多行,我們一步一步來分析,先來看看其構(gòu)造函數(shù):
/** * Handy class for starting a new thread that has a looper. The looper can then be * used to create handler classes. Note that start() must still be called. */ public class HandlerThread extends Thread { int mPriority;//線程優(yōu)先級 int mTid = -1; Looper mLooper;//當前線程持有的Looper對象 public HandlerThread(String name) { super(name); mPriority = Process.THREAD_PRIORITY_DEFAULT; } /** * Constructs a HandlerThread. * @param name * @param priority The priority to run the thread at. The value supplied must be from * {@link android.os.Process} and not from java.lang.Thread. */ public HandlerThread(String name, int priority) { super(name); mPriority = priority; } /** * Call back method that can be explicitly overridden if needed to execute some * setup before Looper loops. */ protected void onLooperPrepared() { }
從源碼可以很明顯的看出HandlerThread繼續(xù)自Thread,構(gòu)造函數(shù)也相當簡單傳遞參數(shù)有兩個,一個是name指的是線程的名稱,一個是priority指的是線程優(yōu)先級,我們根據(jù)需要調(diào)用即可。成員變量mLooper就是HandlerThread自己持有的Looper對象。onLooperPrepared()該方法是一個空實現(xiàn),是留給我們必要時可以去重寫的,但是重寫時機是在Looper循環(huán)啟動前。還記得我們在前面創(chuàng)建完HandlerThread后還要去調(diào)用start()方法后才可以去創(chuàng)建Handler嗎?這是為什么呢?接下來我們就來揭曉其中奧秘:
@Override public void run() { mTid = Process.myTid(); Looper.prepare(); synchronized (this) { mLooper = Looper.myLooper(); notifyAll(); //喚醒等待線程 } Process.setThreadPriority(mPriority); onLooperPrepared(); Looper.loop(); mTid = -1; }
這個是HandlerThread的run方法,代碼也比較簡單,開始就通過Looper.prepare()去創(chuàng)建Looper對象,然后通過同步線程去給當前成員變量mLooper賦值,并喚醒等待線程(后續(xù)會解析為什么要喚醒等待線程),然后在Looper.loop()循環(huán)啟動前調(diào)用了onLooperPrepared方法,到此Looper創(chuàng)建完成,循環(huán)線程也啟動完成?,F(xiàn)在我們也就明白了創(chuàng)建HandlerThread后為什么要調(diào)用start方法了,因為通過調(diào)用start方法,程序會去執(zhí)行run方法,這樣才會去創(chuàng)建Looper對象并啟動Looper循環(huán),最后我們才能把Looper對象傳遞給Handler實例。
public Looper getLooper() { if (!isAlive()) { return null; } // If the thread has been started, wait until the looper has been created. synchronized (this) { while (isAlive() && mLooper == null) { try { wait();//等待喚醒 } catch (InterruptedException e) { } } } return mLooper; }
這個方法名一看就知道是獲取looper對象的,雖然很簡單,但是這里有個地方還是要說明一下,方法開始后先去判斷當前線程是否是啟動狀態(tài),如果線程已經(jīng)啟動,再通過一個同步代碼塊去判斷當前成員變量mLooper是否為空,如果為空,那就wait(),直到mLooper創(chuàng)建完成,否則就返回mLooper對象,那么為什么會由可能為空呢?還記得前面的Looper對象是在哪里創(chuàng)建的嗎?沒錯,是在子線程,這樣我們就無法保障我們在調(diào)用getLooper方法時Looper已經(jīng)創(chuàng)建完成。因此在前面的run方法中當Looper創(chuàng)建完成后會調(diào)用notifyAll方法就是為了喚醒getLooper方法中的wait等待機制。
小結(jié):在獲取mLooper對象的時候存在一個同步的問題,只有當線程創(chuàng)建成功并且Looper對象也創(chuàng)建成功之后才能獲得mLooper的值。這里等待方法wait和run方法中的notifyAll方法共同完成同步問題。
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; }
上述就是小編為大家分享的Android中HandlerThread如何使用了,如果剛好有類似的疑惑,不妨參照上述分析進行理解。如果想知道更多相關(guān)知識,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。