從Kestrel看Scala的核心程序模塊
之前曾介紹過Kestrel這個Scala實例教程,這個代碼實例在Twitter中也有用到,相當于Ruby中的Starling。有關Kestrel還有很多其他的細節,下面繼續介紹Scala的核心程序模塊,Scala的開發包以及Scala Actor。
讀完ManyClients.scala之后,基本上對Scala有一個大致的印象了,接著我們就開始讀Scala的核心程序模塊,從src/main/scala/net/kestrel開始。
需要介紹一些scala的package:
- ……
- import java.util.concurrent._
- import scala.actors.{Actor, Scheduler}
- import scala.actors.Actor._
- import scala.collection.mutable
- import org.apache.mina.core.session.IoSession
- ……
#t#在Scala里面主要用到了幾個開發包,java.util.concurrent是Java 5.0平臺上的多線程框架。org.apache.mina是Apache Mina提供的NIO開發包,因為走讀主要是為了了解Scala,所以就不多說這兩個包了,讓我們著重說一下scala的一個非常有用的多線程核心包actor。
actor,在Scala中幾乎占到了非常核心的地位(可以說就是Scala的核心)。有很多人幾乎是同時聽到actor和scala的。或者是因為scala有了actor,才決定用scala的。當然,scala不僅僅有actor,在后面的代碼中,你可以看到許多語言的設計,都使得actor的設計近乎***,簡潔的,可讀性很高的代碼,可以完成非常多的工作。
不過還是讓我們從簡單的actor開始吧,一個完整的actor寫法如下:
- import scala.actors.Actor
- class Redford extends Actor {
- def act() {
- println("A lot of what acting is, is paying attention.")
- }
- }
- val robert = new Redford
- robert.start
Redford繼承一個Actor的類(關于class和object在Scala的區別,我們稍后再說),它有一個函數,也就是線程運行的內容叫做act(),當線程啟動之后,就會執行這個act()函數。需要調用這個線程的時候,創建這個對象,然后調用robert.start線程就啟動了。
這個寫法其實沒有太多的精細,只是比Java的寫法少敲了一些鍵盤而已。這倒是沒有什么錯,但是往下看,我們多import進來一個package,就可以這樣寫了:
- import scala.actors.Actor
- import scala.actors.Actor._
- val paulNewman = actor {
- println("To be an actor, you have to be a child.")
- }
直接啟動一個線程,處理一個分支的業務。大括號里面的就是act()的函數體。再回過來看Kestrel的代碼:
- private val deathSwitch = new CountDownLatch(1)
- ……
- def startup(config: Config): Unit = {
- ……
- // make sure there's always one actor running so scala 2.7.2
- // doesn't kill off the actors library.
- actor {
- deathSwitch.await
- }
- ……
- }
- def shutdown(): Unit = {
- ……
- deathSwitch.countDown
- }
注意那句注釋,在startup系統中多開一個線程,讓服務可以一直運行著……直到shutdown。
回過來我們說一下class和object的區別:
1. 對于Scala的編譯器來看,class不支持任何的static變量,在使用class的時候,必須要先用new來創建實例。而object可以看做是一個只有static內容的Java類,所以對它的調用不需要創建,直接調用即可。
2. 在設計模式里面,object可以看做是一個Singleton,也就是單例模式。所以在調用的時候,就不需要象Java一樣,老是要getInstance來獲取句柄了。
當我們看到PersistentQueue.scala的時候,一個文件中同時包含了class PersistentQueue和object PersistentQueue。就比較容易了解class和object的用法了。
【編輯推薦】