使用 Rx Java 读取文件

Question

我从一个文件夹中有许多文件，我正在读取这些文件并将其内容存储到数据库中。随后如何使用 RX Java 执行相同的操作？因为我有很多文件要阅读，并且在异步任务中花费了很多时间

String path = "some path";
        File directory = new File(path);
        File[] files = directory.listFiles();
        Log.d(TAG, "Size: " + files.length);
        for (int i = 0; i < files.length; i++) {
            Log.d(TAG, "FileName -> " + files[i].getName());

         //execute async to read file
        }

Answer 1

你可以在 RxJava 中用多线程替换你的单线程方法非常容易（相比之下，不使用 RxJava）。 AsyncTask 使用executeOnExecutor(Executor exec, Params... params) 提供并行执行，因此您当前的实现可以调整为AsyncTask 以处理单个文件而不是完整的目录。但是你的问题是关于 RxJava。

多线程将加快文件读取速度 - 速度提升将取决于很多因素，但主要是您的闪存顺序读取/随机读取速度。看到这将是一个冷Observable 他们真的没有意义使用Flowable 因为背压不会在这里发挥作用。

用于实现某种多线程的伪代码：

    Observable.just(directory)
            .flatMap(dir ->
                    Observable.fromArray(dir.listFiles()))
            .filter(File::isFile)
            .flatMap(file ->
                    Observable.just(file)
                            .map(this::readFileFunctionWithReturn)
                            .subscribeOn(Schedulers.io())) // execute on multiple threads
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread()) // observe on UI, or choose another Scheduler
            .subscribe(fileResult -> {
                // unordered results
            });

如果您想对线程进行更细粒度的控制，例如自定义ThreadFactory，您还可以创建由Executor 支持的自定义Scheduler 实现。