- 通过Process.setThreadPriority()方法来设置线程使用的是后台运行优先级。 这个方法减少了通过Runnable创建的线程和和UI线程之间的资源竞争。
-
你还应该通过在Runnable 自身中调用Thread.currentThread()来存储一个引用到Runnable对象的线程。
class PhotoDecodeRunnable implements Runnable {
// 定义要在这个任务中执行的代码
@Override
public void run() {
// 把当前的线程变成后台执行的线程
android.os.Process.setThreadPriority(android.os.Process.THREAD_PRIORITY_BACKGROUND);
...
//在PhotoTask实例中存储当前线程，以至于这个实例能中断这个线程
mPhotoTask.setImageDecodeThread(Thread.currentThread());
...
}
} -
创建多线程管理器
-
为线程池使用静态变量
为了有一个单一控制点用来限制CPU或涉及网络资源的Runnable类型，你可能需要有一个能管理所有线程的线程池，且每个线程都会是单个实例。比如，你可以把这个作为一部分添加到你的全局变量的声明中去：
public class PhotoManager {
...
static {
...
// Creates a single static instance of PhotoManager
sInstance = new PhotoManager();
}
...
-
为线程池使用静态变量
*** 使用私有构造方法***
让构造方法私有从而保证这是一个单例，这意味着你不需要在同步代码块(synchronized block)中额外访问这个类：
public class PhotoManager {
...
* Constructs the work queues and thread pools used to download
* and decode images. Because the constructor is marked private,
* it's unavailable to other classes, even in the same package.
*/
private PhotoManager() {
...
}通过调用线程池类里的方法开启你的任务
在线程池类中定义一个能添加任务到线程池队列的方法。例如：
public class PhotoManager {
...
// Called by the PhotoView to get a photo
static public PhotoTask startDownload(
PhotoView imageView,
boolean cacheFlag) {
...
// Adds a download task to the thread pool for execution
sInstance.
mDownloadThreadPool.
execute(downloadTask.getHTTPDownloadRunnable());
...
}在构造方法中实例化一个Handler，且将它附加到你APP的UI线程。
一个Handler允许你的APP安全地调用UI对象（例如 View对象）的方法。大多数UI对象只能从UI线程安全的代码中被修改。这个方法将会在与UI线程进行通信(Communicate with the UI Thread)这一课中进行详细的描述。例如：
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) {
...
}
...
}
}
-
确定线程池的参数
一旦有了整体的类结构,你可以开始定义线程池了。为了初始化一个ThreadPoolExecutor对象，你需要提供以下数值：-
线程池的初始化大小和最大的大小
这个是指最初分配给线程池的线程数量，以及线程池中允许的最大线程数量。在线程池中拥有的线程数量主要取决于你的设备的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内核，对于这样的设备，availableProcessors()方法返回的是处于活动状态的内核数量，可能少于设备的实际内核总数。
-
线程池的初始化大小和最大的大小
-
线程保持活动状态的持续时间和时间单位
这个是指线程被关闭前保持空闲状态的持续时间。这个持续时间通过时间单位值进行解译，是TimeUnit()中定义的常量之一。 -
一个任务队列
这个传入的队列由ThreadPoolExecutor获取的Runnable对象组成。为了执行一个线程中的代码，一个线程池管理者从先进先出的队列中取出一个Runnable对象且把它附加到一个线程。当你创建线程池时需要提供一个队列对象，这个队列对象类必须实现BlockingQueue接口。为了满足你的APP的需求，你可以选择一个Android SDK中已经存在的队列实现类。为了学习更多相关的知识，你可以看一下ThreadPoolExecutor类的概述。下面是一个使用LinkedBlockingQueue实现的例子：
public class PhotoManager {
...
private PhotoManager() {
...
// A queue of Runnables
private final BlockingQueue<Runnable> mDecodeWorkQueue;
...
// Instantiates the queue of Runnables as a LinkedBlockingQueue
mDecodeWorkQueue = new LinkedBlockingQueue<Runnable>();
...
}
...
}
创建一个线程池
为了创建一个线程池，可以通过调用[ThreadPoolExecutor()](http://developer.android.com/reference/java/util/concurrent/ThreadPoolExecutor.html#ThreadPoolExecutor(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue<java.lang.Runnable>))构造方法初始化一个线程池管理者对象，这样就能创建和管理一组可约束的线程了。如果线程池的初始化大小和最大大小相同，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);
}
