带有SQlite和ContentProvider操作的RxJava

Question

我正在研究RxJava，为此我正在使用SQLite，编写一个帮助类SQLiteUtils，以便更容易地处理异步ContentResolver查询。例如，这是QueryInBackground方法：

static
public <T> Observable<T> queryInBackground(
        final ContentResolver cr,
        final Uri uri,
        final String[] projection,
        final String selection,
        final String[] selectionArgs,
        final String sortOrder,
        final CursorHandler<T> ch) {
    return  Observable.create(new Observable.OnSubscribe<T>() {
        @Override
        public void call(Subscriber<? super T> observer) {
            if (!observer.isUnsubscribed()) {
                Cursor cursor = null;
                try {
                    cursor = cr.query(uri, projection, selection, selectionArgs, sortOrder);
                    if (cursor != null && cursor.getCount() > 0) {
                        while (cursor.moveToNext()) {
                            observer.onNext(ch.handle(cursor));
                        }
                    }
                    observer.onCompleted();
                } catch (Exception err) {
                    observer.onError(err);

                } finally {
                    if (cursor != null) cursor.close();
                }
            }
        }
    }).subscribeOn(Schedulers.computation());
}

其中CursorHandler是接口：

/**
 * Implementations of this interface convert Cursor into other objects.
 *
 * @param <T> the target type the input Cursor will be converted to.
 */
public interface CursorHandler<T> {
    T handle(Cursor cu) throws SQLException;
}

我读过有关调度器的文档，但我不太确定Schedulers.computation()是否是正确的选择。

如果我想为基本的httpurlconnection操作实现类似的操作，我应该选择哪种调度程序？schedulers.newthread()或schedulers.io()，我会坚持使用schedulers.io()...但不确定。

提前道谢。

万事如意，卢卡

Answer 1

根据这个答案，您应该使用schedulers.io()。相关报价：

io（）由一个无界线程池支持，您可以将它用于非计算密集型任务，即不会给CPU带来太多负载的任务。因此，与文件系统的交互、与不同主机上的数据库或服务的交互都是很好的例子。