在Scala中,Future和Promise可以用于異步編程。Future表示一個異步計算的結果,而Promise是Future的一個可寫的版本,用于將結果寫入Future中。
下面是一個簡單的示例代碼,演示如何使用Future和Promise進行異步編程:
import scala.concurrent.{Future, Promise}
import scala.concurrent.ExecutionContext.Implicits.global
// 創建一個Promise
val promise = Promise[Int]()
// 獲取Promise的Future
val future: Future[Int] = promise.future
// 在Future中定義異步任務
val asyncTask = Future {
// 模擬耗時操作
Thread.sleep(1000)
42
}
// 將異步任務的結果寫入Promise中
asyncTask.onSuccess {
case result => promise.success(result)
}
// 在Future中處理異步任務的結果
future.onComplete {
case scala.util.Success(value) => println(s"Async task result: $value")
case scala.util.Failure(exception) => println(s"Async task failed with exception: $exception")
}
// 阻塞主線程,等待異步任務完成
Thread.sleep(2000)
在上面的示例中,我們首先創建了一個Promise,并通過promise.future
獲取了Promise的Future。然后我們定義了一個異步任務asyncTask
,并將其結果寫入Promise中。最后我們通過future.onComplete
來處理異步任務的結果。
需要注意的是,Future和Promise是線程安全的,可以在不同的線程中并發使用。在實際應用中,我們可以將復雜的異步任務封裝成Future,并通過Promise來控制異步任務的執行和結果。