DT大数据梦工厂 第66讲
2015-07-23 20:33
225 查看
王家林亲授《DT大数据梦工厂》大数据实战视频“Scala深入浅出实战经典”视频、音频和PPT下载!第66讲:Scala并发编程实战初体验及其在Spark源码中的应用解析
百度云:http://pan.baidu.com/s/1pJ5jzHx
腾讯微云:http://url.cn/aSawrm
360云盘:http://yunpan.cn/cctL3QYACaVNa 访问密码 c0fb
本节王老师讲了scala并发编程的Actor。其原理是通过发送和接收消息来实现并发访问的,这样就不存在共享数据的问题。每一个数据都是新的,没有静态的数据。而java是通过synchronized或者lock把共享的数据锁起来来避免同时操作同一个数据。但是这样容易造成死锁和资源争用。而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://pan.baidu.com/s/1pJ5jzHx
腾讯微云:http://url.cn/aSawrm
360云盘:http://yunpan.cn/cctL3QYACaVNa 访问密码 c0fb
本节王老师讲了scala并发编程的Actor。其原理是通过发送和接收消息来实现并发访问的,这样就不存在共享数据的问题。每一个数据都是新的,没有静态的数据。而java是通过synchronized或者lock把共享的数据锁起来来避免同时操作同一个数据。但是这样容易造成死锁和资源争用。而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
}
将会交叉第打印各自的语句。
相关文章推荐
- 对HBase整个框架的理解
- 2015 Multi-University Training Contest 2 1006
- 基于Pre-Train的CNN模型的图像分类实验
- Hdu 5305 Friends 2015 Multi-University Training Contest 2
- HDU 5235 Friends (2015 Multi-University Training Contest 2 搜索+剪枝)
- LeetCode#70 Climbing Stairs
- 2015 Multi-University Training Contest 2 1004 苹果树 dp+单调队列
- 2015多校联合训练赛 hdu 5308 I Wanna Become A 24-Point Master 2015 Multi-University Training Contest 2 构造题
- 什么是大数据?
- 2015 Multi-University Training Contest 2 1006 Friends
- 理解OpenContrail(by quqi99)
- Lua中闭包详解 来自RingOfTheC[ring.of.the.c@gmail.com]
- activity_main.xml
- 一切成功源于积累——20150723 大数据分析 201501-201507 所有的亏损源于五分钟定律
- 算法杂货铺——分类算法之朴素贝叶斯分类(Naive Bayesian classification)
- error Link2005:"pulbic:_thiscall class:run()已经在main.class。obj中定义
- Rails 上传图片
- AIDL(不完整)
- CLOSE_WAIT TIME_WAIT
- Failure [INSTALL_FAILED_OLDER_SDK]解决办法