我们应该每次都在RxJava中使用调度程序吗

Question

我是RxJava新手，目前正在使用RxJava版本1。我的用例就像我必须进行一次rest API调用（使用rest模板）。因此，使用调度器是更好的主意吗。在这种情况下，每次都可以使用computation（）或任何调度器。

我的课程是

SampleController。Java语言

@RequestMapping(value = "/", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
    public DeferredResult<List<Response>> getresponse() {
        DeferredResult<List<Response>> response = new DeferredResult<>();
            service
              .fetchJson()
              .subscribe(result -> response.setResult(result));
        return response;
    }

服务Java语言

@Override
    public Observable<List<Response>> fetchJson() {
        Observable<List<Response>> list = Observable.<List<Response>>create(
                subscriber -> subscriber.onNext(this.invokeRestCall(APIURL)))
                .subscribeOn(Schedulers.from(executor));*/
        return list;
    }

    private List<Response> invokeRestCall(String APIURL) {  

        Response[] responses = restTemplate.getForObject(APIURL, Response[].class);
        return Arrays.stream(responses).collect(Collectors.toList());
    }

在这里，我使用Schedulers来启动新线程。但我再次使用延迟结果进行即时响应，Spring将把它放在队列中，一旦响应出现，它就会传递响应。

那么，我应该避免调度程序并使其仅在订阅线程上运行，因为我只有一个Rest调用吗？

请建议，因为我真的是新的。

Answer 1

如果您想在可观察操作符的级联中引入多线程，可以通过指示这些操作符（或特定可观察操作符）在特定调度器上操作来实现。

Answer 2

默认情况下，Rx是同步的，所有内容都在同一个线程上工作，除非您将执行（'subscribeOn'）和/或观察（'observeOn'）分配给在其他线程上运行的调度器。

因此，这实际上取决于手头的任务。例如，改型就是使用自己的调度器。UI只能从Android主线程变异而来。对于单元测试，使用调度器可以方便地手动提前时间。

Answer 3

RxJava为您提供了对何时何地完成计算的关键控制。使用显式提供的调度器控制观察者链的某些阶段提供了线程安全性，并确保数据在需要时在需要的位置。

也就是说，Schedulers静态类方法返回全局已知的调度程序。当您进行测试时，或者当您想在不同的上下文中重新使用您的代码时，全局变量的使用是一个严重的障碍。

我建议您传入要使用的调度器，可能是服务类的构造函数。这有时被称为依赖注入，它使您的代码更具可移植性、可测试性，最终更易于维护。