Android開發(fā)高級進階
第一章學(xué)習(xí)
傳統(tǒng)多線程開發(fā)####
概要:
之前的文章里寫過了AsyncTask的一些坑贝搁,這次就不講它了,使用傳統(tǒng)的 Handler和Message來進行線程的使用誓竿,并且第一次添加了CallBack方式的接口進行回調(diào)操作
多線程
這概念并不需要多余的介紹了鳖擒,用法跟Java里沒什么不同
new Thread(new Runnable() {
@Override
public void run() {
// 處理具體的邏輯
}
}).start();
什么是UI線程球及,什么是工作線程:
Android中合愈,將其他線程和主線程(UI線程)進行了區(qū)分,由于Android的圖形界面總是伴隨著各種動畫效果颅湘,所以Android特地為UI自動開啟了主線程话侧,用于持續(xù)不斷的計算,且UI的操作必須在主線程里進行闯参,如果在主線程里進行了耗時操作瞻鹏,那就會出現(xiàn)ANR (Application Not Responding),此時鹿寨,多線程就非常必要了新博。
從子線程回調(diào)數(shù)據(jù)進行操作:
簡單的線程操作,只能控制他start脚草,一旦運行完畢了赫悄,無法進行返回,或者無法進行UI的操,接下來為解決這兩種問題埂淮,提供一些方法姑隅。
標準的線程間通訊是使用Handler+Message進行通訊的,當(dāng)然這種通訊畢竟能夠傳遞的參數(shù)非常有限倔撞,大致上只有int和object讲仰,非常少,某些時候用得并不順手痪蝇。
比如網(wǎng)絡(luò)連接的時候鄙陡,想要在聯(lián)網(wǎng)獲得Json文件后,立即調(diào)用另一個方法對此Json文件進行處理躏啰,此時可以引入回調(diào)的機制柔吼。
1.定義接口,是一個抽象方法
public interface HttpCallbackListener {
void onFinish(String response);
void onError(Exception e);
}
2.在聯(lián)網(wǎng)方法的傳入?yún)?shù)中丙唧,定義此接口
public static void sendHttpRequest(final String address, final HttpCallbackListener
listener) {
new Thread(new Runnable() {
@Override
public void run() {
HttpURLConnection connection = null;
try {
URL url = new URL(address);
connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
connection.setConnectTimeout(8000);
connection.setReadTimeout(8000);
connection.setDoInput(true);
connection.setDoOutput(true);
InputStream in = connection.getInputStream();
BufferedReader reader = new BufferedReader(new
InputStreamReader(in));
StringBuilder response = new StringBuilder();
String line;
while ((line = reader.readLine()) != null) {
response.append(line);
}
if (listener != null) {
// 回調(diào)onFinish()方法
listener.onFinish(response.toString());
}
} catch (Exception e) {
if (listener != null) {
// 回調(diào)onError()方法
listener.onError(e);
}
} finally {
if (connection != null) {
connection.disconnect();
}
}
}
}).start();
}
3.此時,其它地方調(diào)用此聯(lián)網(wǎng)方法時觅玻,將會需要重寫這個抽象方法
HttpUtil.sendHttpRequest(address, new HttpCallbackListener() {
@Override
public void onFinish(String response) {
// 在這里根據(jù)返回內(nèi)容執(zhí)行具體的邏輯
}
@Override
public void onError(Exception e) {
// 在這里對異常情況進行處理
}
});
完成了在不同的地方想际,都能在子線程中執(zhí)行到onFinish()方法時,進行回調(diào)溪厘,立即取得子線程的計算結(jié)果并執(zhí)行想要進行的操作胡本。
但是回調(diào)的同時,仍然還是子線程中畸悬,并不允許進行UI操作侧甫。
從子線程進行UI操作:
Android為子線程中進行UI操作提供了一些封裝方法:
- Activity.runOnUiThread(Runnable action)
如同字面意思般在工作線程中跳轉(zhuǎn)到UI線程進程操作 - View.post(Runnable action)
直接給控件添加線程操作,此處可以更新UI - View.postDelayed(Runnable action, long delayMillis)
方法2的延時版本 - new Handler(Looper.getMainLooper()).post(Runnable action)
獲取了主線程的Looper進行線程操作蹋宦,當(dāng)然可以更新UI
舉個栗子:
new Thread(new Runnable() {
@Override
public void run() {
runOnUiThread(new Runnable() {
@Override
public void run() {
mTestTextView.setText("賺錢好難");
}
});
}
}).start();
3個方法使用起來很類似披粟,不一一說明了。
多線程管理
線程池的操作
new Thread()的缺點
每次new Thread()耗費性能
調(diào)用new Thread()創(chuàng)建的線程缺乏管理冷冗,被稱為野線程守屉,而且可以無限制創(chuàng)建,之間相互競爭蒿辙,會導(dǎo)致過多占用系統(tǒng)資源導(dǎo)致系統(tǒng)癱瘓拇泛。
不利于擴展,比如如定時執(zhí)行思灌、定期執(zhí)行俺叭、線程中斷
采用線程池的優(yōu)點
重用存在的線程,減少對象創(chuàng)建泰偿、消亡的開銷熄守,性能佳
可有效控制最大并發(fā)線程數(shù),提高系統(tǒng)資源的使用率,同時避免過多資源競爭柠横,避免堵塞
提供定時執(zhí)行窃款、定期執(zhí)行、單線程牍氛、并發(fā)數(shù)控制等功能
Executor
android中線程池的概念來源于java中的Executor, 線程池真正的實現(xiàn)類是ThreadPoolExecutor晨继,它間接實現(xiàn)了Executor接口。
Executor接口只有一個方法execute()搬俊,該方法用來執(zhí)行線程中的操作紊扬。
Executor executor = new MyExecutor();
executor.execute(new RunnableTaskOne());
executor.execute(new RunnableTaskTwo());
ThreadPoolExecutor提供了一系列參數(shù)來配置線程池,通過不同的參數(shù)配置實現(xiàn)不同功能特性的線程池唉擂,android中的Executors類提供了4個工廠方法用于創(chuàng)建4種不同特性的線程池給開發(fā)者用.
newFixedThreadPool
創(chuàng)建一個可重用固定線程數(shù)的線程池餐屎,以共享的無界隊列方式來運行這些線程。
ExecutorService executorService = Executors.newFixedThreadPool(5);
for (int i = 0; i < 20; i++) {
Runnable syncRunnable = new Runnable() {
@Override
public void run() {
Log.e(TAG, Thread.currentThread().getName());
}
};
executorService.execute(syncRunnable);
}
運行結(jié)果:總共只會創(chuàng)建5個線程玩祟, 開始執(zhí)行五個線程腹缩,當(dāng)五個線程都處于活動狀態(tài),再次提交的任務(wù)都會加入隊列等到其他線程運行結(jié)束空扎,當(dāng)線程處于空閑狀態(tài)時會被下一個任務(wù)復(fù)用
特點:只有核心線程數(shù)藏鹊,并且沒有超時機制,因此核心線程即使閑置時转锈,也不會被回收盘寡,因此能更快的響應(yīng)外界的請求.
newCachedThreadPool
創(chuàng)建一個可緩存線程池,如果線程池長度超過處理需要撮慨,可靈活回收空閑線程
ExecutorService executorService = Executors.newCachedThreadPool(5);
for (int i = 0; i < 100; i++) {
Runnable syncRunnable = new Runnable() {
@Override
public void run() {
Log.e(TAG, Thread.currentThread().getName());
}
};
executorService.execute(syncRunnable);
}
運行結(jié)果:緩存線程池大小是不定值竿痰,可以需要創(chuàng)建不同數(shù)量的線程,在使用緩存型池時砌溺,先查看池中有沒有以前創(chuàng)建的線程影涉,如果有,就復(fù)用.如果沒有规伐,就新建新的線程加入池中常潮,緩存型池子通常用于執(zhí)行一些生存期很短的異步型任務(wù)
特點:沒有核心線程,非核心線程數(shù)量沒有限制楷力, 超時為60秒.
newScheduledThreadPool
創(chuàng)建一個定長線程池喊式,支持定時及周期性任務(wù)執(zhí)行
schedule(Runnable command,long delay, TimeUnit unit)創(chuàng)建并執(zhí)行在給定延遲后啟用的一次性操作
ExecutorService executorService = Executors.newScheduledThreadPool(5);
for (int i = 0; i < 200; i++) {
Runnable syncRunnable = new Runnable() {
@Override
public void run() {
Log.e(TAG, Thread.currentThread().getName());
}
};
executorService.schedule(syncRunnable, 5000, TimeUnit.MILLISECONDS);
}
特點:核心線程數(shù)是固定的,非核心線程數(shù)量沒有限制萧朝, 沒有超時機制.主要用于執(zhí)行定時任務(wù)和具有固定周期的重復(fù)任務(wù).
SingleThreadExecutor
創(chuàng)建一個單線程化的線程池岔留,它只會用唯一的工作線程來執(zhí)行任務(wù),保證所有任務(wù)按照指定順序(FIFO, LIFO, 優(yōu)先級)執(zhí)行
ExecutorService executorService = Executors.newScheduledThreadPool(5);
for (int i = 0; i < 200; i++) {
Runnable syncRunnable = new Runnable() {
@Override
public void run() {
Log.e(TAG, Thread.currentThread().getName());
}
};
executorService.execute(syncRunnable);
}
特點:只有一個核心線程检柬,并沒有超時機制.意義在于統(tǒng)一所有的外界任務(wù)到一個線程中献联, 這使得在這些任務(wù)之間不需要處理線程同步的問題.