本節主要內容：
1. 停止Actor

1. 停止Actor

（1）通過ActorSystem.shutdown方法停止所有 Actor的運行

/* *停止Actor:ActorSystem.shutdown方法 */ object Example_10 extends App{import akka.actor.Actorimport akka.actor.ActorSystemimport akka.actor.Propsclass FirstActor extends Actor with ActorLogging{var child:ActorRef = context.actorOf(Props[MyActor], name = "myActor")def receive = {//向MyActor發送消息case x => child ! x;log.info("received "+x)}override def postStop(): Unit = {log.info("postStop In FirstActor")}}class MyActor extends Actor with ActorLogging{def receive = {case "test" => log.info("received test");case _ => log.info("received unknown message");}override def postStop(): Unit = {log.info("postStop In MyActor")}}val system = ActorSystem("MyActorSystem")val systemLog=system.log//創建FirstActor對象val firstactor = system.actorOf(Props[FirstActor], name = "firstActor")systemLog.info("準備向firstactor發送消息")//向firstactor發送消息firstactor!"test"firstactor! 123//關閉ActorSystem，停止所有Acotr運行system.shutdown() }

代碼運行結果：

[INFO] [04/02/2016 21:51:34.440] [main] [ActorSystem(MyActorSystem)] 準備向firstactor發送消息 [INFO] [04/02/2016 21:51:34.441] [MyActorSystem-akka.actor.default-dispatcher-4] [akka://MyActorSystem/user/firstActor/myActor] received test [INFO] [04/02/2016 21:51:34.441] [MyActorSystem-akka.actor.default-dispatcher-2] [akka://MyActorSystem/user/firstActor] received test [INFO] [04/02/2016 21:51:34.441] [MyActorSystem-akka.actor.default-dispatcher-2] [akka://MyActorSystem/user/firstActor] received 123 [INFO] [04/02/2016 21:51:34.441] [MyActorSystem-akka.actor.default-dispatcher-4] [akka://MyActorSystem/user/firstActor/myActor] received unknown message [INFO] [04/02/2016 21:51:34.446] [MyActorSystem-akka.actor.default-dispatcher-4] [akka://MyActorSystem/user/firstActor/myActor] postStop In MyActor [INFO] [04/02/2016 21:51:34.447] [MyActorSystem-akka.actor.default-dispatcher-5] [akka://MyActorSystem/user/firstActor] postStop In FirstActor

（2）通過context.stop方法停止Actor的運行

/* *停止Actor:context.stop方法 */ object Example_11 extends App{import akka.actor.Actorimport akka.actor.ActorSystemimport akka.actor.Propsclass FirstActor extends Actor with ActorLogging{var child:ActorRef = context.actorOf(Props[MyActor], name = "myActor")def receive = {case "stop"=>context.stop(child)case x =>{//向MyActor發送消息child ! xlog.info("received "+x)}}override def postStop(): Unit = {log.info("postStop In FirstActor")}}class MyActor extends Actor with ActorLogging{def receive = {case "test" => log.info("received test");case _ => log.info("received unknown message");}override def postStop(): Unit = {log.info("postStop In MyActor")}}val system = ActorSystem("MyActorSystem")val systemLog=system.log//創建FirstActor對象val firstactor = system.actorOf(Props[FirstActor], name = "firstActor")systemLog.info("準備向firstactor發送消息")//向firstactor發送消息firstactor!"test"firstactor! 123firstactor!"stop"}

代碼運行結果：

[INFO] [04/02/2016 22:02:48.760] [main] [ActorSystem(MyActorSystem)] 準備向firstactor發送消息 [INFO] [04/02/2016 22:02:48.761] [MyActorSystem-akka.actor.default-dispatcher-5] [akka://MyActorSystem/user/firstActor/myActor] received test [INFO] [04/02/2016 22:02:48.761] [MyActorSystem-akka.actor.default-dispatcher-2] [akka://MyActorSystem/user/firstActor] received test [INFO] [04/02/2016 22:02:48.762] [MyActorSystem-akka.actor.default-dispatcher-2] [akka://MyActorSystem/user/firstActor] received 123 [INFO] [04/02/2016 22:02:48.762] [MyActorSystem-akka.actor.default-dispatcher-5] [akka://MyActorSystem/user/firstActor/myActor] received unknown message [INFO] [04/02/2016 22:02:48.763] [MyActorSystem-akka.actor.default-dispatcher-5] [akka://MyActorSystem/user/firstActor/myActor] postStop In MyActor

代碼的重點為

class FirstActor extends Actor with ActorLogging{var child:ActorRef = context.actorOf(Props[MyActor], name = "myActor")def receive = {case "stop"=>context.stop(child)case x =>{//向MyActor發送消息child ! xlog.info("received "+x)}}override def postStop(): Unit = {log.info("postStop In FirstActor")}}

中的case “stop”=>context.stop(child)，直接通過context.stop方法停止Actor的運行。注意程序中并沒有使用system.shutdown方法，因此整個程序的不會停止，如下圖所示

（3）通過akka.actor.PoisonPill消息停止Actor的運行

/* *停止Actor:使用akka.actor.PoisonPill */ object Example_12 extends App{import akka.actor.Actorimport akka.actor.ActorSystemimport akka.actor.Propsimport akka.actor.PoisonPillclass FirstActor extends Actor with ActorLogging{var child:ActorRef = context.actorOf(Props[MyActor], name = "myActor")def receive = {//向child發送PoisonPill停止其運行case "stop"=>child!PoisonPillcase x =>{//向MyActor發送消息child ! xlog.info("received "+x)}}override def postStop(): Unit = {log.info("postStop In FirstActor")}}class MyActor extends Actor with ActorLogging{def receive = {case "test" => log.info("received test");case _ => log.info("received unknown message");}override def postStop(): Unit = {log.info("postStop In MyActor")}}val system = ActorSystem("MyActorSystem")val systemLog=system.log//創建FirstActor對象val firstactor = system.actorOf(Props[FirstActor], name = "firstActor")systemLog.info("準備向firstactor發送消息")//向firstactor發送消息firstactor!"test"firstactor! 123firstactor!"stop"}

代碼運行結果：

[INFO] [04/02/2016 22:12:09.947] [main] [ActorSystem(MyActorSystem)] 準備向firstactor發送消息 [INFO] [04/02/2016 22:12:09.947] [MyActorSystem-akka.actor.default-dispatcher-2] [akka://MyActorSystem/user/firstActor/myActor] received test [INFO] [04/02/2016 22:12:09.947] [MyActorSystem-akka.actor.default-dispatcher-4] [akka://MyActorSystem/user/firstActor] received test [INFO] [04/02/2016 22:12:09.947] [MyActorSystem-akka.actor.default-dispatcher-4] [akka://MyActorSystem/user/firstActor] received 123 [INFO] [04/02/2016 22:12:09.947] [MyActorSystem-akka.actor.default-dispatcher-2] [akka://MyActorSystem/user/firstActor/myActor] received unknown message [INFO] [04/02/2016 22:12:09.951] [MyActorSystem-akka.actor.default-dispatcher-4] [akka://MyActorSystem/user/firstActor/myActor] postStop In MyActor

代碼與Exampel_11中的不同之處在于

//向child發送PoisonPill停止其運行 case "stop"=>child!PoisonPill

它使用不是context.stop方法，而是向MyActor發送了PoisonPill消息，其它代碼不變。

還有一種gracefulStop方法可以停止Actor的運行，這部分內容等了解完Future類的作用原理之后再來討論

總結

以上是生活随笔為你收集整理的Akka并发编程——第五节：Actor模型（四） 停止Actor的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。