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