码迷,mamicode.com
首页 > 其他好文 > 详细

并行集合

时间:2015-05-15 19:40:05      阅读:114      评论:0      收藏:0      [点我收藏+]

标签:

使用并行集合,能够并行的访问集合,大幅提高性能。

举例:

1 val urls = List("http://scala-lang.org",
2   "https://github.com/yankay/scala-tour")
3 
4 def fromURL(url: String) = scala.io.Source.fromURL(url)
5   .getLines().mkString("\n")
6 
7 val t = System.currentTimeMillis()
8 urls.par.map(fromURL(_))
9 println("time: " + (System.currentTimeMillis - t) + "ms")

使用方法,就只是把urls.map修改为urls.par.map。

再举之前wordCount的例子:

1 val file = List("warn 2013 msg", "warn 2012 msg",
2   "error 2013 msg", "warn 2013 msg")
3 
4 def wordcount(str: String): Int = str.split(" ").count("msg" == _)
5 
6 val num = file.par.map(wordcount).par.reduceLeft(_ + _)
7 
8 println("wordcount:" + num)

在集合之前,使用前缀par.

并行集合

标签:

原文地址:http://www.cnblogs.com/wlwgcdxc/p/4506389.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!