英文:
How to call multiple Flowable statements in parallel?
问题
接口包含函数
public interface XYZDownstreamService {Flowable<String> getData(Request request);}
以下是调用者
public List<String> getDataFromDownstreamForRequests(List<Request> requests, XYZDownstreamService service) {List<String> dataFromDownstream = Lists.newArrayList();for (Request request : requests) {dataFromDownstream.add(service.getData(request).blockingFirst());}return dataFromDownstream;}
我想要同时执行上述的函数调用，以优化for循环。最佳的方法是什么？
英文:
I have a few function calls that return Flowable object. I have to call this function multiple times and this function is doing some network calls. I want to do all these calls concurrently.
Below is the code.
Interface containing the function
public Interface XYZDownstreamService {Flowable<String> getData(Request request);}
Below is the Caller
public List<String> getDataFromDownstreamForRequests(List<Request> requests, XYZDownstreamService service) {List<String> dataFromDownstream = Lists.newArrayList();for(Request request: requests) {dataFromDownstream.add(service.getData(request).blockingFirst());}return dataFromDownstream;}
I want to do the above function calls concurrently to optimize the for a loop. What is the best way to do it?
答案1
得分: 2
你只需要使用 merge 或者 flatMap 来合并你的请求。此外，可以使用不同的线程来处理你的请求，使用 observeOn。
Flowable.merge(requests.stream().map(r -> service.getData(r).observeOn(Schedulers.io()))).collect(toList())).subscribe()
或者这样写：
Flowable.fromIterable(requests).flatMap(r -> service.getData(r).observeOn(Schedulers.io())).subscribe();
我已经在一个类似的问题中回答过了，有更多的细节内容。
英文:
You just need to merge your requests using merge or flatMap. Moreover, use a diffrent threads to process your requests using observeOn.
Flowable.merge(requests.stream().map(r -> service.getData(r).observeOn(Schedulers.io()))).collect(toList())).subscribe()
Or write it like :
Flowable.fromIterable(requests).flatMap(r -> service.getData(r).observeOn(Schedulers.io())).subscribe();
I've already reply to a similar question for more details.
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论