Akka并发编程——第七节:Actor模型(六)
主要内容:
1. Typed Actor定义
2. Typed Actor创建
3. 消息发送
1. Typed Actor定义
Akka中的Typed Actor是Active Objects设计模式的实现,Active Objects模式将方法的执行和方法的调用进行解耦合,从而为程序引入并发性。Typed Actor由公用的接口和对应实现两部分构成,其后面深层次的实现使用的是代理模式,即通过使用JDK中的动态代理来实现,在调用接口的方法时自动分发到实现接口的对象上。Typed Actor的定义[ ]如下所示。
trait Squarer {//fire-and-forget消息def squareDontCare(i: Int): Unit//非阻塞send-request-reply消息def square(i: Int): Future[Int]//阻塞式的send-request-reply消息def squareNowPlease(i: Int): Option[Int]//阻塞式的send-request-reply消息def squareNow(i: Int): Int}class SquarerImpl(val name: String) extends Squarer {def this() = this("SquarerImpl")def squareDontCare(i: Int): Unit = i * idef square(i: Int): Future[Int] = Promise.successful(i * i).futuredef squareNowPlease(i: Int): Option[Int] = Some(i * i)def squareNow(i: Int): Int = i * i}
trait Squarer中定义了4个方法:
(1)def squareDontCare(i: Int): Unit方法:返回值类型为Unit,它类似于Untyped Actor中的fire-and-forget消息发送模型,即!和tell方法调用。
(2)def square(i: Int): Future[Int]:返回值类型为Future[Int],它类似于Untyped Actor中的send-request-reply消息发送模型,即?和ask方法调用,此种调用是非阻塞的。
(3)def squareNowPlease(i: Int): Option[Int]:返回值类型为Option[Int](Option类可以是Scala.Option[_]也可以是akka.japi.Option
2. 创建Typed Actor
通过下列代码创建Typed Actor实例。
//直接通过默认的构造函数创建Typed Actor
val mySquarer: Squarer =TypedActor(system).typedActorOf(TypedProps[SquarerImpl]())
//直接通过默认的构造函数创建Typed Actor并指定Typed Actor名称
val mySquarer: Squarer =TypedActor(system).typedActorOf(TypedProps[SquarerImpl](),"mySquarer")
//通过非默认的构造函数创建Typed Actor并指定Typed Actor名称
val otherSquarer: Squarer = TypedActor(system).typedActorOf(TypedProps(classOf[Squarer],new SquarerImpl("SquarerImpl")), "otherSquarer")
上面代码演示的是使用构造函数和非默认构造函数创建Typed Actor,其中Squarer为代理的类型,SquarerImpl为具体实现的类型。
3. 消息发送
//fire-forget消息发送mySquarer.squareDontCare(10)//send-request-reply消息发送val oSquare = mySquarer.squareNowPlease(10)val iSquare = mySquarer.squareNow(10)//Request-reply-with-future 消息发送val fSquare = mySquarer.square(10)val result = Await.result(fSquare, 5 second)
代码mySquarer.squareDontCare(10)是单向消息发送,方法将在另外一个线程上异步地执行;val oSquare = mySquarer.squareNowPlease(10)、val iSquare = mySquarer.squareNow(10)为Request-reply消息发送,在特定时间内以阻塞的方式执行,对于.squareNowPlease(10)方法如果在对应时间内没有返回结果则返回值为None,否则返回值为Option[Int]类型,对于squareNow(10)方法如果在对应时间内无返回值则会抛出异常Java.util.concurrent.TimeoutException,否则返回Int类型值;val fSquare = mySquarer.square(10)为Request-reply-with-future式的消息发送,以非阻塞的方式执行,可以通过val result = Await.result(fSquare, 5 second)获取执行结果。完整代码如下所示。
/** Typed Actor*/
object Example_01 extends App {import akka.event.Loggingimport scala.concurrent.{ Promise, Future }import akka.actor.{ TypedActor, TypedProps }import scala.concurrent.duration._trait Squarer {//fire-and-forget消息def squareDontCare(i: Int): Unit//非阻塞send-request-reply消息def square(i: Int): Future[Int]//阻塞式的send-request-reply消息def squareNowPlease(i: Int): Option[Int]//阻塞式的send-request-reply消息def squareNow(i: Int): Int}class SquarerImpl(val name: String) extends Squarer {def this() = this("SquarerImpl")def squareDontCare(i: Int): Unit = i * idef square(i: Int): Future[Int] = Promise.successful(i * i).futuredef squareNowPlease(i: Int): Option[Int] = Some(i * i)def squareNow(i: Int): Int = i * i}val system = ActorSystem("TypedActorSystem")val log = Logging(system, this.getClass)//使用默认构造函数创建Typed Actorval mySquarer: Squarer =TypedActor(system).typedActorOf(TypedProps[SquarerImpl](),"mySquarer")//使用非默认构造函数创建Typed Actorval otherSquarer: Squarer =TypedActor(system).typedActorOf(TypedProps(classOf[Squarer],new SquarerImpl("SquarerImpl")), "otherSquarer")//fire-forget消息发送mySquarer.squareDontCare(10)//send-request-reply消息发送val oSquare = mySquarer.squareNowPlease(10)log.info("oSquare="+oSquare)val iSquare = mySquarer.squareNow(10)log.info("iSquare="+iSquare)//Request-reply-with-future 消息发送val fSquare = mySquarer.square(10)val result = Await.result(fSquare, 5 second)log.info("fSquare="+result)system.shutdown()
}
代码运行结果如下:
[INFO] [03/21/2016 21:15:50.592] [main] [Example12_9(akka://TypedActorSystem)]oSquare=Some(100)[INFO][03/21/201621:15:50.649][main][Example129(akka://TypedActorSystem)] iSquare=100
[INFO] [03/21/2016 21:15:50.649] [main] [Example12_9$(akka://TypedActorSystem)] fSquare=100
Akka并发编程——第七节:Actor模型(六)相关推荐
- Akka并发编程——第八节:Actor模型(七)
本节主要内容 停止运行Typed Actor 当Typed Actor不再需要时要将其停止,有3种方法停止Typed Actor的运行: (1)通过system.shutdown()停止ActorSy ...
- Akka并发编程——第三节:Actor模型(二)
本节主要内容: Actor API解析 1. Actor API解析 Actor中的主要成员变量和方法定义如下: package akka.actor trait Actor extends scal ...
- Akka并发编程——第五节:Actor模型(四) 停止Actor
本节主要内容: 1. 停止Actor 1. 停止Actor (1)通过ActorSystem.shutdown方法停止所有 Actor的运行 /* *停止Actor:ActorSystem.shutd ...
- 【Akka】Akka并发编程设计
1.概述 转载:Akka并发编程设计 2. 响应式系统设计 Akka 被称为是一个响应式平台,更具体的说,它是 Typesafe 响应式平台的一部分.响应式宣言中包含了 4 个准则,也可以说是设计目标 ...
- 并发编程中的重重量级模型和轻量级模型
并发编程中的重重量级模型和轻量级模型 使用轻量级并发开发 不管是Amdahl定律还是Gustafson的定律都没有考虑引入并发需要付出的额外开销.同时也没有考虑那些可以将顺序代码转变成可以利用并行优势 ...
- 并发编程(七)好用的线程池ThreadPoolExecutor
并发编程专栏系列博客 并发编程(一)python并发编程简介 并发编程(二)怎样选择多线程多进程和多协程 并发编程(三)Python编程慢的罪魁祸首.全局解释器锁GIL 并发编程(四)如何使用多线程, ...
- 高并发编程-重新认识Java内存模型(JMM)
文章目录 从CPU到内存模型 内存模型如何确保缓存一致性 并发变成需要解决的问题 (原子性.可见性.有序性) 内存模型需要解决的问题 Java内存模型 JMM的API实现 原子性 synchroniz ...
- 并发编程(三)---共享模型之管程
三.共享模型之管程 3.1临界区(Critical Section) 一个程序运行多个线程本身是没有问题的 问题出在多个线程访问共享资源 多个线程读取共享资源其实也没有问题 在多个线程对共享资源读写操 ...
- Python并发编程之多进程(生产者消费者模型)
十二.生产者消费者模型 1.什么是生产者消费者模型 生产者 : 程序中负责产生数据的一方 消费者 : 程序中负责处理数据的一方 2.为什么引入生产者消费者模型 在并发编程中, 生产者消费者模式通过一个 ...
最新文章
- 基于TensorFlow理解三大降维技术:PCA、t-SNE 和自编码器
- 委员建议开辟多种科研资助模式,呼唤“科研悬赏制”
- matlab增强对数字辅助,MATLAB 增强对数字辅助 RF MIMO 系统的设计支持
- C++用模板元编程进行循环展开的性能测试
- Alsa驱动分析(转)
- java queue源码_java源码解读--queue
- docker运行中的container怎么修改之前run时的env
- Bootstrap 和 LESS
- java判断输入值是否在数组_java判断特定值是否在数组中的方法
- 操作系统--第八章 磁盘存储器--习题答案
- java修改硬盘序列号怎么查_硬盘序列号的查看方法,如果多块硬盘如何查是哪块块的哪块要换掉?...
- Win10桌面点鼠标右键一直转圈的解决方法
- ubuntu 安装osx 主题 转自linux公社
- 2003服务器密码怎么修改密码,2003服务器设置密码
- pandas 取某一列数据的几种形式比较
- 耐得住寂寞,是一种境界和品味
- 尝鲜——Windows11 安装教程 (无视TMP2.0)
- P1463 [POI2001][HAOI2007]反素数 题解
- php写的软件帮助手册源码使用帮助源码html模版源码,系统依附HDSYSCMS内容系统
- GAN原理及简单mnist生成图片
热门文章
- 4行代码AC——L1-038 新世界 (5分)
- 【最详细】数据结构(C语言版 第2版)第五章课后习题答案 严蔚敏 等 编著
- 10行代码AC——UVa 10940(Throwing cards away II 数学规律+约瑟夫环)
- xp系统怎么关dhcp服务器,怎样解决Win XP操作系统DHCP故障:获取未使用的IP地址
- head在linux命令中什么意思,Linux系统中head命令如何使用
- 计算机任务驱动法教学应用,任务驱动教学法在计算机教学中的应用
- python爬虫经典段子_Python爬虫实战(1):爬取糗事百科段子
- php echo中的点是什么?,php编程中echo用逗号和用点号连接的区别,echo逗号_PHP教程...
- 如何设置jinternalframe无边框_word文档美化技巧:加个边框提升版面颜值
- 计算机有哪两种绘图,能被计算机接受的数字图像有哪两种?它们分别由什么构成?...