作者热门文章
- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我在一台主机上启动了两个远程 actor,它们只回显发送给他们的任何内容。然后我创建另一个 Actor ,它向两个 Actor 发送一些消息(使用 !! ),并保留一个包含这些 Actor 的回复的 Future 对象列表。然后我遍历这个 List 获取每个 Future 的结果。问题是大多数时候一些 future 永远不会返回,即使 Actor 声称它已经发送了回复。问题是随机发生的,有时它会通过整个列表,但大多数时候它会卡在某个点并无限期挂起。
这是一些在我的机器上产生问题的代码:
sink.scala:
import scala.actors.Actor
import scala.actors.Actor._
import scala.actors.Exit
import scala.actors.remote.RemoteActor
import scala.actors.remote.RemoteActor._
object Sink {
def main(args: Array[String]): Unit = {
new RemoteSink("node03-0",43001).start()
new RemoteSink("node03-1",43001).start()
}
}
class RemoteSink(name: String, port: Int) extends Actor
{
def act() {
println(name+" starts")
trapExit=true
alive(port)
register(Symbol(name),self)
loop {
react {
case Exit(from,reason) =>{
exit()
}
case msg => reply{
println(name+" sending reply to: "+msg)
msg+" back at you from "+name
}
}
}
}
}
import scala.actors.Actor
import scala.actors.Actor._
import scala.actors.remote.Node;
import scala.actors.remote.RemoteActor
import scala.actors.remote.RemoteActor._
object Source {
def main(args: Array[String]):Unit = {
val peer = Node("127.0.0.1", 43001)
val source = new RemoteSource(peer)
source.start()
}
}
class RemoteSource(peer: Node) extends Actor
{
def act() {
trapExit=true
alive(43001)
register(Symbol("source"),self)
val sinks = List(select(peer,Symbol("node03-0"))
,select(peer,Symbol("node03-1"))
)
sinks.foreach(link)
val futures = for(sink <- sinks; i <- 0 to 20) yield sink !! "hello "+i
futures.foreach( f => println(f()))
exit()
}
}
最佳答案
我猜你的问题是由于这一行:
futures.foreach( f => println(f()))
futures.foreach(f => f.foreach(r => println(r)))
for (future <- futures; result <- future) { println(result) }
关于scala - 将多个 future 与多个远程参与者一起使用时,程序会挂起,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/3356823/
我是一名优秀的程序员,十分优秀!