上下文:我想编写烫伤作业(hadoop)来抓取页面,并且我想在 url 提取上设置超时(在 URLConnection 上没有超时,我想要其他超时情况的通用解决方案),即地图功能。
我正在考虑在所有资源释放后一些超时后被杀死的期货,因为它是内存关键代码。不确定在 scala API 中使用什么。
上下文:我想编写烫伤作业(hadoop)来抓取页面,并且我想在 url 提取上设置超时(在 URLConnection 上没有超时,我想要其他超时情况的通用解决方案),即地图功能。
我正在考虑在所有资源释放后一些超时后被杀死的期货,因为它是内存关键代码。不确定在 scala API 中使用什么。
虽然建议使用 Akka - 并且优于以下解决方案 - Scala 确实有自己的内置 Actor 模型,就像 Akka 一样,它可以做你想要的。可以在这里找到示例:
http://www.scala-lang.org/node/242
您可能需要 reactWithin 或 receiveWithin,其文档可在此处找到:
http://www.scala-lang.org/api/current/scala/actors/TIMEOUT$.html