p*****2
发帖数: 21240 | 1 future之间，以及future和main thread之间，一般通过什么方式通信。有啥好的吗？ |
l**********n
发帖数: 8443 | 2 啥意思？ countdown latch， cyclic barrier
【在 p*****2 的大作中提到】
: future之间，以及future和main thread之间，一般通过什么方式通信。有啥好的吗？
|
p*****2
发帖数: 21240 | 3 传递数据 比如actor的mailbox
golang的gochannel
【在 l**********n 的大作中提到】
: 啥意思？ countdown latch， cyclic barrier
|
c******o
发帖数: 1277 | 4 标准做法就是组合future 成一个大的future(map/zip/flatMap)
dependency会自动解决的。这样不能适用与你的要求？
基本上就像组装机器／pipeline一样的。和函数的互相组合也类似。 |
l**********n
发帖数: 8443 | 5 eventbus?
【在 p*****2 的大作中提到】
: future之间，以及future和main thread之间，一般通过什么方式通信。有啥好的吗？
|
p*****2
发帖数: 21240 | 6
但是future之间不能通信呀。
【在 c******o 的大作中提到】
: 标准做法就是组合future 成一个大的future(map/zip/flatMap)
: dependency会自动解决的。这样不能适用与你的要求？
: 基本上就像组装机器／pipeline一样的。和函数的互相组合也类似。
|
p*****2
发帖数: 21240 | 7
那还是上actor吧。
【在 l**********n 的大作中提到】
: eventbus?
|
p*****2
发帖数: 21240 | 8
大牛说说用什么eventbus好用？
【在 l**********n 的大作中提到】
: eventbus?
|
c******o
发帖数: 1277 | 9 举个例吧，在同一个JVM里有什么是需要future互相通讯的？
一般都能拆分成足够小的单个的future互相组合达到你的要求。 |
p*****2
发帖数: 21240 | 10 producer consumer
【在 c******o 的大作中提到】
: 举个例吧，在同一个JVM里有什么是需要future互相通讯的？
: 一般都能拆分成足够小的单个的future互相组合达到你的要求。
|
p*****2
发帖数: 21240 | 11 stm应该也算个不错的选择吧
【在 c******o 的大作中提到】
: 举个例吧，在同一个JVM里有什么是需要future互相通讯的？
: 一般都能拆分成足够小的单个的future互相组合达到你的要求。
|
c******o
发帖数: 1277 | 12 忘了回这个， 我的slides有啊：
http://www.slideshare.net/hangzhao54/fp-in-scala-part-2?qid=3a1
16页
【在 p*****2 的大作中提到】
: producer consumer
|
p*****2
发帖数: 21240 | 13
promise只能写一次吧？而且不能回写。
【在 c******o 的大作中提到】
: 忘了回这个， 我的slides有啊：
: http://www.slideshare.net/hangzhao54/fp-in-scala-part-2?qid=3a1
: 16页
|
c******o
发帖数: 1277 | 14 那你要的就不是future，是一个persistent 的channel.
可以用STM/RXjava/Actor都可以。
也有可能你要的是一个streaming processing tool, 那就是Iteratee/Machines (
https://www.playframework.com/documentation/2.0/Iteratees
https://github.com/scalaz/scalaz-stream
) |
