android 线程list.add,ListenableWorker 中的线程处理
在某些情況下，您可能需要提供自定義線程處理策略。例如，您可能需要處理基于回調(diào)的異步操作。在這種情況下，不能只依靠 Worker 來完成操作，因為它無法以阻塞方式完成這項工作。WorkManager 通過 ListenableWorker 支持該用例。ListenableWorker 是最基本的工作器 API；Worker、CoroutineWorker 和 RxWorker 都是從這個類衍生而來的。ListenableWorker 只會發(fā)出信號以表明應該開始和停止工作，而線程處理則完全交您決定。開始工作信號在主線程上調(diào)用，因此請務必手動轉(zhuǎn)到您選擇的后臺線程。
抽象方法 ListenableWorker.startWork() 會返回一個將使用操作的 Result 設置的 ListenableFuture。ListenableFuture 是一個輕量級接口：它是一個 Future，用于提供附加監(jiān)聽器和傳播異常的功能。在 startWork 方法中，應該返回 ListenableFuture，完成操作后，您需要使用操作的 Result 設置這個返回結果。您可以通過以下兩種方式之一創(chuàng)建 ListenableFuture 實例：
如果您使用的是 Guava，請使用 ListeningExecutorService。
如果您希望基于異步回調(diào)執(zhí)行某些工作，則應以類似如下的方式執(zhí)行：
Kotlin
class CallbackWorker(
context: Context,
params: WorkerParameters
) : ListenableWorker(context, params) {
override fun startWork(): ListenableFuture {
return CallbackToFutureAdapter.getFuture { completer ->
val callback = object : Callback {
var successes = 0
override fun onFailure(call: Call, e: IOException) {
completer.setException(e)
}
override fun onResponse(call: Call, response: Response) {
successes++
if (successes == 100) {
completer.set(Result.success())
}
}
}
repeat(100) {
downloadAsynchronously("https://example.com", callback)
}
callback
}
}
}Java
public class CallbackWorker extends ListenableWorker {
public CallbackWorker(Context context, WorkerParameters params) {
super(context, params);
}
@NonNull
@Override
public ListenableFuture startWork() {
return CallbackToFutureAdapter.getFuture(completer -> {
Callback callback = new Callback() {
int successes = 0;
@Override
public void onFailure(Call call, IOException e) {
completer.setException(e);
}
@Override
public void onResponse(Call call, Response response) {
successes++;
if (successes == 100) {
completer.set(Result.success());
}
}
};
for (int i = 0; i < 100; i++) {
downloadAsynchronously("https://www.example.com", callback);
}
return callback;
});
}
}
如果您的工作停止會發(fā)生什么？如果預計工作會停止，則始終會取消 ListenableWorker 的 ListenableFuture。通過使用 CallbackToFutureAdapter，您只需添加一個取消監(jiān)聽器即可，如下所示：
Kotlin
class CallbackWorker(
context: Context,
params: WorkerParameters
) : ListenableWorker(context, params) {
override fun startWork(): ListenableFuture {
return CallbackToFutureAdapter.getFuture { completer ->
val callback = object : Callback {
var successes = 0
override fun onFailure(call: Call, e: IOException) {
completer.setException(e)
}
override fun onResponse(call: Call, response: Response) {
++successes
if (successes == 100) {
completer.set(Result.success())
}
}
}
completer.addCancellationListener(cancelDownloadsRunnable, executor)
repeat(100) {
downloadAsynchronously("https://example.com", callback)
}
callback
}
}
}Java
public class CallbackWorker extends ListenableWorker {
public CallbackWorker(Context context, WorkerParameters params) {
super(context, params);
}
@NonNull
@Override
public ListenableFuture startWork() {
return CallbackToFutureAdapter.getFuture(completer -> {
Callback callback = new Callback() {
int successes = 0;
@Override
public void onFailure(Call call, IOException e) {
completer.setException(e);
}
@Override
public void onResponse(Call call, Response response) {
++successes;
if (successes == 100) {
completer.set(Result.success());
}
}
};
completer.addCancellationListener(cancelDownloadsRunnable, executor);
for (int i = 0; i < 100; ++i) {
downloadAsynchronously("https://www.example.com", callback);
}
return callback;
});
}
}
總結
以上是生活随笔為你收集整理的android 线程list.add,ListenableWorker 中的线程处理的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 遍开头的成语有哪些？
- 下一篇： 一个java高级工程师的进阶之路【转】