iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

BAEL-4876: Use Java 8 API

Browse Source
This commit is contained in:
Daniel Strmecki 2021-05-03 11:52:32 +02:00
parent d160a09b01
commit b0ade9d58b
3 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/ParallelStream.java
View File

@ -1,11 +1,12 @@
package com.baeldung.streams.parallel; package com.baeldung.streams.parallel;
import java.util.Arrays;
import java.util.List; import java.util.List;
public class ParallelStream { public class ParallelStream {
public static void main(String[] args) { public static void main(String[] args) {
List<Integer> listOfNumbers = List.of(1, 2, 3, 4); List<Integer> listOfNumbers = Arrays.asList(1, 2, 3, 4);
listOfNumbers.parallelStream().forEach(number -> listOfNumbers.parallelStream().forEach(number ->
System.out.println(number + " " + Thread.currentThread().getName()) System.out.println(number + " " + Thread.currentThread().getName())
); );

3
core-java-modules/core-java-streams-3/src/main/java/com/baeldung/streams/parallel/SequentialStream.java
View File

@ -1,11 +1,12 @@
package com.baeldung.streams.parallel; package com.baeldung.streams.parallel;
import java.util.Arrays;
import java.util.List; import java.util.List;
public class SequentialStream { public class SequentialStream {
public static void main(String[] args) { public static void main(String[] args) {
List<Integer> listOfNumbers = List.of(1, 2, 3, 4); List<Integer> listOfNumbers = Arrays.asList(1, 2, 3, 4);
listOfNumbers.stream().forEach(number -> listOfNumbers.stream().forEach(number ->
System.out.println(number + " " + Thread.currentThread().getName()) System.out.println(number + " " + Thread.currentThread().getName())
); );

9
core-java-modules/core-java-streams-3/src/test/java/com/baeldung/streams/parallel/ForkJoinUnitTest.java
View File

@ -2,6 +2,7 @@ package com.baeldung.streams.parallel;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool; import java.util.concurrent.ForkJoinPool;
@ -12,21 +13,21 @@ class ForkJoinUnitTest {
@Test @Test
void givenSequentialStreamOfNumbers_whenReducingSumWithIdentityFive_thenResultIsCorrect() { void givenSequentialStreamOfNumbers_whenReducingSumWithIdentityFive_thenResultIsCorrect() {
List<Integer> listOfNumbers = List.of(1, 2, 3, 4); List<Integer> listOfNumbers = Arrays.asList(1, 2, 3, 4);
int sum = listOfNumbers.stream().reduce(5, Integer::sum); int sum = listOfNumbers.stream().reduce(5, Integer::sum);
assertThat(sum).isEqualTo(15); assertThat(sum).isEqualTo(15);
} }
@Test @Test
void givenParallelStreamOfNumbers_whenReducingSumWithIdentityFive_thenResultIsNotCorrect() { void givenParallelStreamOfNumbers_whenReducingSumWithIdentityFive_thenResultIsNotCorrect() {
List<Integer> listOfNumbers = List.of(1, 2, 3, 4); List<Integer> listOfNumbers = Arrays.asList(1, 2, 3, 4);
int sum = listOfNumbers.parallelStream().reduce(5, Integer::sum); int sum = listOfNumbers.parallelStream().reduce(5, Integer::sum);
assertThat(sum).isNotEqualTo(15); assertThat(sum).isNotEqualTo(15);
} }
@Test @Test
void givenParallelStreamOfNumbers_whenReducingSumWithIdentityZero_thenResultIsCorrect() { void givenParallelStreamOfNumbers_whenReducingSumWithIdentityZero_thenResultIsCorrect() {
List<Integer> listOfNumbers = List.of(1, 2, 3, 4); List<Integer> listOfNumbers = Arrays.asList(1, 2, 3, 4);
int sum = listOfNumbers.parallelStream().reduce(0, Integer::sum) + 5; int sum = listOfNumbers.parallelStream().reduce(0, Integer::sum) + 5;
assertThat(sum).isEqualTo(15); assertThat(sum).isEqualTo(15);
} }
@ -34,7 +35,7 @@ class ForkJoinUnitTest {
@Test @Test
public void givenParallelStreamOfNumbers_whenUsingCustomThreadPool_thenResultIsCorrect() public void givenParallelStreamOfNumbers_whenUsingCustomThreadPool_thenResultIsCorrect()
throws InterruptedException, ExecutionException { throws InterruptedException, ExecutionException {
List<Integer> listOfNumbers = List.of(1, 2, 3, 4); List<Integer> listOfNumbers = Arrays.asList(1, 2, 3, 4);
ForkJoinPool customThreadPool = new ForkJoinPool(4); ForkJoinPool customThreadPool = new ForkJoinPool(4);
int sum = customThreadPool.submit( int sum = customThreadPool.submit(
() -> listOfNumbers.parallelStream().reduce(0, Integer::sum)).get(); () -> listOfNumbers.parallelStream().reduce(0, Integer::sum)).get();