小编rad*_*226的帖子

Dockerfile中VOLUME的用途是什么

我正在努力深入了解Docker的数量,并且我很难弄清楚差异/用例:

  • docker volume create命令
  • docker run -v /path:/host_path
  • 文件中的VOLUME条目Dockerfile

我特别不明白如果将VOLUME条目与-v标志组合起来会发生什么.

如果有人理解得很好,请解释我!

volume docker

79
推荐指数
3
解决办法
3万
查看次数

在RxJava流中添加线程池

我想知道是否可以使用RxJava库以便在以下用例中添加一些并发性:

  • 使用自定义(类似)String从现有列中顺序获取列ResultSetObservableResultSetObservable.create(resultSet)
  • 调用Web Service的每个值(与InvokeWebServiceFunc1<String, Pair<String, Integer>>()以获取相关的一些statistiques实例,例如)String(请注意,StringPair相同的一个输入通过)
  • 以CSV格式打印所有内容(带a ExportAsCSVAction1<Pair<String, Integer>>(PrintStream printStream)).

所以这就是我所拥有的:

ResultSetObservable.create(resultSet)
    .map(new InvokeWebServiceFunc1<String, Pair<String, Integer>>())
    .subscribe(new ExportAsCSVAction1<Pair<String, Integer>>(System.out));
Run Code Online (Sandbox Code Playgroud)

它运作良好,但随着Web服务可能需要一些时间,一些的String投入,我想添加一些并发有一个线程池类似行为的映射(10个线程的例子),但我需要ExportAsCSVAction0,以在被称为相同的线程(实际上当前的线程将是完美的).

你能帮我么?我无法想象在这里使用toBlocking().forEach()模式是否是正确的解决方案,我不明白在哪里使用Schedulers.from(fixedThreadPool)(在observeOn()或中subscribeOn()).

感谢您的任何帮助!

java concurrency multithreading asynchronous rx-java

7
推荐指数
1
解决办法
7375
查看次数