Kestrel.scala中的PersistentQueue是什么

這篇文章主要講解了“Kestrel.scala中的PersistentQueue是什么”，文中的講解內(nèi)容簡(jiǎn)單清晰，易于學(xué)習(xí)與理解，下面請(qǐng)大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“Kestrel.scala中的PersistentQueue是什么”吧！

繼續(xù)走讀QueueCollection.scala的代碼，因?yàn)楹竺娣庋b的大量方法，都是對(duì)queues和fanout_queues的操作，根據(jù)定義，這兩個(gè)變量都是mutable.HashMap[String, XXXX]類型的，所以我們先介紹一下mutable.HashMap的幾個(gè)在Java中陌生的方法：( scala 的 apidoc 在 http://www.scala-lang.org/docu/files/api/index.html 可以查到）

◆apply (key : A) : B

◆Retrieve the value which is associated with the given key. This method throws an exception if there is no mapping from the given key to a value.

◆get (key : A) : Option[B]

◆Check if this map maps key to a value and return the value if it exists.

◆getOrElse [B2 >: B](key : A, default : => B2) : B2

◆Check if this map maps key to a value. Return that value if it exists, otherwise return default.

◆getOrElseUpdate (key : A, default : => B) : B

◆Check if this map maps key to a value. Return that value if it exists, otherwise put default as that key’s value and return it.

我們發(fā)現(xiàn)get和apply在Scala中，是完全相同的功能，但是在get返回值里面的Option究竟是什么意思呢？這個(gè)問題從剛開始閱讀Scala代碼的時(shí)候就已經(jīng)困惑我們很久了。其實(shí)查詢一下Scala的手冊(cè)，我們不難發(fā)現(xiàn)，這是一個(gè)對(duì)于NULL的改造，因?yàn)樵贘ava里面，有些是面向?qū)ο蟮淖兞浚行┎皇?，如果需要在Scala的語言內(nèi)，保證所有對(duì)空的判斷是一致的，那么就需要做一點(diǎn)什么。所以Scala設(shè)計(jì)了Option這個(gè)抽象類，以及兩個(gè)子類Some和None。Option的實(shí)例，要么是Some類型，要么是None類型。所以把Option[類型]作為參數(shù)傳遞，也就是把這種類型的空值一并處理了，如果不存在，返回的是None[類型]，不需要象apply一樣拋出一個(gè)異常。

讓我們重新讀下面這段代碼：

private[kestrel] def queue(name: String): Option[PersistentQueue] = synchronized {      ……        Some(queues.get(name) getOrElse {          // only happens when creating a queue for the first time.          val q = if (name contains '+') {            val master = name.split('+')(0)            fanout_queues.getOrElseUpdate(master, new mutable.HashSet[String]) += name            log.info("Fanout queue %s added to %s", name, master)            new PersistentQueue(path.getPath, name, queueConfigs.configMap(master))          } else {            new PersistentQueue(path.getPath, name, queueConfigs.configMap(name))          }          q.setup          queues(name) = q          q        })    ……    }

先不要暈，根據(jù)之前對(duì)Option的理解，我們知道這是一個(gè)被Option封裝了的PersistentQueue類。我們也知道了所有的Scala方法都不需要return，***一條執(zhí)行命令的返回值就是這個(gè)方法的返回值，所以，在這里，Some(……)就是整個(gè)方法的返回值，很高興，因?yàn)榉椒▽?duì)返回值的定義是PersistentQueue，所以我們知道Some括號(hào)里面的一定也是PersistentQueue。

Some(queues.get(name) ……)，很好，因?yàn)閝ueues的定義是mutable.HashMap[String, PersistentQueue]，所以get返回的就是Option[PersistentQueue]。這個(gè)方法貌似已經(jīng)寫完了，后面的到底是在做什么呢？getOrElse，按照定義，就是如果值不存在，那么就做后面{}里面的事情，這樣的寫法，其實(shí)就是對(duì)空值的處理。用QueueCollection角度來看，就是當(dāng)查詢queues的時(shí)候，這個(gè)隊(duì)列如果不存在，那么就做{}里面的處理，創(chuàng)建一個(gè)隊(duì)列。這里需要注意的是——這個(gè)getOrElse不是HashMap的getOrElse，而是Option的getOrElse。

然后讀起來就比較順利了，創(chuàng)建一個(gè)q，是PersistentQueue類型的，把它賦值給queues(name)中，加入HashMap表中。***不要忘記把q作為整個(gè)函數(shù)的返回，也就是Some()的返回。和get(name)存在的時(shí)候一樣。

有了queue這個(gè)函數(shù)作為基礎(chǔ)，后面讀起來就容易很多了，我們就重點(diǎn)介紹一下match和case的用法，在add方法里面有這么一段代碼：

queue(key) match {    case None => false   case Some(q) =>      ……      val result = q.add(item, normalizedExpiry)      if (result) totalAdded.incr()      result  }

之前我們知道 queue(key)返回的是Option[PersistentQueue]，match就是做匹配，根據(jù)不同的匹配來執(zhí)行不同的操作，None，如果這個(gè)queue沒有查詢到，那么就返回false。Some(q)，如果queue返回的是一個(gè)Some類型，也就是Option有值的時(shí)候的返回，那么這個(gè)q就是返回的PersistentQueue類型的那個(gè)實(shí)例！就像函數(shù)的參數(shù)一樣，可以直接使用。

很驚奇吧，剛接觸Scala的時(shí)候，我?guī)缀鯚o法相信case可以這樣做判斷。后來我們發(fā)現(xiàn)，之所以能夠做這種判斷，是因?yàn)樗械腟cala都是被類封裝的，并且基于Scala的基類，實(shí)現(xiàn)了一個(gè)所謂的case class和case object的抽象類，并且實(shí)現(xiàn)了基于類的統(tǒng)一的==操作符。這一連串的改變?cè)炀土水惓?qiáng)大的Scala的case語法。

感謝各位的閱讀，以上就是“Kestrel.scala中的PersistentQueue是什么”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對(duì)Kestrel.scala中的PersistentQueue是什么這一問題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！