Android Bolts中如何快速完成线程调度和任务管理，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。
创新互联是专业的兴宁网站建设公司，兴宁接单;提供成都网站制作、成都做网站、外贸营销网站建设,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行兴宁网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!
使用 Bolts 可以将一个完整的操作拆分成多个子任务，这些子任务可以自由的拆分、组合和替换，每个任务作为整个任务链的一环可以运行在指定线程中，同时既能从上行任务中获取任务结果，又可以向下行任务发布当前任务的结果，而不必考虑线程之间的交互。
Bolts-Android Bolts 在 Android 下的实现 Bolts-ObjC Bolts 在 OC 下的实现 Bolts-Swift Bolts 在 Swift 下的实现
前言
一个关于线程调度的简单需求，在子线程从网络下载图片，并返回下载的图片，在主线程使用该图片更新到 UI，同时返回当前 UI 的状态 json，在子线程将 json 数据保存到本地文件，完成后在主线程弹出提示，这中间涉及到了 4 次线程切换，同时后面的任务需要前面任务完成后的返回值作为参数。
使用 Thread + Handler 实现，线程调度很不灵活，代码可读性差，不美观，扩展性差，错误处理异常麻烦。
String url = "http://www.baidu.com"; Handler handler = new Handler(Looper.getMainLooper()); new Thread(() -> { // 下载 Bitmap bitmap = downloadBitmap(url); handler.post(() -> { // 更新 UI String json = updateUI(bitmap); new Thread(() -> { // 向存储写入UI状态 saveUIState(json); // 保存成功后，提示 handler.post(() -> toastMsg("save finish.")); }).start(); }); }).start();使用 RxJava 实现，线程调度非常灵活，链式调用，代码清晰，扩展性好，有统一的异常处理机制，不过 Rx 是一个很强大的库，如果只用来做线程调度的话， Rx 就显得有点太重了。
Observable.just(URL) // 下载 .map(this::downloadBitmap) .subscribeOn(Schedulers.newThread()) // 更新UI .observeOn(AndroidSchedulers.mainThread()) .map(this::updateUI) // 存储 UI 状态 .observeOn(Schedulers.io()) .map(this::saveUIState) // 显示提示 .observeOn(AndroidSchedulers.mainThread()) .subscribe(rst -> toastMsg("save to " + rst), // handle error Throwable::printStackTrace);使用 bolts 实现，线程调度灵活，链式调用，代码清晰，具有良好的扩展性，具有统一的异常处理机制，虽然没有 Rx 那么丰富的操作符，但是胜在类库非常非常小，只有 38 KB。
Task .forResult(URL) // 下载 .onSuccess(task -> downloadBitmap(task.getResult()), Task.BACKGROUND_EXECUTOR) // 更新UI .onSuccess(task -> updateUI(task.getResult()), Task.UI_THREAD_EXECUTOR) // 存储UI状态 .onSuccess(task -> saveUIState(task.getResult()), Task.BACKGROUND_EXECUTOR) // 提示 .onSuccess(task -> toastMsg("save to " + task.getResult()), Task.UI_THREAD_EXECUT // handle error .continueWith(task -> { if (task.isFaulted()) { task.getError().printStackTrace(); return false; } return true; });线程调度器
共有 4 种类型执行线程，将任务分发到指定线程执行，分别是
backgroud - 后台线程池，可以并发执行任务。
scheduled - 单线程池，只有一个线程，主要用来执行 delay 操作。
immediate - 即时线程，如果线程调用栈小于 15，则在当前线程执行，否则代理给 background 。
uiThread - 针对 Android 设计，使用 Handler 发送到主线程执行。
backgroud
主要用来在后台并发执行多任务
public static final ExecutorService BACKGROUND_EXECUTOR = BoltsExecutors.background();
在 Android 平台下根据 CPU 核数创建线程池，其他情况下，创建缓存线程池。
background = !isAndroidRuntime() ? java.util.concurrent.Executors.newCachedThreadPool() : AndroidExecutors.newCachedThreadPool();
scheduled
主要用于任务之间做 delay 操作，并不实际执行任务。
scheduled = Executors.newSingleThreadScheduledExecutor();
immediate
主要用来简化那些不指定运行线程的方法，默认在当前线程去执行任务，使用 ThreadLocal 保存每个线程调用栈的深度，如果深度不超过 15，则在当前线程执行，否则代理给 backgroud 执行。
private static final Executor IMMEDIATE_EXECUTOR = BoltsExecutors.immediate(); // 关键方法 @Override public void execute(Runnable command) { int depth = incrementDepth(); try { if (depth <= MAX_DEPTH) { command.run(); } else { BoltsExecutors.background().execute(command) } } finally { decrementDepth(); } }uiThread
为 Android 专门设计，在主线程执行任务。
public static final Executor UI_THREAD_EXECUTOR = AndroidExecutors.uiThread();
private static class UIThreadExecutor implements Executor { @Override public void execute(Runnable command) { new Handler(Looper.getMainLooper()).post(command); } }核心类
Task ，最核心的类，每个子任务都是一个 Task ，它们负责自己需要执行的任务。每个 Task 具有 3 种状态 Result 、 Error 和 Cancel ，分别代表成功、异常和取消。
Continuation ，是一个接口，它就像链接子任务每一环的锁扣，把一个个独立的任务链接在一起。
通过 Task - Continuation - Task - Continuation ... 的形式组成完整的任务链，顺序在各自线程执行。
创建 Task
根据 Task 的 3 种状态，创建简单的 Task ，会复用已有的任务对象
public staticTask forResult(TResult value) public static Task forError(Exception error) public static Task cancelled()
使用 delay 方法，延时执行并创建 Task
public static Task delay(long delay) public static Task delay(long delay, CancellationToken cancellationToken)
使用 whenAny 方法，执行多个任务，当任意任务返回结果时，保存这个结果
public static Task> whenAnyResult(Collection> tasks) public static Task> whenAny(Collection> tasks)
使用 whenAll 方法，执行多个任务，当全部任务执行完后，返回结果
public static Task whenAll(Collection> tasks) public static Task> whenAllResult(final Collection> tasks)
使用 call 方法，执行一个任务，同时创建 Task
public static Task call(final Callable callable, Executor executor, final CancellationToken ct)
链接子任务
使用 continueWith 方法，链接一个子任务，如果前行任务已经执行完成，则立即执行当前任务，否则加入队列中，等待。
