Actor併發模型入門

2021-07-27 23:21:35 字數 1177 閱讀 9659

使用scala,基於akka的actor併發模型。

importakka.actor.actor

importakka.actor.props

importakka.actor.actorsystem

importakka.routing.roundrobinpool

//定義乙個封閉的特質

sealed traitsumtrait

// 定義乙個case類,混合特質sumtrait

case classresult(value: int)extendssumtrait

//sealed case class result(value:int)

// 計算用的actor

classsumactorextendsactor

cal += i

}println("flag : "+ flag +".")

returncal

}defreceive =

}// 列印結果用的actor

classprintactorextendsactor

}// 主actor,傳送計算指令給sumactor,傳送列印指令給printactor

classmasteractorextendsactor

case_ => println("未知 in masteractor...")

源**工程

下次會發布akk remote和akka cluster的例子。

使用scala的actor模型實現併發的例子

created by lengmengwuxie on 2016 7 29.import scala.actors.import scala.actors.actor.設計方式 1,任何模擬物件在所有其他模擬物件完成對時間n的處理之前,都不應該處理時間n 1的事件 2,假設要實現所有模擬物件同步執行...

Akka併發程式設計 4 Actor模型 四)

摘要 本節主要內容 1.停止actor 1 通過actorsystem.shutdown方法停止該system下所有actor的執行 2 通過context.stop方法停止actor的執行 3 通過akka.actor.poisonpill訊息停止actor的執行 本節主要內容 停止actor 1...

Akka併發程式設計 5 Actor模型 五)

摘要 本將主要內容 1.訊息傳送,fire and forget訊息模型 2.訊息傳送,send and receive future訊息模型 akka提供了兩種訊息模型 fire and forget和send and receive future。fire and forget是一種單向訊息傳送...