标签：project-reactor reactive-programming java

考虑以下通量

Flux.range(1, 5)
  .parallel(10)
  .runOn(Schedulers.parallel())
  .map(i -> "https://www.google.com")
  .flatMap(uri -> Mono.fromCallable(new HttpGetTask(httpClient, uri)))

HttpGetTask是一个Callable,在这种情况下其实际实现是无关紧要的,它对给定的URI进行HTTP GET调用,如果成功,则返回内容.

现在,我想通过引入人为延迟来减慢发射速度,这样就可以同时启动多达10个线程,但是HttpGetTask完成后每个线程不会立即完成.例如,说没有线程必须在3秒之前完成.我该如何实现？

解决方法:

如果要求确实是“不少于3s”,则可以使用Mono.fromCallable(…).delayElement(Duration.ofSeconds(3))在flatMap中为Mono添加3秒的延迟.

标签：project-reactor,reactive-programming,java
来源： https://codeday.me/bug/20191026/1933136.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。