1
hingbong 2022-04-20 08:07:41 +08:00 via Android
并行流可以用不同的线程池的吧
|
2
huang119412 2022-04-20 09:05:12 +08:00
看场景,如果不是阻塞 IO ( JDBC 等),还是可以使用的。ForkJoinPool 适合 CPU 密集型,但是这个线程池是全局共享的,JDK 本身也在使用,CHM ,CompletableFuture 等。所以还是不太建议使用。loom 救不了阻塞 io 。纤程,协程,promise 都只是更简单处理异步 IO ,可以说是回调的语法糖。处理同步阻塞 IO ,还是会阻塞,协程所在的线程都阻塞了,当然没法切换了。所以 WebFlux 现在还是玩具
|
3
wolfie 2022-04-20 10:48:10 +08:00
forkjoinpool.execute(
// 并行流代码 ) |
4
lmshl 2022-04-20 11:53:16 +08:00
|
5
lmshl 2022-04-20 11:54:29 +08:00
|
6
codefever 2022-04-20 12:03:56 +08:00
还是要看业务需求,有需求的话,我觉得还是可以用
|
7
jeesk 2022-04-20 12:55:14 +08:00 via Android
我们公司大佬自己用 scala 模拟 storm 写了一套框架,做了很多优化,进程内流式处理, 玩的花样很多。 主要是解决广告过滤,聚合,反过滤,添加多个异步子任务。 不过还是会阻塞 io 。 😂
|