快捷導(dǎo)航

如何在WorkManager中處理異步任務(wù)詳解

更新時間：2019年02月14日 09:46:42 作者：湫水長天

這篇文章主要給大家介紹了關(guān)于如何在WorkManager中處理異步任務(wù)的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧

前言

WorkManager 是 Android Jetpack 中的新組件，用于負(fù)責(zé)管理后臺任務(wù)。關(guān)于這個組件的介紹就不多說了，網(wǎng)上到處都是，這里分享一下在 WorkManager 中處理異步任務(wù)的方法。

我們知道，在 WorkManager 中，處理任務(wù)的方式是創(chuàng)建一個繼承自 Worker 的任務(wù)類，實現(xiàn) doWork() 方法，并在這個方法中實現(xiàn)我們自己的任務(wù)，然后返回 Result.success() 或 Result.failure() 來表示任務(wù)執(zhí)行成功或者失敗。在這里， doWork() 方法中的任務(wù)應(yīng)該是同步的，這是很自然的，因為 doWork() 方法本身就是在子線程中執(zhí)行，因此可以在 doWork() 方法中同步執(zhí)行耗時操作。

但是些情況，我們想要執(zhí)行的是異步任務(wù)，在 WorkManager 中，有兩種比較好的處理異步任務(wù)的方案。

RxWorker

很多時候我們會使用 RxJava 來處理數(shù)據(jù)。幸運的是，我們可以使用 RxWorker 來處理異步任務(wù)。

dependencies {
 ...
 implementation "android.arch.work:work-runtime:1.0.0-beta05"
 implementation "android.arch.work:work-rxjava2:1.0.0-beta05"
}

然后，將之前集成 Work 的類改為繼承 RxWorker ，然后實現(xiàn) createWork() 方法，基本結(jié)構(gòu)如下：

public class AsyncWorker extends RxWorker {

 public AsyncWorker(Context appContext, WorkerParameters workerParams) {
  super(appContext, workerParams);
 }

 @Override
 public Single<Result> createWork() {
  return remoteService.getMySingleResponse()
    .doOnSuccess(new Consumer() {
     @Override
     public void accept(Object object) throws Exception {
      // 處理任務(wù)
     }
    })
    .map(new Function() {
     @Override
     public Object apply(Object object) throws Exception {
      return Result.success();
     }
    })
    .onErrorReturn(new Function() {
     @Override
     public Object apply(Object object) throws Exception {
      return Result.failure();
     }
    });
 }
}

很簡單是吧？有一點要注意的是， createWork() 方法默認(rèn)是在主線程中執(zhí)行的，如果 10 分鐘沒有結(jié)束任務(wù)，就會自動取消。

ListenableWorker

當(dāng)我們?nèi)ゲ榭?RxWorker 的源碼時，就可以發(fā)現(xiàn)它是繼承了 ListenableWorker 類，其實 Worker 也是通過繼承 ListenableWorker 實現(xiàn)的。因此，我們可以通過自定義 ListenableWorker 來實現(xiàn)相同的功能。

看一下 Worker 的源碼，很簡單：

public abstract class Worker extends ListenableWorker {
 SettableFuture<Result> mFuture;
 public Worker(@NonNull Context context, @NonNull WorkerParameters workerParams) {
  super(context, workerParams);
 }

 @WorkerThread
 public abstract @NonNull Result doWork();
 @Override
 public final @NonNull ListenableFuture<Result> startWork() {
  mFuture = SettableFuture.create();
  getBackgroundExecutor().execute(new Runnable() {
   @Override
   public void run() {
    Result result = doWork();
    mFuture.set(result);
   }
  });
  return mFuture;
 }
}

可以里面主要使用了 SettableFuture 這個類，在 startWork() 里面先創(chuàng)建了 SettableFuture 對象，然后開了一個子線程，在子線程里面執(zhí)行 doWork() 方法，完了就使用 mFuture.set() 方法將 Result 返回。

因此我們也可以模仿 Worker 類的寫法，來實現(xiàn)自己的異步處理，簡單地模板代碼如下：

public class AsyncWorker extends ListenableWorker {
 private SettableFuture<Result> mFuture;
 public AsyncWorker(Context appContext,WorkerParameters workerParams) {
  super(appContext, workerParams);
 }

 @Override
 public ListenableFuture<Result> startWork() {
  mFuture = SettableFuture.create();
  doSomeAsyncWork(new AsyncListener() {
   @Override
   public void success() {
    mFuture.set(Result.success());
   }
   
   @Override
   public void fail() {
    mFuture.set(Result.failure());
   }
  });
  return mFuture;
 }
}

總結(jié)

以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。

您可能感興趣的文章: