scala actor编程之对象传递

scala 最吸引人的一点就是actor并发编程了。但是纵观scala官方文档,baidu文档,IBM文档都写的通过字符串传呀传,如果用作actor编程说明当然没有问题。但是在正式开放中,光传字符串就显的势单力薄了。

所以如何传对象呢?

先看通过字符串传递消息的模型:

消息接收类:

import scala.actors.Actor
import org.andy.rtbd.actor.ActorDeal

class ActorRev1 extends Actor{

    def act()={
      while(true){
        receive  {case str:String =>println("There is say "+str)
          case _=>println("There is no message ")
        }
      }
    }

    def dealAD(adm:ActorDeal)={

      adm.dealPrint

    }
}

消息发送类

object ActorSed {

  def main(args: Array[String]): Unit = {
    var ar = new ActorRev1()
    ar.start

    ar!"111"
  }

}

执行ActorSed,看一下结果:

There is say 111

这个结果是最简单通过字符串传递消息的,那么我们改造一下,看看如何传递对象。

首先,添加一个class。

class ActorDeal {

  var msg:String=""

  def dealPrint() = {
    println("From deal " + msg)
  }
}

然后改造消息接受类:

 1 import scala.actors.Actor
 2 import org.andy.rtbd.actor.ActorDeal
 3
 4 class ActorRev1 extends Actor{
 5
 6     def act()={
 7       while(true){
 8         receive  {
 9           case ad:ActorDeal => dealAD(ad)
10           case str:String =>println("There is say "+str)
11           case _=>println("There is no message ")
12         }
13       }
14     }
15
16     def dealAD(adm:ActorDeal)={
17
18       adm.dealPrint
19
20     }
21 }

高亮的部分是新增的消息接收选项,so easy,我们对发送类稍加改造即可测试:

 1 object ActorSed {
 2
 3   def main(args: Array[String]): Unit = {
 4     var ar = new ActorRev1()
 5     ar.start
 6     var adm = new ActorDeal
 7     adm.msg="HEHE"
 8
 9     ar!"111"
10     ar!adm
11   }
12
13 }

OK,我们可以看结果了:

1 There is say 111
2 From deal HEHE

虽说,代码量很小,但找了半天都没找到这方面的资料。自己苦逼看了半天,才蒙出来的。

如果对您有用的话,请推荐一下。谢谢

时间: 2024-08-13 20:49:00

scala actor编程之对象传递的相关文章

68:Scala并发编程原生线程Actor、Cass Class下的消息传递和偏函数实战解析及其在Spark中的应用源码解析

今天给大家带来的是王家林老师的scala编程讲座的第68讲:Scala并发编程原生线程Actor.Cass Class下的消息传递和偏函数实战解析 昨天讲了Actor的匿名Actor及消息传递,那么我们今天来看一下原生线程Actor及CassClass下的消息传递,让我们从代码出发: case class Person(name:String,age:Int)//定义cass Class class HelloActor extends Actor{//预定义一个Actor  def act()

Scala编程--函数式对象

本章的重点在于定义函数式对象,也就是说,没有任何可变状态的对象的类.作为运行的例子,我们将创造若干把分数作为不可变对象建模的类的变体.在这过程中,我们会展示给你Scala面向对象编程的更多方面:类参数和构造函数,方法和操作符,私有成员,子类方法重载,先决条件检查,同类方法重载和自指向. 6.1 类Rational的式样书 一个,或许不怎么重要的,发现是数学上,分数不具有可变的状态.一个分数加到另外一个分数上,产生的结果是一个新的分数.而原来的数不会被“改变”.我们将在本章设计的不可变的Ratio

Scala 深入浅出实战经典 第67讲:Scala并发编程匿名Actor、消息传递、偏函数解析

王家林亲授<DT大数据梦工厂>大数据实战视频 Scala 深入浅出实战经典(1-87讲)完整视频.PPT.代码下载:百度云盘:http://pan.baidu.com/s/1c0noOt6 腾讯微云:http://url.cn/TnGbdC 360云盘:http://yunpan.cn/cQ4c2UALDjSKy 访问密码 45e2土豆:http://www.tudou.com/programs/view/LwsfuGIsWEk/优酷:http://v.youku.com/v_show/id_

scala并发编程Actor实战

今天在这里跟大家分享下王家林老师讲的scala编程中的actor的并发编程. 在java中,同时进行一个操作的时候,java会先把共享数据锁死,从而避免不同的操作来同时操作一个数据,这个就形成了资源调度的问题,而且如果用不好,还会造成死锁.而在scala中,通过类似消息的发送和接收的队列的方式,来访问同一个共享数据,这样一来,当轮到一个操作来访问某个数据的时候,不会发生另一个操作也同时访问的该数据的情况,这样就避免了资源争用的问题及死锁的发生.下面我们通过一个小小的实例来看看scala是怎样通过

Scala并发编程匿名Actor、消息传递、偏函数实

学习了Scala并发编程匿名Actor.消息传递.偏函数实战解析及其在Spark源码中的应用解析,具体来说Scala就是通过actor_message=actor{},实现匿名Actor并发消息传递的,这样就的方法在spark用应用很广泛,极大地简化了程序编写,提高效率: def main(args:Array[string]){ val actor_message=actor{ while(true){ receive{ Case msg=>println( “messsage  from i

Scala 深入浅出实战经典 第68讲:Scala并发编程原生线程Actor、Cass Class下的消息传递和偏函数实战解析

王家林亲授<DT大数据梦工厂>大数据实战视频 Scala 深入浅出实战经典(1-87讲)完整视频.PPT.代码下载: 百度云盘:http://pan.baidu.com/s/1c0noOt6 腾讯微云:http://url.cn/TnGbdC 360云盘:http://yunpan.cn/cQ4c2UALDjSKy 访问密码 45e2土豆:http://www.tudou.com/programs/view/mm3eDHk3T5o/优酷:http://v.youku.com/v_show/id

Scala入门到精通——第二十六节 Scala并发编程基础

作者:摇摆少年梦 视频地址:http://www.xuetuwuyou.com/course/12 本节主要内容 Scala并发编程简介 Scala Actor并发编程模型 react模型 Actor的几种状态 Actor深入使用解析 本节主要介绍的scala并发编程的基本思想,由于scala在2.10版本之后宣布使用akka作为其并发编程库,因此本节只进行基础性的内容介绍,后面将把重点放在akka框架的讲解上. 1. Scala并发编程简介 2003 年,Herb Sutter 在他的文章 "

Scala函数式编程进阶

1 package com.dtspark.scala.basics 2 3 /** 4 * 函数式编程进阶: 5 * 1,函数和变量一样作为Scala语言的一等公民,函数可以直接赋值给变量: 6 * 2, 函数更长用的方式是匿名函数,定义的时候只需要说明输入参数的类型和函数体即可,不需要名称,但是如果你要使用的话,一般会把这个匿名函数赋值给一个变量(其实是val常量),Spark源码中大量存在这种语法,必须掌握: 7 * 3, 函数可以作为参数直接传递给函数,这极大的简化的编程的语法,为什么这

Scala之类型参数和对象

泛型 类型边界 视图界定 逆变和协变 上下文界定 源代码 1.泛型 泛型用于指定方法或类可以接受任意类型参数,参数在实际使用时才被确定,泛型可以有效地增强程序的适用性, 使用泛型可以使得类或方法具有更强的通用性. 在Scala中用方括号来定义类型参数,即用[]表示, 如 class Pair[T, S](val first, val) 以上将定义一个带有两个类型参数T和S的类,带有类型参数的类是泛型的.如果把类型参数替换成实际的类型将得到普通的类. *简单理解就是类型或者方法后面加个中括号就表示