RXJava：如何在不同的线程上创建可观察的线程，而不是主线程
Observable operationObservable = Observable.create(new ObservableOnSubscribe() {
@Override
public void subscribe(ObservableEmitter e) throws Exception {
e.onNext(longRunningOperation());
e.onComplete();
}
})
.subscribeOn(Schedulers.io()) // subscribeOn the I/O thread
.observeOn(AndroidSchedulers.mainThread());
暂时还没有答案
-
我正在开发利用RxJava、realm和改进的应用程序。 我需要创建非常具体的数据处理链。我需要在io调度程序上执行改装调用，然后在我的自定义单线程领域调度程序上处理提供的数据，然后将结果推送到主线程调度程序上的ui。我试图通过使用多个组合来实现这一点，包括观察（observeOn）和订阅（subscribeOn），但我无法让中间部分在调度程序（scheduler）上执行。 我的目标是这样的
-
我正在运行RxJava并创建一个主题以使用方法生成数据。我正在使用Spring。 这是我的设置： 在RxJava流上生成新数据的方式是通过Autowire private SubjectObserver SubjectObserver，然后调用SubjectObserver。发布（newDataObjGenerated） 无论我为subscribeOn（）指定了什么 Schedulers.io（）
-
问题内容： 我是Java技术的新手。我知道在Java中只有两种创建方式 扩展线程类 实施可运行接口 因此，这只是两种创建方法。但是，当我们使用主JVM启动程序时，它启动了一个main 。我认为甚至JVM也必须遵循创建主要方法的规则，以创建主线程JVM必须扩展Thread类或实现。 我尽了最大的努力，但是不知道JVM是如何创建这个主要对象的。当我完全遍历主类（）时，我知道这是负责主线程的类。但是在G
-
我在Android上使用RxJava和Retrofit2.0来处理网络请求。 在创建可观察对象时，我向其添加以下内容： 是否有一个优雅的解决方案来解决这个问题，而不必手动地用一个块包装我的实现，以便将一些东西发布到主线程？
-
我正在进行一个项目，我们在该项目中遇到了线程问题。有一个问题使线程终止，并且线程无法自动重新启动，因此我们想更改当前的实现。我们想出了一个想法来运行一个观察者线程来管理文件处理线程。 请有人建议如何制作监视程序状态的线程以及如何执行此操作的想法。 编辑：所以基本上这就是发生的事情。用户上载一些写入文件共享的媒体文件。移动服务中运行的线程扫描媒体文件并附加到电子邮件。在此过程中，线程终止，无法将媒体
-
有没有可能使用一组线程池来共享大型线程池中的线程，而不是创建新的线程？ 在我们的RESTful API应用程序中，一个请求可能涉及多个并行任务。为了提高性能，我们希望在具有固定数量（比如200个）线程的线程池中执行并行任务。但是我们也希望限制每个请求可以使用的最大线程数。所以我在想，如果有可能为每个请求创建一个具有最大池大小的子线程池，它不会自己创建线程，而是尝试从全局线程池中获取一个新线程，并在