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

JAVA-8924 Fixed spliterator packages and formatting (#14211)

Browse Source
This commit is contained in:
Dhawal Kapil
2023-06-10 12:42:38 +05:30
committed by GitHub
parent ecce4a4121
commit fec7001cbd
8 changed files with 72 additions and 61 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-java-modules/core-java-8/src/main/java/com/baeldung/spliteratorAPI/Article.java → core-java-modules/core-java-8/src/main/java/com/baeldung/spliterator/Article.java
+1 -1
View File
@@ -1,4 +1,4 @@
package com.baeldung.spliteratorAPI;
package com.baeldung.spliterator;
import java.util.List;
core-java-modules/core-java-8/src/main/java/com/baeldung/spliteratorAPI/Author.java → core-java-modules/core-java-8/src/main/java/com/baeldung/spliterator/Author.java
+1 -1
View File
@@ -1,4 +1,4 @@
package com.baeldung.spliteratorAPI;
package com.baeldung.spliterator;
public class Author {
private String name;
core-java-modules/core-java-8/src/main/java/com/baeldung/spliteratorAPI/Executor.java → core-java-modules/core-java-8/src/main/java/com/baeldung/spliterator/Executor.java
+1 -1
View File
@@ -1,4 +1,4 @@
package com.baeldung.spliteratorAPI;
package com.baeldung.spliterator;
import java.util.List;
import java.util.stream.Collectors;
core-java-modules/core-java-8/src/main/java/com/baeldung/spliteratorAPI/RelatedAuthorCounter.java → core-java-modules/core-java-8/src/main/java/com/baeldung/spliterator/RelatedAuthorCounter.java
+1 -1
View File
@@ -1,4 +1,4 @@
package com.baeldung.spliteratorAPI;
package com.baeldung.spliterator;
public class RelatedAuthorCounter {
private final int counter;
core-java-modules/core-java-8/src/main/java/com/baeldung/spliteratorAPI/RelatedAuthorSpliterator.java → core-java-modules/core-java-8/src/main/java/com/baeldung/spliterator/RelatedAuthorSpliterator.java
+1 -1
View File
@@ -1,4 +1,4 @@
package com.baeldung.spliteratorAPI;
package com.baeldung.spliterator;
import java.util.List;
import java.util.Spliterator;
core-java-modules/core-java-8/src/main/java/com/baeldung/spliteratorAPI/Task.java → core-java-modules/core-java-8/src/main/java/com/baeldung/spliterator/Task.java
+1 -1
View File
@@ -1,4 +1,4 @@
package com.baeldung.spliteratorAPI;
package com.baeldung.spliterator;
import java.util.Spliterator;
import java.util.concurrent.Callable;
core-java-modules/core-java-8/src/test/java/com/baeldung/spliterator/ExecutorUnitTest.java
+66
View File
@@ -0,0 +1,66 @@
package com.baeldung.spliterator;
import java.util.Arrays;
import java.util.List;
import java.util.Spliterator;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import java.util.stream.StreamSupport;
import static org.assertj.core.api.Assertions.*;
import org.junit.Before;
import org.junit.Test;
import com.baeldung.spliterator.Article;
import com.baeldung.spliterator.Author;
import com.baeldung.spliterator.Executor;
import com.baeldung.spliterator.RelatedAuthorSpliterator;
import com.baeldung.spliterator.Task;
public class ExecutorUnitTest {
Article article;
Stream<Author> stream;
Spliterator<Author> spliterator;
Spliterator<Article> split1;
Spliterator<Article> split2;
@Before
public void init() {
article = new Article(Arrays.asList(new Author("Ahmad", 0), new Author("Eugen", 0), new Author("Alice", 1), new Author("Alice", 1), new Author("Mike", 0), new Author("Alice", 1), new Author("Mike", 0), new Author("Alice", 1), new Author("Mike", 0),
new Author("Alice", 1), new Author("Mike", 0), new Author("Mike", 0), new Author("Alice", 1), new Author("Mike", 0), new Author("Alice", 1), new Author("Mike", 0), new Author("Alice", 1), new Author("Mike", 0), new Author("Alice", 1),
new Author("Mike", 0), new Author("Michał", 0), new Author("Loredana", 1)), 0);
stream = article.getListOfAuthors()
.stream();
split1 = Executor.generateElements()
.spliterator();
split2 = split1.trySplit();
spliterator = new RelatedAuthorSpliterator(article.getListOfAuthors());
}
@Test
public void givenAstreamOfAuthors_whenProcessedInParallelWithCustomSpliterator_coubtProducessRightOutput() {
Stream<Author> stream2 = StreamSupport.stream(spliterator, true);
assertThat(Executor.countAutors(stream2.parallel())).isEqualTo(9);
}
@Test
public void givenSpliterator_whenAppliedToAListOfArticle_thenSplittedInHalf() {
assertThat(new Task(split1).call()).containsSequence(Executor.generateElements()
.size() / 2 + "");
assertThat(new Task(split2).call()).containsSequence(Executor.generateElements()
.size() / 2 + "");
}
@Test
public void givenAstreamOfArticles_whenProcessedInSequentiallyWithSpliterator_ProducessRightOutput() {
List<Article> articles = Stream.generate(() -> new Article("Java"))
.limit(35000)
.collect(Collectors.toList());
Spliterator<Article> spliterator = articles.spliterator();
while (spliterator.tryAdvance(article -> article.setName(article.getName()
.concat("- published by Baeldung"))));
articles.forEach(article -> assertThat(article.getName()).isEqualTo("Java- published by Baeldung"));
}
}
core-java-modules/core-java-8/src/test/java/com/baeldung/spliteratorAPI/ExecutorUnitTest.java
-55
View File
@@ -1,55 +0,0 @@
package com.baeldung.spliteratorAPI;
import java.util.Arrays;
import java.util.List;
import java.util.Spliterator;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import java.util.stream.StreamSupport;
import static org.assertj.core.api.Assertions.*;
import org.junit.Before;
import org.junit.Test;
public class ExecutorUnitTest {
Article article;
Stream<Author> stream;
Spliterator<Author> spliterator;
Spliterator<Article> split1;
Spliterator<Article> split2;
@Before
public void init() {
article = new Article(Arrays.asList(new Author("Ahmad", 0), new Author("Eugen", 0), new Author("Alice", 1),
new Author("Alice", 1), new Author("Mike", 0), new Author("Alice", 1), new Author("Mike", 0),
new Author("Alice", 1), new Author("Mike", 0), new Author("Alice", 1), new Author("Mike", 0),
new Author("Mike", 0), new Author("Alice", 1), new Author("Mike", 0), new Author("Alice", 1),
new Author("Mike", 0), new Author("Alice", 1), new Author("Mike", 0), new Author("Alice", 1),
new Author("Mike", 0), new Author("Michał", 0), new Author("Loredana", 1)), 0);
stream = article.getListOfAuthors().stream();
split1 = Executor.generateElements().spliterator();
split2 = split1.trySplit();
spliterator = new RelatedAuthorSpliterator(article.getListOfAuthors());
}
@Test
public void givenAstreamOfAuthors_whenProcessedInParallelWithCustomSpliterator_coubtProducessRightOutput() {
Stream<Author> stream2 = StreamSupport.stream(spliterator, true);
assertThat(Executor.countAutors(stream2.parallel())).isEqualTo(9);
}
@Test
public void givenSpliterator_whenAppliedToAListOfArticle_thenSplittedInHalf() {
assertThat(new Task(split1).call()).containsSequence(Executor.generateElements().size() / 2 + "");
assertThat(new Task(split2).call()).containsSequence(Executor.generateElements().size() / 2 + "");
}
@Test
public void givenAstreamOfArticles_whenProcessedInSequentiallyWithSpliterator_ProducessRightOutput() {
List<Article> articles = Stream.generate(() -> new Article("Java")).limit(35000).collect(Collectors.toList());
Spliterator<Article> spliterator = articles.spliterator();
while (spliterator.tryAdvance(article -> article.setName(article.getName().concat("- published by Baeldung"))));
articles.forEach(article -> assertThat(article.getName()).isEqualTo("Java- published by Baeldung"));
}
}