使用scala,基於akka的actor併發模型。
importakka.actor.actorimportakka.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是一種單向訊息傳送...