p*****2 发帖数: 21240 | 1 看了看可以指定observable和subscriber的线程池
对于map,flatmap这些operators,是运行在哪个线程呢? |
p*****2 发帖数: 21240 | |
c*********e 发帖数: 16335 | 3 你们公司不就是用rxjava吗?rxjava看来要火。
【在 p*****2 的大作中提到】 : 看了看可以指定observable和subscriber的线程池 : 对于map,flatmap这些operators,是运行在哪个线程呢?
|
s*i 发帖数: 5025 | 4 RxJava 跟其他 functional languages 的写法比较,ugly 到吐! |
p*****2 发帖数: 21240 | 5 有这个就不错了
java还能指望啥
:RxJava 跟其他 functional languages 的写法比较,ugly 到吐! |
c*********e 发帖数: 16335 | 6 RxJava是有明确目的和用途的,functional languages算个鸟。
【在 s*i 的大作中提到】 : RxJava 跟其他 functional languages 的写法比较,ugly 到吐!
|
n*w 发帖数: 3393 | 7 Java 8会不会好点?
【在 s*i 的大作中提到】 : RxJava 跟其他 functional languages 的写法比较,ugly 到吐!
|
n*****3 发帖数: 1584 | 8 does RxJava use java 8, if not,
switch to use java 8 's FP will require some extra work for them.
【在 n*w 的大作中提到】 : Java 8会不会好点?
|
H****S 发帖数: 1359 | 9 早就到java8了
【在 n*****3 的大作中提到】 : does RxJava use java 8, if not, : switch to use java 8 's FP will require some extra work for them.
|
n*****3 发帖数: 1584 | 10 cool
【在 H****S 的大作中提到】 : 早就到java8了
|
c*********e 发帖数: 16335 | 11 如果concurrency的java code是你自己写的,又何必要rxjava呢?直接在原来的代码里
加不就完了?
【在 p*****2 的大作中提到】 : 看了看可以指定observable和subscriber的线程池 : 对于map,flatmap这些operators,是运行在哪个线程呢?
|
d******e 发帖数: 2265 | 12 concurrency 是上一代的事情了吧。
rxjava,这个我没搞过啊,类似的东西是面向event stream driven app.
比如说,你有一个计步器,不听的想server发送event.
这样就可以看作一个stream。后台处理直接用stream.map.andthen.onsucess..
..
搞定了。
这里的backpressure process, 异步用刀的threadpool什么的,都给你搞定了。
你自己安心写处理的code就好了。
【在 c*********e 的大作中提到】 : 如果concurrency的java code是你自己写的,又何必要rxjava呢?直接在原来的代码里 : 加不就完了?
|
H****S 发帖数: 1359 | 13 不光是这个。rxjava所带动的reactive stream programming可以帮助你做到很多事情,
1。preemptive control:如果你的stream crash了,如何能让它clean up all the
unclosed resources and start again from a reasonable checkpoint _by itself_
2。stream和stream之间的操作:zip和merge是最常用的两种操作。鉴于stream本身是
纯异步的,如果要自己写这些操作绝对是nontrivial amount of work。
3。stream ordering:你可以选择让stream的items come strictly in order,或者是
fully parallell。
4。back pressure。看上去简单,但是rxjava一开始的支持是基本算没有的,直到后来
加了producer interface。我自己的感觉即便使用producer interface,在rxjava里面
实现backpressure control也不容易。我是自己写了些aqs based implementation的,
也许更好的办法。scalaz-stream的实现还是最好的,可惜preemption有问题,希
望重写的版本可以克服preemption。
【在 d******e 的大作中提到】 : concurrency 是上一代的事情了吧。 : rxjava,这个我没搞过啊,类似的东西是面向event stream driven app. : 比如说,你有一个计步器,不听的想server发送event. : 这样就可以看作一个stream。后台处理直接用stream.map.andthen.onsucess.. : .. : 搞定了。 : 这里的backpressure process, 异步用刀的threadpool什么的,都给你搞定了。 : 你自己安心写处理的code就好了。
|
c*********e 发帖数: 16335 | 14 rxjava是one thread, async. 但是,它的async,是用的epoll吗?
..
【在 d******e 的大作中提到】 : concurrency 是上一代的事情了吧。 : rxjava,这个我没搞过啊,类似的东西是面向event stream driven app. : 比如说,你有一个计步器,不听的想server发送event. : 这样就可以看作一个stream。后台处理直接用stream.map.andthen.onsucess.. : .. : 搞定了。 : 这里的backpressure process, 异步用刀的threadpool什么的,都给你搞定了。 : 你自己安心写处理的code就好了。
|