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就好了。
|
