Commit 7159036a authored by Trisha Gee's avatar Trisha Gee
Browse files

[appB] Really basic example of starting a parallel stream.

parent 6c5b2d99
Loading
Loading
Loading
Loading
+23 −0
Changes for src/main/java/appB/ParallelStreams.java: 23 added lines, 0 removed lines.
Original line number Diff line number Diff line
package appB;


import ch12.JukeboxData;
import ch12.Song;

import java.util.List;
import java.util.stream.Stream;

public class ParallelStreams {
  void startAParallelStream() {
    List<Song> songs = new JukeboxData.Songs().getSongs();

    Stream<Song> songStream = songs.parallelStream();
  }

  void addAParallelOperationStream() {
    List<Song> songs = new JukeboxData.Songs().getSongs();

    Stream<Song> songStream = songs.stream()
                                   .parallel();
  }
}
+1 −1
Changes for src/main/java/ch12/JukeboxData.java: 1 added line, 1 removed line.
Original line number Diff line number Diff line
@@ -10,7 +10,7 @@ import static java.util.stream.Collectors.*;
// TODO: introduce duplicates for number of times played
// or: add a timesPlayed field.
public class JukeboxData {
  static class Songs {
  public static class Songs {

    public List<Song> getSongs() {
      return List.of(