在Android开发中、涉及比较深的话、我们会用到线程池来做异步操作
比如下载图片、执行异步任务等、为了方便管理、继承一个线程池管理类、
在使用线程的时候只需要 submmitJob和removeJob、不会产生大量的线程、有效防止OOM
代码如下:
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadPool {
private static final String TAG = "ThreadPool";
private static ThreadPool instance;
private ThreadPoolExecutor threadPool = null;
private static final int CORE_POOL_SIZE = 3;
private static final int MAX_POOL_SIZE = 8;
private static final int KEEP_ALIVE_TIME = 10; // 10 seconds
private ThreadPool() {
threadPool = new ThreadPoolExecutor(CORE_POOL_SIZE,MAX_POOL_SIZE,KEEP_ALIVE_TIME,
TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(),
new PriorityThreadFactory("mthread-pool",
android.os.Process.THREAD_PRIORITY_BACKGROUND));
}
public static synchronized ThreadPool getInstance(){
if(instance == null){
instance = new ThreadPool();
}
return instance;
}
public void removeJob(Runnable task){
threadPool.remove(task);
}
/***
* 线程池执行command
* @param r
*/
public void submmitJob(Runnable r){
threadPool.execute(r);
}
}
使用说明
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
ThreadPool.getInstance().submmitJob(r);
}
@Override
protected void onDestroy() {
super.onDestroy();
ThreadPool.getInstance().removeJob(r);
}
private Runnable r = new Runnable() {
@Override
public void run() {
//do something
}
};
参数说明
参数名 | 作用 |
---|---|
corePoolSize | 核心线程池大小 |
maximumPoolSize | 线程池中超过corePoolSize数目的空闲线程最大存活时间;可以allowCoreThreadTimeOut(true)使得核心线程有效时间 |
TimeUnit | keepAliveTime时间单位 |
workQueue | 阻塞任务队列 |
threadFactory | 新建线程工厂 |
RejectedExecutionHandler | 当提交任务数超过maxmumPoolSize+workQueue之和时,任务会交给RejectedExecutionHandler来处理 |
重点讲解:
其中比较容易让人误解的是:corePoolSize,maximumPoolSize,workQueue之间关系。
1.当线程池小于corePoolSize时,新提交任务将创建一个新线程执行任务,即使此时线程池中存在空闲线程。
2.当线程池达到corePoolSize时,新提交任务将被放入workQueue中,等待线程池中任务调度执行
3.当workQueue已满,且maximumPoolSize>corePoolSize时,新提交任务会创建新线程执行任务
4.当提交任务数超过maximumPoolSize时,新提交任务由RejectedExecutionHandler处理
5.当线程池中超过corePoolSize线程,空闲时间达到keepAliveTime时,关闭空闲线程
6.当设置allowCoreThreadTimeOut(true)时,线程池中corePoolSize线程空闲时间达到keepAliveTime也将关闭
时间: 2024-10-07 05:31:29