日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

Akka的Hello World(二)Akka的Actor生命周期

發布時間:2025/3/19 编程问答 35 豆豆
生活随笔 收集整理的這篇文章主要介紹了 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生命周期的全部內容,希望文章能夠幫你解決所遇到的問題。

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