Они решают разные проблемы.Актеры хороши в решении задач параллельных задач .В то время как параллельные коллекции хорошо решают проблемы параллельных данных .Я не думаю, что они являются взаимоисключающими - вы можете использовать параллельные коллекции в актерах и параллельные коллекции, содержащие акторов.
Редактирование - быстрый тест: даже что-то простое, например, цикл уведомления актера, дает преимущества.
В следующем коде мы регистрируем миллион актеров в реестре актеров, который должен уведомить их о событии.
Непараллельный цикл уведомлений (registry foreach {}) занимает в среднем 2,8 секунды на моей машине (4-ядерный ноутбук с частотой 2,5 ГГц).Когда используется параллельный цикл сбора (registry.par.foreach {}), он занимает 1,2 секунды и использует все четыре ядра.
import actors.Actor
case class Register(actor: Actor)
case class Unregister(actor: Actor)
case class Message( contents: String )
object ActorRegistry extends Actor{
var registry: Set[Actor] = Set.empty
def act() {
loop{
react{
case reg: Register => register( reg.actor )
case unreg: Unregister => unregister( unreg.actor )
case message: Message => fire( message )
}
}
}
def register(reg: Actor) { registry += reg }
def unregister(unreg: Actor) { registry -= unreg }
def fire(msg: Message){
val starttime = System.currentTimeMillis()
registry.par.foreach { client => client ! msg } //swap registry foreach for single th
val endtime = System.currentTimeMillis()
println("elapsed: " + (endtime - starttime) + " ms")
}
}
class Client(id: Long) extends Actor{
var lastmsg = ""
def act() {
loop{
react{
case msg: Message => got(msg.contents)
}
}
}
def got(msg: String) {
lastmsg = msg
}
}
object Main extends App {
ActorRegistry.start
for (i <- 1 to 1000000) {
var client = new Client(i)
client.start
ActorRegistry ! Register( client )
}
ActorRegistry ! Message("One")
Thread.sleep(6000)
ActorRegistry ! Message("Two")
Thread.sleep(6000)
ActorRegistry ! Message("Three")
}