diff --git a/src/codemasters/lambda/eval/StreamEval.java b/src/codemasters/lambda/eval/StreamEval.java index ab82047..eff1829 100644 --- a/src/codemasters/lambda/eval/StreamEval.java +++ b/src/codemasters/lambda/eval/StreamEval.java @@ -14,7 +14,7 @@ public static void main(String[] args) { BiConsumer,String> acc = ArrayList::add; BiConsumer,ArrayList> comb = ArrayList::addAll; - List strings = asList(1,2,3,4,5).stream() + List strings = asList(1,2,3,4,5).parallelStream() .map(Object::toString) .collect(ArrayList::new,ArrayList::add,ArrayList::addAll); diff --git a/src/codemasters/lambda/jug/Prep02.java b/src/codemasters/lambda/jug/Prep02.java index af64656..88aeab8 100644 --- a/src/codemasters/lambda/jug/Prep02.java +++ b/src/codemasters/lambda/jug/Prep02.java @@ -29,7 +29,7 @@ public class Prep02 { public static void main(String[] args) { - List brands = cars.stream().filter(car -> car.getYear() >= 2012) + List brands = cars.parallelStream().filter(car -> car.getYear() >= 2012) .map(car -> car.getBrand()) .collect(Collectors.toList()); diff --git a/src/codemasters/lambda/practice/Demo4.java b/src/codemasters/lambda/practice/Demo4.java index 8fe6fe0..2ee0b00 100644 --- a/src/codemasters/lambda/practice/Demo4.java +++ b/src/codemasters/lambda/practice/Demo4.java @@ -15,8 +15,8 @@ public class Demo4 { public static void main(String[] args) { Stream test = asList(1,2,3,4,5,6).stream(); - Integer max = asList(1,2,3,4,5,6).stream().max(Integer::compare).get(); - Integer min = asList(1,2,3,4,5,6).stream().min(Integer::compare).get(); + Integer max = asList(1,2,3,4,5,6).parallelStream().max(Integer::compare).get(); + Integer min = asList(1,2,3,4,5,6).parallelStream().min(Integer::compare).get(); System.out.printf("Min: %d - Max: %d%n", min,max);