scala的Promise和Future的理解

scala版本：2.11
在scala的并發(fā)包下存在2個(gè)類Promise和Future。用起來很簡單。例子如下：

import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.{Future, Promise}

object PromiseAndFuture extends App {

  // 小李：等你到上海了，打電話告訴我
  val tellMe = Promise[String]()

  val result = tellMe.future
  result.recover {
    case CannotArriveException(msg) => msg
  }.foreach(msg => {
    println(s"接電話：$msg")
    println("小李：好，立刻去接他。")// 小李自己的任務(wù)
  })

  xiaoZhangTask()

  println("小李：逛街中。。。")
  Thread.sleep(5000) // 防止線程直接退出

  private def xiaoZhangTask() = {
    Future {
      println("小張：從北京出發(fā)了。")
      Thread.sleep(2000) // 一直在路上
      println("小張：已經(jīng)到上海了，該告訴小李了。")
      tellMe.success("我是小張，我已經(jīng)到上海了。")
    }.recover {
      case _: Throwable =>
        println("小張：我迷路了，該告訴小李了。")
        tellMe.failure(CannotArriveException("我是小張，我找不到上海怎么辦？"))
    }
  }
}

case class CannotArriveException(msg: String) extends Exception(msg)

控制臺輸入如下：

小張：從北京出發(fā)了。
小李：逛街中。。。
小張：已經(jīng)到上海了，該告訴小李了。
接電話：我是小張，我已經(jīng)到上海了。
小李：好，終于可以見到他了。

• Promise字面意思為“許可”，當(dāng)你向讓另外一個(gè)人（另外一個(gè)線程）去做某件事，并且需要該事情的結(jié)果，你需要先“許可”對方可以告訴你的結(jié)果（成功/失敗，成功是什么或者失敗的原因是什么）。
• Future字面意思為“未來”，表示未來發(fā)生的結(jié)果，這個(gè)結(jié)果可關(guān)心可不關(guān)心。如果關(guān)心可使用map或onComplete或recover等方法來處理。

結(jié)論：在異步轉(zhuǎn)同步時(shí)Promise非常好用。其他情況再具體分析是否要用Promise，大部分情況直接使用Future就比較簡單。