diff --git a/_ja/overviews/core/futures.md b/_ja/overviews/core/futures.md index 8796c37b4d..d83e2043e8 100644 --- a/_ja/overviews/core/futures.md +++ b/_ja/overviews/core/futures.md @@ -139,43 +139,19 @@ Future の実装の多くは、Future の結果を知りたくなったクライ } `onComplete` メソッドは、Future 計算の失敗と成功の両方の結果を扱えるため、汎用性が高い。 -成功した結果のみ扱う場合は、(部分関数を受け取る) `onSuccess` コールバックを使う: +成功した結果のみ扱う場合は、`foreach` コールバックを使う: val f: Future[List[String]] = Future { session.getRecentPosts } - f onSuccess { - case posts => for (post <- posts) println(post) + f foreach { posts => + for (post <- posts) println(post) } -失敗した結果のみ扱う場合は、`onFailure` コールバックを使う: - - val f: Future[List[String]] = Future { - session.getRecentPosts - } - - f onFailure { - case t => println("エラーが発生した: " + t.getMessage) - } - - f onSuccess { - case posts => for (post <- posts) println(post) - } - -`onFalure` コールバックは Future が失敗した場合、つまりそれが例外を保持する場合のみ実行される。 - -部分関数は `isDefinedAt` メソッドを持つため、`onFailure` メソッドはコールバックが特定の `Throwable` に対して定義されている場合のみ発火される。 -以下の例では、登録された `onFailure` コールバックは発火されない: - - val f = Future { - 2 / 0 - } - - f onFailure { - case npe: NullPointerException => - println("これが表示されているとしたらビックリ。") - } +`Future` は、失敗した結果のみを処理する方法を提供していて、 +`Failure[Throwable]` を `Success[Throwable]` へと変換する `failed` 投射を用いることができる。 +詳細は以下の[投射](#projections)を参照。 キーワードの初出の位置を検索する例に戻ると、キーワードの位置を画面に表示したいかもしれない: @@ -184,15 +160,12 @@ Future の実装の多くは、Future の結果を知りたくなったクライ source.toSeq.indexOfSlice("myKeyword") } - firstOccurence onSuccess { - case idx => println("キーワードの初出位置: " + idx) - } - - firstOccurence onFailure { - case t => println("ファイルの処理に失敗した: " + t.getMessage) + firstOccurence oncomplete { + case Success(idx) => println("キーワードの初出位置: " + idx) + case Failure(t) => println("処理失敗：" + t.getMessage) } -`onComplete`、`onSuccess`、および `onFailure` メソッドは全て `Unit` 型を返すため、これらの呼び出しを連鎖させることができない。 +`onComplete`、および `foreach` メソッドは全て `Unit` 型を返すため、これらの呼び出しを連鎖させることができない。 これは意図的な設計で、連鎖された呼び出しが登録されたコールバックの実行の順序を暗示しないようにしている (同じ Future に登録されたコールバックは順不同に発火される)。 @@ -212,12 +185,12 @@ Future 内の値が利用可能となることを必要とするため、Future "na" * 16 + "BATMAN!!!" } - text onSuccess { - case txt => totalA += txt.count(_ == 'a') + text.foreach { txt => + totalA += txt.count(_ == 'a') } - text onSuccess { - case txt => totalA += txt.count(_ == 'A') + text.foreach { txt => + totalA += txt.count(_ == 'A') } 2つのコールバックが順次に実行された場合は、変数 `totalA` は期待される値 `18` を持つ。 @@ -232,7 +205,7 @@ Future 内の値が利用可能となることを必要とするため、Future
  1. Future に onComplete コールバックを登録することで、対応するクロージャが Future が完了した後に eventually に実行されることが保証される。
    2. -
  2. onSuccess や onFailure コールバックを登録することは onComplete と同じ意味論を持つ。ただし、クロージャがそれぞれ成功したか失敗した場合のみに呼ばれるという違いがある。
    3. +
  3. foreach コールバックを登録することは onComplete と同じ意味論を持つ。ただし、クロージャがそれぞれ成功したか失敗した場合のみに呼ばれるという違いがある。
  4. 既に完了した Future にコールバックを登録することは (1 により) コールバックが eventually に実行されることとなる。
    5. @@ -257,33 +230,32 @@ Future 内の値が利用可能となることを必要とするため、Future connection.getCurrentValue(USD) } - rateQuote onSuccess { case quote => + for (quote <- rateQuote) { val purchase = Future { if (isProfitable(quote)) connection.buy(amount, quote) else throw new Exception("有益ではない") } - purchase onSuccess { - case _ => println(amount + " USD を購入した") - } + for (amount <- purchase) + println(amount + " USD を購入した") } まずは現在の為替相場を取得する `rateQuote` という `Future` を作る。 この値がサーバから取得できて Future が成功した場合は、計算は -`onSuccess` コールバックに進み、ここで買うかどうかの決断をすることができる。 +`foreach` コールバックに進み、ここで買うかどうかの決断をすることができる。 ここでもう 1つの Future である `purchase` を作って、有利な場合のみ買う決定をしてリクエストを送信する。 最後に、`purchase` が完了すると、通知メッセージを標準出力に表示する。 これは動作するが、2つの理由により不便だ。 -第一に、`onSuccess` を使わなくてはいけなくて、2つ目の Future である +第一に、`foreach` を使わなくてはいけなくて、2つ目の Future である `purchase` をその中に入れ子にする必要があることだ。 例えば `purchase` が完了した後に別の貨幣を売却したいとする。 -それはまた `onSuccess` の中でこのパターンを繰り返すことになり、インデントしすぎで理解しづらく肥大化したコードとなる。 +それはまた `foreach` の中でこのパターンを繰り返すことになり、インデントしすぎで理解しづらく肥大化したコードとなる。 -第二に、`purchase` は他のコードのスコープ外にあり、`onSuccess` +第二に、`purchase` は他のコードのスコープ外にあり、`foreach` コールバック内においてのみ操作することができる。 そのため、アプリケーションの他の部分は `purchase` を見ることができず、他の貨幣を売るために別の -`onSuccess` コールバックを登録することもできない。 +`foreach` コールバックを登録することもできない。 これらの 2つの理由から Future はより自然な合成を行うコンビネータを提供する。 基本的なコンビネータの 1つが `map` で、これは与えられた Future @@ -301,11 +273,11 @@ Future の投射はコレクションの投射と同様に考えることがで else throw new Exception("有益ではない") } - purchase onSuccess { - case _ => println(amount + " USD を購入した") + purchase.foreach { amount => + println(amount + " USD を購入した") } -`rateQuote` に対して `map` を使うことで `onSuccess` コールバックを一切使わないようになった。 +`rateQuote` に対して `map` を使うことで `foreach` コールバックを一切使わないようになった。 それと、より重要なのが入れ子が無くなったことだ。 ここで他の貨幣を売却したいと思えば、`purchase` に再び `map` するだけでいい。 @@ -321,7 +293,7 @@ Future の投射はコレクションの投射と同様に考えることがで この例外を伝搬させる意味論は他のコンビネータにおいても同様だ。 Future の設計指針の 1つは for 内包表記から利用できるようにすることだった。 -このため、Future は `flatMap`、`filter` そして `foreach` コンビネータを持つ。 +このため、Future は `flatMap` そして `withFilter` コンビネータを持つ。 `flatMap` メソッドは値を新しい Future `g` に投射する関数を受け取り、`g` が完了したときに完了する新たな Future を返す。 @@ -338,8 +310,8 @@ Future の設計指針の 1つは for 内包表記から利用できるように if isProfitable(usd, chf) } yield connection.buy(amount, chf) - purchase onSuccess { - case _ => println(amount + " CHF を購入した") + purchase foreach { _ => + println(amount + " CHF を購入した") } この `purchase` は `usdQuote` と `chfQuote` が完了した場合のみ完了する。 @@ -370,10 +342,6 @@ Future に関しては、`filter` の呼び出しは `withFilter` の呼び出 `collect` と `filter` コンビネータの関係はコレクション API におけるこれらのメソッドの関係に似ている。 -`foreach` コンビネータで注意しなければいけないのは値が利用可能となった場合に走査するのにブロックしないということだ。 -かわりに、`foreach` のための関数は Future が成功した場合のみ非同期に実行される。 -そのため、`foreach` は `onSuccess` コールバックと全く同じ意味を持つ。 - `Future` トレイトは概念的に (計算結果と例外という) 2つの型の値を保持することができるため、例外処理のためのコンビネータが必要となる。 `rateQuote` に基いて何らかの額を買うとする。 @@ -418,7 +386,7 @@ Future は同じ `Throwable` とともに失敗する。 val anyQuote = usdQuote fallbackTo chfQuote - anyQuote onSuccess { println(_) } + anyQuote foreach { println(_) } `andThen` コンビネータは副作用の目的のためだけに用いられる。 これは、成功したか失敗したかに関わらず現在の Future と全く同一の結果を返す新たな Future を作成する。 @@ -454,12 +422,18 @@ Future は同じ `Throwable` とともに失敗する。 } for (exc <- f.failed) println(exc) +上の例での for 内包表記は以下のように書き換えることができる: + + f.failed.foreach( exc => println(exc)) + +`f` が失敗したため、クロージャは新規に成功値を持つ `Future[Throwable]` の +`foreach` コールバックに登録される。 以下の例は画面に何も表示しない: - val f = Future { + val g = Future { 4 / 2 } - for (exc <- f.failed) println(exc) + for (exc <- g.failed) println(exc)