博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Android创建多线程并管理,Android中创建多线程管理器实例
阅读量:6157 次
发布时间:2019-06-21

本文共 2946 字,大约阅读时间需要 9 分钟。

如果你要反复执行一个任务,用不同的数据集(参数不同),但一次只要一个执行(任务是单线程的),IntentService符合你的需求。当需要在资源可用时自动执行任务,或允许多任务同时执行,你需要一个线程管理器管理你的线程。ThreadPoolExecutor,会维护一个队列,当它的线程池有空时,从队列里取任务,并执行。要运行任务,你要做的就是把它加到队列里。

线程池可以并联运行一个任务的多个实例,所以你要保存代码线程安全。能被多线程访问的变量需要同步块.更多信息,见Processes and Threads(http://developer.android.com/guide/components/processes-and-threads.html)

定义线程池类

在它自己类中实例ThreadPoolExecutor.在类里,如下操作:

为线程池使用static变量

你可能在app里只需要一个单例的线程池,这是为了统一控制限制CPU或网络资源。如果你有不同的Runnable类型,你可能想要每种类型都有各自的线程池,但这些都可以放到一个单一的实例里。比如,你可以把它声明成全局变量:

public class PhotoManager {

...

static  {

...

// Creates a single static instance of PhotoManager

sInstance = new PhotoManager();

}

...

使用private构造方法

把构造方法声明成private,可以确保单例,这意味着你不需要在同步代码块里封装类访问。

public class PhotoManager {

...

/**

* 构建用来下载和decode图片的工作队列和线程池,因为构造方法标记为private,

* 对其他类不可访问(甚至同包下的类)

*/

private PhotoManager() {

...

}

调用线程池类里的方法来开始任务

线程池类里定义一个方法,用来添加任务到线程池队列,如:

public class PhotoManager {

...

// 供PhotoView调用获取图片

static public PhotoTask startDownload(

PhotoView imageView,

boolean cacheFlag) {

...

// 添加一个任务到线程池

sInstance.

mDownloadThreadPool.

execute(downloadTask.getHTTPDownloadRunnable());

...

}

实例化一个UI线程的Handler.

Handler用于与UI线程通讯,大多数UI控件只允许在UI线程修改。

private PhotoManager() {

...

// Defines a Handler object that's attached to the UI thread

mHandler = new Handler(Looper.getMainLooper()) {

/*

* handleMessage() defines the operations to perform when

* the Handler receives a new Message to process.

*/

@Override

public void handleMessage(Message inputMessage) {

...

}

...

}

}

判断线程池参数

一旦你有了全部类结构,你就可以开始定义线程池。实例化一个线程池对象,你需要下面的值:

初始池大小,最大池大小。

线程池的线程数量主要依赖于设备的CPU核心数.可以从系统环境中获取。

public class PhotoManager {

...

/*

* Gets the number of available cores

* (not always the same as the maximum number of cores)

*/

private static int NUMBER_OF_CORES =

Runtime.getRuntime().availableProcessors();

}

这个数字可能不能反映出设备的物理cpu内核数量;某些设备CPU会根据系统负载自动禁用部分内核,对于这些设备,availableProcessors()返回的是当前活跃的内核数量。

保持活跃时间和时间单位一个进程在关闭前,保持空闲状态的时间(可以复用进程)。时间单位在TimeUnit里

任务队列

ThreadPoolExecutor的列队保存Runnable对象。在线程中执行代码,线程池管理器会从一个FIFO队列里取出一个Runnable对象,附加到线程里。队列实现BlockingQueue接口,在创建线程池时提供。你可以从现有实现中选一个,适应你的需求,参见ThreadPoolExecutor。下面是使用LinkedBlockingQueue的例子:

public class PhotoManager {

...

private PhotoManager() {

...

// A queue of Runnables

private final BlockingQueue mDecodeWorkQueue;

...

// Instantiates the queue of Runnables as a LinkedBlockingQueue

mDecodeWorkQueue = new LinkedBlockingQueue();

...

}

...

}

创建线程池

调用ThreadPoolExecutor()方法初始化线程池。它会创建管理线程。因为线程池的初始大小和最大池大小是一样的,ThreadPoolExecutor在初始化时就创建了所有线程对象,如:

private PhotoManager() {

...

// Sets the amount of time an idle thread waits before terminating

private static final int KEEP_ALIVE_TIME = 1;

// Sets the Time Unit to seconds

private static final TimeUnit KEEP_ALIVE_TIME_UNIT = TimeUnit.SECONDS;

// Creates a thread pool manager

mDecodeThreadPool = new ThreadPoolExecutor(

NUMBER_OF_CORES,       // Initial pool size

NUMBER_OF_CORES,       // Max pool size

KEEP_ALIVE_TIME,

KEEP_ALIVE_TIME_UNIT,

mDecodeWorkQueue);

}

转载地址:http://ikifa.baihongyu.com/

你可能感兴趣的文章
树莓派是如何免疫 Meltdown 和 Spectre 漏洞的
查看>>
雅虎瓦片地图切片问题
查看>>
HTML 邮件链接,超链接发邮件
查看>>
HDU 5524:Subtrees
查看>>
手机端userAgent
查看>>
pip安装Mysql-python报错EnvironmentError: mysql_config not found
查看>>
http协议组成(请求状态码)
查看>>
怎样成为一个高手观后感
查看>>
[转]VC预处理指令与宏定义的妙用
查看>>
MySql操作
查看>>
python 解析 XML文件
查看>>
MySQL 文件导入出错
查看>>
java相关
查看>>
由一个异常开始思考springmvc参数解析
查看>>
向上扩展型SSD 将可满足向外扩展需求
查看>>
虚机不能启动的特例思考
查看>>
SQL Server编程系列(1):SMO介绍
查看>>
在VMware网络测试“专用VLAN”功能
查看>>
使用Formik轻松开发更高质量的React表单(三)<Formik />解析
查看>>
也问腾讯:你把用户放在什么位置?
查看>>