使用 RXJava 执行异步任务的推荐方法

Question

我是 RxJava 的新手，我正在尝试了解 best/recommended 异步执行长运行任务（例如网络请求）的方法。我已经在线阅读了很多示例，但希望得到一些反馈。

以下代码有效（它打印 'one'、'two'、然后 'User: x' ... 等等）但我真的应该手动 creating/managing 线程吗？

提前致谢！

public void start() throws Exception {
    System.out.println("one");
    observeUsers()
        .flatMap(users -> Observable.from(users))
        .subscribe(user -> System.out.println(String.format("User: %s", user.toString()));
    System.out.println("two");
}

Observable<List<User>> observeUsers() {
    return Observable.<List<User>>create(s -> {
        Thread thread = new Thread(() -> getUsers(s));
        thread.start();
    });
}

void getUsers(final Subscriber s) {
    s.onNext(userService.getUsers());
    s.onCompleted();
}

// userService.getUsers() fetches users from a web service.

Answer 1

与其管理自己的线程，不如尝试使用 defer() operator. Meaning replace observeUsers() with Observable.defer(() -> Observable.just(userService.getUsers())). Then you can use the RxJava Schedulers 来控制订阅和观察期间使用的线程。这是根据上述建议修改后的代码。

Observable.defer(() -> Observable.just(userService.getUsers()))
        .flatMap(users -> Observable.from(users))
        .subscribeOn(Schedulers.newThread())
        .observeOn(Schedulers.trampoline())
        .subscribe(user -> System.out.println(String.format("User: %s", user.toString()));

使用 RXJava 执行异步任务的推荐方法

Recommended way to execute async tasks with RXJava

java

asynchronous

rx-java