Android的线程和线程池
Android中的线程形态
1.AsyncTask
AsyncTask封装了Thread和Handler,是抽象的泛型类,提供了Params,Progress,Result这三个泛型参数
四个核心方法:
- 1.onPreExecute() 主线程中执行,异步任务之前调用
- 2.doInBackground(Params… par) 异步后台执行
- 3.onProgressUpdate(Progress… value) 主线程中执行,进度发生变化该方法被调用
- 4.onPostExecute(Result res) 主线程中执行,异步任务执行完改方法被调用
使用过程中有以下条件限制
- 1.AsyncTask的类必须在主线程中加载。在5.0的源码中ActivityThread的main方法中调用AsyncTask的init方法
- 2.AsyncTask的对象必须在主线程中创建
- 3.execute方法必须在UI线程调用
- 4.不要在程序中直接调用上述四个核心方法
- 5.一个AsyncTask对象只能执行一次,即只能调用一次execute方法,否则报运行时异常
- 6.版本差异
- 1.在Android1.6之前是串行执行任务;
- 2.Android1.6的时候采取并行处理;
- 3.Android3.0又采取串行执行,尽管如此3.0以后的版本还可以通过AsyncTask的executeOnExecutor来并行执行任务
2.HandlerThread
HandlerThread继承了Thread. 该线程运行的时候创建Looper。可以说是自带Looper的Thread
3.IntentService
IntentService抽象类,继承了Service. 内部包含了ServiceHandler和HandlerThread.
public class LocalIntentService extends IntentService {
private static final String TAG = "LocalIntentService";
public LocalIntentService() {
super(TAG);
}
@Override
protected void onHandleIntent(final Intent intent) {
final String action = intent.getStringExtra("task_action");
Log.d(TAG, "receive task :" + action);
SystemClock.sleep(3000);
if ("com.ryg.action.TASK1".equals(action)) {
Log.d(TAG, "handle task: " + action);
}
}
@Override
public void onDestroy() {
Log.d(TAG, "service destroyed.");
super.onDestroy();
}
}
启动服务
Intent service = new Intent(this, LocalIntentService.class);
service.putExtra("task_action", "com.ryg.action.TASK1");
startService(service);
service.putExtra("task_action", "com.ryg.action.TASK2");
startService(service);
service.putExtra("task_action", "com.ryg.action.TASK3");
startService(service);
Android中的线程池
线程池的优点:
- 1.重用线程,避免开销
- 2.有效控制线程并发数,避免因抢占资源造成的阻塞
- 3.有效管理,提供定时及循环间隔执行等功能
ThreadPoolExecutor
参数:
- 1.corePoolSize: 核心线程数。默认情况下核心线程在线程池中会一直存活,即便是闲置状态。如果将ThreadPoolExecutor的allowCoreThreadTimeOut设置为true,那么闲置的核心线程在等待新任务到来时会有超时策略
- 2.maximumPoolSize:容纳的最大线程数
- 3.keepAliveTime:非核心线程闲置时的超时时长,超过这个时长,非核心线程就会被回收。
- 4.TimeUnit
- 5.workQueue
- 6.ThreadFactory
线程池的分类
- 1.FixedThreadPool: newFixedThreadPool方法创建。是一种数量固定的线程池,只有核心线程,且核心线程不会被回收,可以快速相应外界请求。没有超时机制,没有队列大小限制。
- 2.CachedThreadPool:newCachedThreadPool方法创建。是一种线程数量不定的线程池,只有非核心线程。有超时机制。适合执行大量的耗时较少的任务
- 3.ScheduledThreadPool:核心线程数量是固定的,非核心线程数是没有固定的,当非核心线程闲置时会被立即回收。主要用于执行定时任务和具有固定周期的重复任务。
- 4.SingleThreadExecutor:线程池内部只有一个核心线程,确保所有的任务都在同一个线程中按顺序执行。
private void runThreadPool() {
Runnable command = new Runnable() {
@Override
public void run() {
SystemClock.sleep(2000);
}
};
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(4);
fixedThreadPool.execute(command);
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
cachedThreadPool.execute(command);
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(4);
// 2000ms后执行command
scheduledThreadPool.schedule(command, 2000, TimeUnit.MILLISECONDS);
// 延迟10ms后,每隔1000ms执行一次command
scheduledThreadPool.scheduleAtFixedRate(command, 10, 1000, TimeUnit.MILLISECONDS);
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
singleThreadExecutor.execute(command);
}
参考:
《Android开发艺术探索》