Java 8 – Strumienie – java.util.stream

//
// Dodanie mapy z danymi
//
Map<String, Integer> map = new HashMap<>();
map.put("jeden", 1);
map.put("dwa", 2);
map.put("trzy", 3);
map.put("cztery", 4);
map.put("pięć", 5);
map.put("szcześć", 6);
 
//
// Kod w Javie 7
//
List<String> listJava7 = new ArrayList<>();
for (Map.Entry<String, Integer> entry : map.entrySet()){
   if (entry.getValue() > 3){
      listJava7.add(entry.getKey());
   }
}
System.out.println("Java7: " + listJava7);
 
//
// Kod w Javie 8
//
List<String> listJava8 = map.entrySet().stream()
                     .filter(entry -> entry.getValue() > 3)
                     .map(Map.Entry::getKey)
                     .collect(Collectors.toList());
System.out.println("Java8: " + listJava8);

//
// Z tablicy
//
System.out.println("Dane tablicy:");
 
double[] as = {42.20, 12.12, 10.0, 20.0, 30.0, 40.0, 43.0, 23.23, 10.22};
Arrays.stream(as)
     .forEach(d -> System.out.print(d + " "));
 
//
// Losowe
//
System.out.println("Losowe dane:");
Random rnd = new Random();
rnd.ints(10, 0, 10)
   .forEach(d -> System.out.print(d + " "));
 
//
// Z kolekcji
//
System.out.println("Dane z kolekcji:");
List<String> list = new ArrayList<>();
list.add("Pierwszy");
list.add("Drugi");
list.add("Trzeci");
list.add("Czwarty");
list.add("Piąty");
list.add("Szósty");
 
list.parallelStream()
   .forEach(s -> System.out.print(s + " "));
 
//
// Z kolekcji intów
//
System.out.println("Dane intów z kolekcji:");
final List<Integer> integerList = Arrays.asList(10, 20, 30, 40, 50, 60, 70, 80, 90, 100);
integerList.stream()
         .forEach(i -> System.out.print(i + " "));

//
// Fitrowanie przy pomnocy strumieni
//
System.out.println("Filtrowanie danych:");
list.stream()
   .filter(s -> s.startsWith("P") || s.startsWith("C"))
   .forEach(s -> System.out.print(s + " "));
 
//
// Sortowanie
//
System.out.println("Sortowanie danych:");
list.stream()
   .sorted(Comparator.reverseOrder())
   .forEach(s -> System.out.print(s + " "));
 
//
// Mapowanie, za obiekt podstawiany jest wynikający z mapowania
//
System.out.println("Mapowanie danych:");
list.stream()
   .map(s -> s + " czy jest równy 'Trzeci' ? " + (s.equals("Trzeci") ? "TAK" : "NIE"))
   .forEach(s -> System.out.println(s));
 
//
// Sortowanie, filtrowanie, mapowanie
//
System.out.println("Obróbka danych:");
list.stream()
   .map(s -> s.toUpperCase())
   .filter(s -> s.endsWith("Y"))
   .sorted()
   .forEach(System.out::println);

class Country{
   private String name;
   private String system;
   private int area;
   private int population;
 
   public Country(String name, String system, int area, int population){
      this.name = name;
      this.system = system;
      this.area = area;
      this.population = population;
   }
 
   public String getName(){
      return name;
   }
 
   public String getSystem(){
      return system;
   }
 
   public int getArea(){
      return area;
   }
 
   public int getPopulation(){
      return population;
   }
 
   @Override
   public String toString(){
      return "Państwo: " + name + " powierzchnia: " + area + " km2 populacja: " + population;
   }
}

//
// Dodanie przykładowych danych
//
List<Country> countryList = Arrays.asList(
new Country("Poland", "Republika", 312679, 38454576),
new Country("Germany", "system kanclerski", 357375, 81083600),
new Country("Česká republika", "Republika", 78866, 10541466),
new Country("Slovenská republika", "Republika", 49035, 5421349),
new Country("République française", "Republika semiprezydencka", 643801, 66318000)
);
 
//
// Fitrowanie i sortowanie po nazwie
//
final List<Country> countriesMoreThan10Million =
countryList.stream()
         .filter(country -> country.getPopulation() > 10000000)
         .sorted((o1, o2) -> o1.getName().compareToIgnoreCase(o2.getName()))
         .collect(Collectors.toList());
 
System.out.println("Państwa z populacją ponad 10 mil:");
countriesMoreThan10Million.forEach(System.out::println);
 
//
// Grupowanie według systemu politycznego
//
Map<String, List<Country>> countriesGroupBySystem =
countryList.stream()
         .sorted((o1, o2) -> o1.getName().compareToIgnoreCase(o2.getName()))
         .collect(Collectors.groupingBy(b -> b.getSystem()));
 
countriesGroupBySystem.forEach((s, countries) -> System.out.println("Ustrój: " + s + " " + countries));
 
//
// Wyliczenie średniej poulacji dla podanej listy krajów
//
Double avgPopulation = countryList.stream()
                          .collect(Collectors.averagingInt(Country::getPopulation));
System.out.println("Średnia populacji dla podanej listy krajów to " + Math.round(avgPopulation) + " osób");