java - 有没有办法使用 RxJava 让方法在多个线程上运行

Question

我是 RxJava 新手，我试图弄清楚是否有相当于在各个线程上并行运行多个异步任务的方法。

我理解 RxJava 相当于

AsyncTask asyncTask = new AsyncTask<String, Void, ObjectType>(){
    @Override
    protected ObjectType doInBackground(String... params) {
         return someMethod(params[0]);
    }

    @Override
    protected void onPostExecute(ObjectType objectType) {}
}

aynctask.execute();

是

Observable.just(string)
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .map(this::someMethod)
    .subscribe(new Observer<ObjectType>() {
        @Override
        public void onCompleted() {}

        @Override
        public void onError(Throwable e) {}

        @Override
        public void onNext(ObjectType objectType) {}
    });

但是我怎样才能在 RxJava 中实现等价的

asyncTask.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR);

Answer 1

Rx Java 文档的“调度程序”部分很好地回答了这个问题，位于 here 。我不会尝试总结这里的大量信息，足以说明 asyncTask.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR); 的等价物是让您的 Observable 运算符级联中的运算符在特定调度程序上运行.

特别是，您可以使用 Schedulers.from(AsyncTask.THREAD_POOL_EXECUTOR)在特定 java.util.concurrent.Executor 上执行运算符的方法。