Scalaのセマンティクスは、トラバース、反復可能、シーケンス、ストリーム、およびビューですか？

Question

Scala: What is the difference between Traversable and Iterable traits in Scala collections?とHow would I get the sum of squares of two Lists in Scala?などの質問が部分的に答えています。私はこのすべてを1つの場所でカバーする質問が理にかなっていると感じました。

Answer 1

トラバーシブルは、コレクション階層の先頭です。その主な方法は 'foreach'なので、コレクションの各要素に対して何かをすることができます。

Iterableは、foreachを実装できるIteratorを作成できます。これは要素のいくつかの順序を定義しますが、その順序はすべての反復子で変更される可能性があります。

Seq（要素）は、要素の順序が固定されているイテラブルです。したがって、要素のインデックスについて話すことは理にかなっています。

ストリームはレイジーシーケンスです。私。ストリームの要素がアクセスされる前に計算されないことがあります。これにより、すべての整数のシーケンスのような無限のシーケンスで作業することが可能になります。

ビューは、コレクションの非厳格なバージョンです。フィルタやマップのようなメソッドは、それぞれの要素がアクセスされたときに渡された関数を実行するだけです。したがって、巨大コレクションのマップは、元のコレクションの周りにラッパーを作成するだけですぐに戻ります。 1つの要素にアクセスする場合にのみ、その要素のマッピングが実際に実行されます。 Viewはクラスではありませんが、さまざまなコレクションのXxxViewクラスがたくさんあります。

Answer 2

1つのコメントストリーム対反復子を追加したいと思います。ストリームとイテレータの両方を使用して、必要になるまで値を計算しない、厳密ではない、潜在的に無限のコレクションを実装することができます。

しかし、これを実行するときに発生する「早すぎる実行」には問題があります。イテレータは使用できますがストリームは使用できません。プロセスでは、この2つの重要な意味の違いが示されます。これはおそらく、最も明確に次のように示されている：

def runiter(start: Int) { 
    // Create a stream that returns successive integers on demand, e.g. 3, 4, 5, .... 
    val iter = { 
    def loop(v: Int): Stream[Int] = { println("I computed a value", v); v} #:: loop(v+1) 
    loop(start) 
    } 
    // Now, sometime later, we retrieve the values .... 
    println("about to loop") 
    for (x <- iter) { 
    if (x < 10) println("saw value", x) else return 
    } 
} 

このコードは、指定された値で始まり、連続した整数を返し、無限ストリームを生成します。これは、インターネット接続を開き、必要に応じて接続から値を返すなど、より複雑なコードのスタンドインとして使用されます。

結果：

scala> runiter(3) 
(I computed a value,3) 
about to loop 
(saw value,3) 
(I computed a value,4) 
(saw value,4) 
(I computed a value,5) 
(saw value,5) 
(I computed a value,6) 
(saw value,6) 
(I computed a value,7) 
(saw value,7) 
(I computed a value,8) 
(saw value,8) 
(I computed a value,9) 
(saw value,9) 
(I computed a value,10) 

注意慎重に最初の値を計算するために必要な実行は、ストリームの値が実際に使用されている場所前に発生しますか。この初期実行でファイルやインターネット接続を開くなど、ストリームを作成した後で値が使用されるまでに時間がかかる場合、これは非常に問題になる可能性があります。開いているファイル記述子あなたのインターネット接続がタイムアウトになり、すべてが失敗する可能性があります。

単純では動作しません最初の空のストリームを使用して、それを修正しようとする：（前と同じ）

def runiter(start: Int) { 
    // Create a stream that returns successive integers on demand, e.g. 3, 4, 5, .... 
    val iter = { 
    def loop(v: Int): Stream[Int] = { println("I computed a value", v); v} #:: loop(v+1) 
    Stream[Int]() ++ loop(start) 
    } 
    // Now, sometime later, we retrieve the values .... 
    println("about to loop") 
    for (x <- iter) { 
    if (x < 10) println("saw value", x) else return 
    } 
} 

結果：しかし

scala> runiter(3) 
(I computed a value,3) 
about to loop 
(saw value,3) 
(I computed a value,4) 
(saw value,4) 
(I computed a value,5) 
(saw value,5) 
(I computed a value,6) 
(saw value,6) 
(I computed a value,7) 
(saw value,7) 
(I computed a value,8) 
(saw value,8) 
(I computed a value,9) 
(saw value,9) 
(I computed a value,10) 

、あなたはによってこの問題を解決することができます初期の空のイテレータを使用してイテレータにストリームを変更します。

def runiter(start: Int) { 
    // Create an iterator that returns successive integers on demand, e.g. 3, 4, 5, .... 
    val iter = { 
    def loop(v: Int): Iterator[Int] = { println("I computed a value", v); Iterator(v)} ++ loop(v+1) 
    Iterator[Int]() ++ loop(start) 
    } 
    // Now, sometime later, we retrieve the values .... 
    println("about to loop") 
    for (x <- iter) { 
    if (x < 10) println("saw value", x) else return 
    } 
} 

結果：あなたが最初の空の反復子を追加しない場合、あなたはストリームと同じ時期尚早実行問題に実行されることを

scala> runiter(3) 
about to loop 
(I computed a value,3) 
(saw value,3) 
(I computed a value,4) 
(saw value,4) 
(I computed a value,5) 
(saw value,5) 
(I computed a value,6) 
(saw value,6) 
(I computed a value,7) 
(saw value,7) 
(I computed a value,8) 
(saw value,8) 
(I computed a value,9) 
(saw value,9) 
(I computed a value,10) 

注意。