学习了Scala并发编程实战初体验及其在Spark源码中的应用解析,具体来说Scala就是通过并发的Actor。实现发送和接收消息来并发访问的,这样就不存在共享数据的问题下面举例:
object First_Actor extends Actor{//第一个线程
def act(){
for(i<-1 to 10){
println("Step: "+i)
Thread.sleep(2000)
}
}
}
object Second_Actor extends Actor{//第二个线程
def act(){
for(i<-1 to 10){
println("Step Further: "+i)
Thread.sleep(2000)
}
}
}
main{
First_Actor.start
Second_Actor.start
}
原文:http://www.cnblogs.com/tom-lee/p/4672315.html