Akka的Hello World(二)Akka的Actor生命周期
生活随笔
收集整理的這篇文章主要介紹了
Akka的Hello World(二)Akka的Actor生命周期
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
(〇)介紹
每當一個Actor停止時,它的所有孩子也會被遞歸地停止。此行為極大地簡化了資源清理,并有助于避免資源泄漏,例如由打開sockets?和文件引起的資源泄漏。實際上,處理低級多線程代碼時常常被忽視的困難是各種并發資源的生命周期管理。
要停止一個Actor,推薦的模式是在Actor內部調用getContext().stop(getSelf())來自行停止,通常作為對某些用戶定義的停止消息的響應,或者當actor完成其作業時。通過調用getContext().stop(actorRef),停止另一個Actor,但是以這種方式阻止任意Actor被認為是一種不好的做法:應該嘗試向他們發送一個PoisonPill或自定義停止消息。
Akka actor API公開了許多可以在Actor實現中覆蓋的生命周期鉤子。最常用的是preStart()和postStop()。
- preStart() 在actor開始之后但在它處理第一條消息之前調用。
- postStop()在actor停止之前調用。此后不會處理任何消息。
讓我們在一個簡單的實驗中使用preStart()和postStop()生命周期鉤子來觀察我們停止一個Actor時的行為。
(一)創建maven工程并添加依賴。
?
(二)編寫代碼
?
import akka.actor.AbstractActor; import akka.actor.AbstractActor.Receive; import akka.actor.ActorRef; import akka.actor.ActorSystem; import akka.actor.Props;class StartStopActor1 extends AbstractActor {static Props props() {return Props.create(StartStopActor1.class, StartStopActor1::new);}@Overridepublic void preStart() {System.out.println("first started");getContext().actorOf(StartStopActor2.props(), "second");}@Overridepublic void postStop() {System.out.println("first stopped");}@Overridepublic Receive createReceive() {return receiveBuilder().matchEquals("stop",s -> {getContext().stop(getSelf());}).build();} }class StartStopActor2 extends AbstractActor {static Props props() {return Props.create(StartStopActor2.class, StartStopActor2::new);}@Overridepublic void preStart() {System.out.println("second started");}@Overridepublic void postStop() {System.out.println("second stopped");}// Actor.emptyBehavior is a useful placeholder when we don't// want to handle any messages in the actor.@Overridepublic Receive createReceive() {return receiveBuilder().build();} } public class ActorHierarchyExperiments {public static void main(String[] args) throws java.io.IOException {ActorSystem system = ActorSystem.create("testSystem");ActorRef first = system.actorOf(StartStopActor1.props(), "first");first.tell("stop", ActorRef.noSender());} }(三)運行
?(四)分析
當我們停止Actor first 時,它停止了它的子Actor? second,然后停下來。這種排序是嚴格的,在調用父項的postStop之前調用子項的所有 postStop()。
也就是說所有的子Actor都在父Acor結束之前結束。
總結
以上是生活随笔為你收集整理的Akka的Hello World(二)Akka的Actor生命周期的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Akka的Hello World(一)A
- 下一篇: Akka的Hello World(三)A