2

我正在使用 rxjava 将一些任务上传到服务器，每当任务启动的片段或活动被破坏时，我都会处理订阅以避免内存泄漏，但我想要的是即使在片段/活动被破坏后我需要继续运行任务背景，有什么办法可以做到这一点？

例子

doSomeLongRunningBgTaks()
     .subscribe()
     .addTo(compositeDisposal)

override onDestroy(){
  compositeDisposal.clear()
}

是否必须始终处置订阅？如果不是什么时候使用 dispose ？

4

3 回答 3

3

那么为什么需要 Disposable ？

所以如果你有一些像下面这样的可观察的：

Observable.just("Hello world!")
     .delay(1, TimeUnit.SECONDS)
     .subscribeWith(new DisposableObserver<String>() {
         @Override public void onStart() {
             System.out.println("Start!");
         }
         @Override public void onNext(String t) {
             System.out.println(t);
         }
         @Override public void onError(Throwable t) {
             t.printStackTrace();
         }
         @Override public void onComplete() {
             System.out.println("Done!");
         }
     });

现在，如果您想停止此任务，则只能通过 dispose() 处理它。

有时如果用户想要处理任何任务，例如：如果用户从屏幕导航或用户按下后退按钮，那么我们必须在那时终止 Web 请求或取消任何任务使用 Disposable。

如果您必须在后台执行任何任务并且如果片段被破坏而不杀死怎么办？

您可以简单地只编写 subscribe() 方法并忘记任务。

doSomeLongRunningBgTaks()
     .subscribe()

也许它会帮助你。谢谢

于 2019-09-11T07:25:22.803 回答
2

首先，您必须了解现代版本的 AndroidOS 的后台任务限制。全部在这里 [a link] ( https://developer.android.com/about/versions/oreo/background ) 简而言之，如果您的应用程序不可见或您的应用程序没有运行的前台服务，则没有任何保证您的后台工作已完成。

其次，在您的情况下，您需要有一些与片段或活动的任何生命周期无关并且能够运行后台工作的实体。有几种可能的解决方案

1）安卓服务方式

创建一个意图服务。这是一个简单的服务，已经实现了具有内部队列的块。每次客户端尝试通过此类服务执行作业时，服务都会在后台队列中执行此类任务。因此，如果您执行两次，该服务将在执行第二个任务之前等待第一个任务完成。

导入 android.app.IntentService 导入 android.content.Intent

class MyIntentService : IntentService("My intent service") {

  // This method already in another thread (not UI thread)
  override fun onHandleIntent(intent: Intent?) {
    doLongRunningBackgroundJob()
  }
}

PS 不要忘记在 Manifest 文件中注册此类服务。

2）Android处理程序方式

您可以使用带有准备好的后台循环器的内部 android 处理程序创建一个类。例如：

import android.os.Handler
import android.os.HandlerThread

class MyBackgroundWorker {

  private val handler = initHandler()

  private fun initHandler(): Handler {
    val handlerThread = HandlerThread("My background thread")
    handlerThread.start()
    return Handler(handlerThread.looper)
  }

  fun executeJobInBackground(job: Runnable) {
    handler.post(job)
  }
}

3）纯java方式

可以创建纯线程的实例，但更可取的是使用 Java 框架的 executors。对于线程方法：

class MyBackgroundWorker {

  fun executeJobInBackground(job: Runnable) {
    Thread(job).start()
  }
}

对于执行者方法：

import java.util.concurrent.Executors

class MyBackgroundWorker {

  private val executor = Executors.newSingleThreadExecutor()

  fun executeJobInBackground(job: Runnable) {
    executor.execute(job)
  }
}

PS 不要忘记使用 DI 方法提供依赖项。

于 2019-09-11T06:09:01.823 回答
-1

你可以使用这样的东西：

webService.doSomething(someData)
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(
          result -> resultText.setText("It worked!"),
          e -> handleError(e));
于 2019-09-11T05:18:45.360 回答