Merge pull request #3 from eugenp/master

master to BAEL-3335
2019-11-23 11:00:09 +00:00
parent 397579079a 7ee5019f7e
commit b640b2c73a
1481 changed files with 8172 additions and 158916 deletions
@@ -0,0 +1,30 @@
+package com.baeldung.algorithms.astar;
+
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+
+public class Graph<T extends GraphNode> {
+    private final Set<T> nodes;
+
+    private final Map<String, Set<String>> connections;
+
+    public Graph(Set<T> nodes, Map<String, Set<String>> connections) {
+        this.nodes = nodes;
+        this.connections = connections;
+    }
+
+    public T getNode(String id) {
+        return nodes.stream()
+            .filter(node -> node.getId().equals(id))
+            .findFirst()
+            .orElseThrow(() -> new IllegalArgumentException("No node found with ID"));
+    }
+
+    public Set<T> getConnections(T node) {
+        return connections.get(node.getId()).stream()
+            .map(this::getNode)
+            .collect(Collectors.toSet());
+    }
+}
@@ -0,0 +1,5 @@
+package com.baeldung.algorithms.astar;
+
+public interface GraphNode {
+    String getId();
+}
@@ -0,0 +1,66 @@
+package com.baeldung.algorithms.astar;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.PriorityQueue;
+import java.util.Queue;
+import java.util.stream.Collectors;
+
+public class RouteFinder<T extends GraphNode> {
+    private final Graph<T> graph;
+    private final Scorer<T> nextNodeScorer;
+    private final Scorer<T> targetScorer;
+
+    public RouteFinder(Graph<T> graph, Scorer<T> nextNodeScorer, Scorer<T> targetScorer) {
+        this.graph = graph;
+        this.nextNodeScorer = nextNodeScorer;
+        this.targetScorer = targetScorer;
+    }
+
+    public List<T> findRoute(T from, T to) {
+        Map<T, RouteNode<T>> allNodes = new HashMap<>();
+        Queue<RouteNode> openSet = new PriorityQueue<>();
+
+        RouteNode<T> start = new RouteNode<>(from, null, 0d, targetScorer.computeCost(from, to));
+        allNodes.put(from, start);
+        openSet.add(start);
+
+        while (!openSet.isEmpty()) {
+            System.out.println("Open Set contains: " + openSet.stream().map(RouteNode::getCurrent).collect(Collectors.toSet()));
+            RouteNode<T> next = openSet.poll();
+            System.out.println("Looking at node: " + next);
+            if (next.getCurrent().equals(to)) {
+                System.out.println("Found our destination!");
+
+                List<T> route = new ArrayList<>();
+                RouteNode<T> current = next;
+                do {
+                    route.add(0, current.getCurrent());
+                    current = allNodes.get(current.getPrevious());
+                } while (current != null);
+
+                System.out.println("Route: " + route);
+                return route;
+            }
+
+            graph.getConnections(next.getCurrent()).forEach(connection -> {
+                double newScore = next.getRouteScore() + nextNodeScorer.computeCost(next.getCurrent(), connection);
+                RouteNode<T> nextNode = allNodes.getOrDefault(connection, new RouteNode<>(connection));
+                allNodes.put(connection, nextNode);
+
+                if (nextNode.getRouteScore() > newScore) {
+                    nextNode.setPrevious(next.getCurrent());
+                    nextNode.setRouteScore(newScore);
+                    nextNode.setEstimatedScore(newScore + targetScorer.computeCost(connection, to));
+                    openSet.add(nextNode);
+                    System.out.println("Found a better route to node: " + nextNode);
+                }
+            });
+        }
+
+        throw new IllegalStateException("No route found");
+    }
+
+}
@@ -0,0 +1,67 @@
+package com.baeldung.algorithms.astar;
+
+import java.util.StringJoiner;
+
+class RouteNode<T extends GraphNode> implements Comparable<RouteNode> {
+    private final T current;
+    private T previous;
+    private double routeScore;
+    private double estimatedScore;
+
+    RouteNode(T current) {
+        this(current, null, Double.POSITIVE_INFINITY, Double.POSITIVE_INFINITY);
+    }
+
+    RouteNode(T current, T previous, double routeScore, double estimatedScore) {
+        this.current = current;
+        this.previous = previous;
+        this.routeScore = routeScore;
+        this.estimatedScore = estimatedScore;
+    }
+
+    T getCurrent() {
+        return current;
+    }
+
+    T getPrevious() {
+        return previous;
+    }
+
+    double getRouteScore() {
+        return routeScore;
+    }
+
+    double getEstimatedScore() {
+        return estimatedScore;
+    }
+
+    void setPrevious(T previous) {
+        this.previous = previous;
+    }
+
+    void setRouteScore(double routeScore) {
+        this.routeScore = routeScore;
+    }
+
+    void setEstimatedScore(double estimatedScore) {
+        this.estimatedScore = estimatedScore;
+    }
+
+    @Override
+    public int compareTo(RouteNode other) {
+        if (this.estimatedScore > other.estimatedScore) {
+            return 1;
+        } else if (this.estimatedScore < other.estimatedScore) {
+            return -1;
+        } else {
+            return 0;
+        }
+    }
+
+    @Override
+    public String toString() {
+        return new StringJoiner(", ", RouteNode.class.getSimpleName() + "[", "]").add("current=" + current)
+            .add("previous=" + previous).add("routeScore=" + routeScore).add("estimatedScore=" + estimatedScore)
+            .toString();
+    }
+}
@@ -0,0 +1,5 @@
+package com.baeldung.algorithms.astar;
+
+public interface Scorer<T extends GraphNode> {
+    double computeCost(T from, T to);
+}
@@ -0,0 +1,19 @@
+package com.baeldung.algorithms.astar.underground;
+
+import com.baeldung.algorithms.astar.Scorer;
+
+public class HaversineScorer implements Scorer<Station> {
+    @Override
+    public double computeCost(Station from, Station to) {
+        double R = 6372.8; // In kilometers
+
+        double dLat = Math.toRadians(to.getLatitude() - from.getLatitude());
+        double dLon = Math.toRadians(to.getLongitude() - from.getLongitude());
+        double lat1 = Math.toRadians(from.getLatitude());
+        double lat2 = Math.toRadians(to.getLatitude());
+
+        double a = Math.pow(Math.sin(dLat / 2),2) + Math.pow(Math.sin(dLon / 2),2) * Math.cos(lat1) * Math.cos(lat2);
+        double c = 2 * Math.asin(Math.sqrt(a));
+        return R * c;
+    }
+}
@@ -0,0 +1,42 @@
+package com.baeldung.algorithms.astar.underground;
+
+import java.util.StringJoiner;
+
+import com.baeldung.algorithms.astar.GraphNode;
+
+public class Station implements GraphNode {
+    private final String id;
+    private final String name;
+    private final double latitude;
+    private final double longitude;
+
+    public Station(String id, String name, double latitude, double longitude) {
+        this.id = id;
+        this.name = name;
+        this.latitude = latitude;
+        this.longitude = longitude;
+    }
+
+    @Override
+    public String getId() {
+        return id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public double getLatitude() {
+        return latitude;
+    }
+
+    public double getLongitude() {
+        return longitude;
+    }
+
+    @Override
+    public String toString() {
+        return new StringJoiner(", ", Station.class.getSimpleName() + "[", "]").add("id='" + id + "'")
+            .add("name='" + name + "'").add("latitude=" + latitude).add("longitude=" + longitude).toString();
+    }
+}
@@ -17,6 +17,11 @@
            <artifactId>commons-codec</artifactId>
            <version>${commons-codec.version}</version>
        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-math3</artifactId>
+            <version>${commons-math3.version}</version>
+        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
@@ -28,6 +33,7 @@
            <artifactId>tradukisto</artifactId>
            <version>${tradukisto.version}</version>
        </dependency>
+
        <dependency>
            <groupId>org.assertj</groupId>
            <artifactId>assertj-core</artifactId>
@@ -52,6 +58,7 @@
        <tradukisto.version>1.0.1</tradukisto.version>
        <org.assertj.core.version>3.9.0</org.assertj.core.version>
        <commons-codec.version>1.11</commons-codec.version>
+        <commons-math3.version>3.6.1</commons-math3.version>
    </properties>

 </project>
@@ -0,0 +1,83 @@
+package com.baeldung.algorithms.caesarcipher;
+
+import org.apache.commons.math3.stat.inference.ChiSquareTest;
+
+import java.util.Arrays;
+import java.util.stream.IntStream;
+
+public class CaesarCipher {
+    private static final char LETTER_A = 'a';
+    private static final char LETTER_Z = 'z';
+    private static final int ALPHABET_SIZE = LETTER_Z - LETTER_A + 1;
+    private static final double[] ENGLISH_LETTERS_PROBABILITIES = {0.073, 0.009, 0.030, 0.044, 0.130, 0.028, 0.016, 0.035, 0.074, 0.002, 0.003, 0.035, 0.025, 0.078, 0.074, 0.027, 0.003, 0.077, 0.063, 0.093, 0.027, 0.013, 0.016, 0.005, 0.019, 0.001};
+
+    public String cipher(String message, int offset) {
+        StringBuilder result = new StringBuilder();
+
+        for (char character : message.toCharArray()) {
+            if (character != ' ') {
+                int originalAlphabetPosition = character - LETTER_A;
+                int newAlphabetPosition = (originalAlphabetPosition + offset) % ALPHABET_SIZE;
+                char newCharacter = (char) (LETTER_A + newAlphabetPosition);
+                result.append(newCharacter);
+            } else {
+                result.append(character);
+            }
+        }
+
+        return result.toString();
+    }
+
+    public String decipher(String message, int offset) {
+        return cipher(message, ALPHABET_SIZE - (offset % ALPHABET_SIZE));
+    }
+
+    public int breakCipher(String message) {
+        return probableOffset(chiSquares(message));
+    }
+
+    private double[] chiSquares(String message) {
+        double[] expectedLettersFrequencies = expectedLettersFrequencies(message.length());
+
+        double[] chiSquares = new double[ALPHABET_SIZE];
+
+        for (int offset = 0; offset < chiSquares.length; offset++) {
+            String decipheredMessage = decipher(message, offset);
+            long[] lettersFrequencies = observedLettersFrequencies(decipheredMessage);
+            double chiSquare = new ChiSquareTest().chiSquare(expectedLettersFrequencies, lettersFrequencies);
+            chiSquares[offset] = chiSquare;
+        }
+
+        return chiSquares;
+    }
+
+    private long[] observedLettersFrequencies(String message) {
+        return IntStream.rangeClosed(LETTER_A, LETTER_Z)
+          .mapToLong(letter -> countLetter((char) letter, message))
+          .toArray();
+    }
+
+    private long countLetter(char letter, String message) {
+        return message.chars()
+          .filter(character -> character == letter)
+          .count();
+    }
+
+    private double[] expectedLettersFrequencies(int messageLength) {
+        return Arrays.stream(ENGLISH_LETTERS_PROBABILITIES)
+          .map(probability -> probability * messageLength)
+          .toArray();
+    }
+
+    private int probableOffset(double[] chiSquares) {
+        int probableOffset = 0;
+        for (int offset = 0; offset < chiSquares.length; offset++) {
+            System.out.println(String.format("Chi-Square for offset %d: %.2f", offset, chiSquares[offset]));
+            if (chiSquares[offset] < chiSquares[probableOffset]) {
+                probableOffset = offset;
+            }
+        }
+
+        return probableOffset;
+    }
+}
@@ -0,0 +1,83 @@
+package com.baeldung.algorithms.caesarcipher;
+
+import org.junit.jupiter.api.Test;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+class CaesarCipherUnitTest {
+    private static final String SENTENCE = "he told me i could never teach a llama to drive";
+    private static final String SENTENCE_SHIFTED_THREE = "kh wrog ph l frxog qhyhu whdfk d oodpd wr gulyh";
+    private static final String SENTENCE_SHIFTED_TEN = "ro dyvn wo s myevn xofob dokmr k vvkwk dy nbsfo";
+
+    private CaesarCipher algorithm = new CaesarCipher();
+
+    @Test
+    void givenSentenceAndShiftThree_whenCipher_thenCipheredMessageWithoutOverflow() {
+        String cipheredSentence = algorithm.cipher(SENTENCE, 3);
+
+        assertThat(cipheredSentence)
+          .isEqualTo(SENTENCE_SHIFTED_THREE);
+    }
+
+    @Test
+    void givenSentenceAndShiftTen_whenCipher_thenCipheredMessageWithOverflow() {
+        String cipheredSentence = algorithm.cipher(SENTENCE, 10);
+
+        assertThat(cipheredSentence)
+          .isEqualTo(SENTENCE_SHIFTED_TEN);
+    }
+
+    @Test
+    void givenSentenceAndShiftThirtySix_whenCipher_thenCipheredLikeTenMessageWithOverflow() {
+        String cipheredSentence = algorithm.cipher(SENTENCE, 36);
+
+        assertThat(cipheredSentence)
+          .isEqualTo(SENTENCE_SHIFTED_TEN);
+    }
+
+    @Test
+    void givenSentenceShiftedThreeAndShiftThree_whenDecipher_thenOriginalSentenceWithoutOverflow() {
+        String decipheredSentence = algorithm.decipher(SENTENCE_SHIFTED_THREE, 3);
+
+        assertThat(decipheredSentence)
+          .isEqualTo(SENTENCE);
+    }
+
+    @Test
+    void givenSentenceShiftedTenAndShiftTen_whenDecipher_thenOriginalSentenceWithOverflow() {
+        String decipheredSentence = algorithm.decipher(SENTENCE_SHIFTED_TEN, 10);
+
+        assertThat(decipheredSentence)
+          .isEqualTo(SENTENCE);
+    }
+
+    @Test
+    void givenSentenceShiftedTenAndShiftThirtySix_whenDecipher_thenOriginalSentenceWithOverflow() {
+        String decipheredSentence = algorithm.decipher(SENTENCE_SHIFTED_TEN, 36);
+
+        assertThat(decipheredSentence)
+          .isEqualTo(SENTENCE);
+    }
+
+    @Test
+    void givenSentenceShiftedThree_whenBreakCipher_thenOriginalSentence() {
+        int offset = algorithm.breakCipher(SENTENCE_SHIFTED_THREE);
+
+        assertThat(offset)
+          .isEqualTo(3);
+
+        assertThat(algorithm.decipher(SENTENCE_SHIFTED_THREE, offset))
+          .isEqualTo(SENTENCE);
+    }
+
+    @Test
+    void givenSentenceShiftedTen_whenBreakCipher_thenOriginalSentence() {
+        int offset = algorithm.breakCipher(SENTENCE_SHIFTED_TEN);
+
+        assertThat(offset)
+          .isEqualTo(10);
+
+        assertThat(algorithm.decipher(SENTENCE_SHIFTED_TEN, offset))
+          .isEqualTo(SENTENCE);
+    }
+}
@@ -15,7 +15,7 @@ public class LocalDbCreationRule extends ExternalResource {
    @Override
    protected void before() throws Exception {
        String port = "8000";
-        this.server = ServerRunner.createServerFromCommandLineArgs(new String[]{"-inMemory", "-port", port});
+        this.server = ServerRunner.createServerFromCommandLineArgs(new String[]{"-inMemory","-sharedDb" ,"-port", port});
        server.start();
    }

@@ -18,7 +18,7 @@ public class CFUAAOAuth2ResourceServerRestController {

    @GetMapping("/read")
    public String read(JwtAuthenticationToken jwtAuthenticationToken) {
-        return "Hello write: " + jwtAuthenticationToken.getTokenAttributes();
+        return "Hello read: " + jwtAuthenticationToken.getTokenAttributes();
    }

    @GetMapping("/write")
@@ -29,6 +29,27 @@
            <version>${assertj.version}</version>
            <scope>test</scope>
        </dependency>
+        <dependency>
+            <groupId>org.openjdk.jmh</groupId>
+            <artifactId>jmh-core</artifactId>
+            <version>${jmh.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.openjdk.jmh</groupId>
+            <artifactId>jmh-generator-annprocess</artifactId>
+            <version>${jmh.version}</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.eclipse.collections</groupId>
+            <artifactId>eclipse-collections</artifactId>
+            <version>10.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.eclipse.collections</groupId>
+            <artifactId>eclipse-collections-api</artifactId>
+            <version>10.0.0</version>
+        </dependency>
    </dependencies>

    <build>
@@ -42,6 +63,42 @@
                    <target>${maven.compiler.target.version}</target>
                </configuration>
            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-shade-plugin</artifactId>
+                <version>3.2.1</version>
+                <executions>
+                    <execution>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>shade</goal>
+                        </goals>
+                        <configuration>
+                            <finalName>${uberjar.name}</finalName>
+                            <transformers>
+                                <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+                                    <mainClass>org.openjdk.jmh.Main</mainClass>
+                                </transformer>
+                                <transformer implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/>
+                            </transformers>
+                            <filters>
+                                <filter>
+                                    <!--
+                                        Shading signed JARs will fail without this.
+                                        http://stackoverflow.com/questions/999489/invalid-signature-file-when-attempting-to-run-a-jar
+                                    -->
+                                    <artifact>*:*</artifact>
+                                    <excludes>
+                                        <exclude>META-INF/*.SF</exclude>
+                                        <exclude>META-INF/*.DSA</exclude>
+                                        <exclude>META-INF/*.RSA</exclude>
+                                    </excludes>
+                                </filter>
+                            </filters>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
        </plugins>
    </build>

@@ -50,6 +107,7 @@
        <maven.compiler.target.version>11</maven.compiler.target.version>
        <guava.version>27.1-jre</guava.version>
        <assertj.version>3.11.1</assertj.version>
+        <uberjar.name>benchmarks</uberjar.name>
+        <jmh.version>1.22</jmh.version>
    </properties>
-
 </project>
@@ -0,0 +1,70 @@
+package com.baeldung.benchmark;
+
+import org.eclipse.collections.api.list.MutableList;
+import org.eclipse.collections.api.list.primitive.IntList;
+import org.eclipse.collections.api.list.primitive.MutableIntList;
+import org.eclipse.collections.impl.factory.primitive.IntLists;
+import org.eclipse.collections.impl.list.mutable.FastList;
+import org.eclipse.collections.impl.list.mutable.primitive.IntArrayList;
+import org.openjdk.jmh.annotations.*;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.PrimitiveIterator;
+import java.util.Random;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
+
+@State(Scope.Benchmark)
+@BenchmarkMode(Mode.Throughput)
+@OutputTimeUnit(TimeUnit.SECONDS)
+@Fork(2)
+public class IntegerListFilter {
+
+    private List<Integer> jdkIntList;
+    private MutableList<Integer> ecMutableList;
+    private IntList ecIntList;
+    private ExecutorService executor;
+
+    @Setup
+    public void setup() {
+        PrimitiveIterator.OfInt iterator = new Random(1L).ints(-10000, 10000).iterator();
+        ecMutableList = FastList.newWithNValues(1_000_000, iterator::nextInt);
+        jdkIntList = new ArrayList<>(1_000_000);
+        jdkIntList.addAll(ecMutableList);
+        ecIntList = ecMutableList.collectInt(i -> i, new IntArrayList(1_000_000));
+        executor = Executors.newWorkStealingPool();
+    }
+
+    @Benchmark
+    public List<Integer> jdkList() {
+        return jdkIntList.stream().filter(i -> i % 5 == 0).collect(Collectors.toList());
+    }
+
+    @Benchmark
+    public MutableList<Integer> ecMutableList() {
+        return ecMutableList.select(i -> i % 5 == 0);
+    }
+
+    @Benchmark
+    public List<Integer> jdkListParallel() {
+        return jdkIntList.parallelStream().filter(i -> i % 5 == 0).collect(Collectors.toList());
+    }
+
+    @Benchmark
+    public MutableList<Integer> ecMutableListParallel() {
+        return ecMutableList.asParallel(executor, 100_000).select(i -> i % 5 == 0).toList();
+    }
+
+    @Benchmark
+    public IntList ecPrimitive() {
+        return this.ecIntList.select(i -> i % 5 == 0);
+    }
+
+    @Benchmark
+    public IntList ecPrimitiveParallel() {
+        return this.ecIntList.primitiveParallelStream().filter(i -> i % 5 == 0).collect(IntLists.mutable::empty, MutableIntList::add, MutableIntList::addAll);
+    }
+}
@@ -0,0 +1,67 @@
+package com.baeldung.benchmark;
+
+import org.eclipse.collections.api.list.MutableList;
+import org.eclipse.collections.api.list.primitive.IntList;
+import org.eclipse.collections.impl.list.mutable.FastList;
+import org.eclipse.collections.impl.list.mutable.primitive.IntArrayList;
+import org.openjdk.jmh.annotations.*;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.PrimitiveIterator;
+import java.util.Random;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
+
+@State(Scope.Benchmark)
+@BenchmarkMode(Mode.Throughput)
+@OutputTimeUnit(TimeUnit.SECONDS)
+@Fork(2)
+public class IntegerListSum {
+
+    private List<Integer> jdkIntList;
+    private MutableList<Integer> ecMutableList;
+    private ExecutorService executor;
+    private IntList ecIntList;
+
+    @Setup
+    public void setup() {
+        PrimitiveIterator.OfInt iterator = new Random(1L).ints(-10000, 10000).iterator();
+        ecMutableList = FastList.newWithNValues(1_000_000, iterator::nextInt);
+        jdkIntList = new ArrayList<>(1_000_000);
+        jdkIntList.addAll(ecMutableList);
+        ecIntList = ecMutableList.collectInt(i -> i, new IntArrayList(1_000_000));
+        executor = Executors.newWorkStealingPool();
+    }
+
+    @Benchmark
+    public long jdkList() {
+        return jdkIntList.stream().mapToLong(i -> i).sum();
+    }
+
+    @Benchmark
+    public long ecMutableList() {
+        return ecMutableList.sumOfInt(i -> i);
+    }
+
+    @Benchmark
+    public long jdkListParallel() {
+        return jdkIntList.parallelStream().mapToLong(i -> i).sum();
+    }
+
+    @Benchmark
+    public long ecMutableListParallel() {
+        return ecMutableList.asParallel(executor, 100_000).sumOfInt(i -> i);
+    }
+
+    @Benchmark
+    public long ecPrimitive() {
+        return this.ecIntList.sum();
+    }
+
+    @Benchmark
+    public long ecPrimitiveParallel() {
+        return this.ecIntList.primitiveParallelStream().sum();
+    }
+}
@@ -0,0 +1,33 @@
+package com.baeldung.benchmark;
+
+import org.junit.Before;
+import org.junit.Test;
+
+import static org.junit.Assert.assertEquals;
+
+
+public class IntegerListFilterUnitTest {
+
+    private IntegerListFilter integerListFilter;
+
+    @Before
+    public void init() {
+        integerListFilter = new IntegerListFilter();
+        integerListFilter.setup();
+    }
+
+    @Test
+    public void whenBenchmarkIsExecute_thenJDKListsMustBeOfSameSize() {
+        assertEquals(integerListFilter.jdkList().size(), integerListFilter.jdkListParallel().size());
+    }
+
+    @Test
+    public void whenBenchmarkIsExecute_thenMutableListsMustBeOfSameSize() {
+        assertEquals(integerListFilter.ecMutableList().size(), integerListFilter.ecMutableListParallel().size());
+    }
+
+    @Test
+    public void whenBenchmarkIsExecute_thenPrimitiveListsMustBeOfSameSize() {
+        assertEquals(integerListFilter.ecPrimitive().size(), integerListFilter.ecPrimitiveParallel().size());
+    }
+}
@@ -0,0 +1,33 @@
+package com.baeldung.benchmark;
+
+import org.junit.Before;
+import org.junit.Test;
+
+import static org.junit.Assert.assertEquals;
+
+
+public class IntegerListSumUnitTest {
+
+    private IntegerListSum integerListSum;
+
+    @Before
+    public void init() {
+        integerListSum = new IntegerListSum();
+        integerListSum.setup();
+    }
+
+    @Test
+    public void whenBenchmarkIsExecute_thenJDKListsMustHaveSameValue() {
+        assertEquals(integerListSum.jdkList(), integerListSum.jdkListParallel());
+    }
+
+    @Test
+    public void whenBenchmarkIsExecute_thenMutableListsMustHaveSameValue() {
+        assertEquals(integerListSum.ecMutableList(), integerListSum.ecMutableListParallel());
+    }
+
+    @Test
+    public void whenBenchmarkIsExecute_thenPrimitiveListsMustHaveSameValue() {
+        assertEquals(integerListSum.ecPrimitive(), integerListSum.ecPrimitiveParallel());
+    }
+}
@@ -0,0 +1 @@
+Sample file content
@@ -1,4 +1,4 @@
-package com.baeldung.list;
+package com.baeldung.list.duplicatescounter;

 import java.util.HashMap;
 import java.util.List;
@@ -33,9 +33,9 @@ public class CollectionFilteringUnitTest {

        for (Employee employee : originalList) {
            for (String name : nameFilter) {
-                if (employee.getName()
-                    .equalsIgnoreCase(name)) {
+                if (employee.getName().equals(name)) {
                    filteredList.add(employee);
+                    //break;
                }
            }
        }
@@ -1,4 +1,4 @@
-package com.baeldung.list;
+package com.baeldung.list.duplicatescounter;

 import org.assertj.core.util.Lists;
 import org.junit.jupiter.api.Test;
@@ -1,17 +1,38 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <modelVersion>4.0.0</modelVersion>
-    <artifactId>core-java-date-operations</artifactId>
-    <version>${project.parent.version}</version>
-    <packaging>jar</packaging>
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<artifactId>core-java-date-operations</artifactId>
+	<version>${project.parent.version}</version>
+	<packaging>jar</packaging>

-    <parent>
-        <groupId>com.baeldung</groupId>
-        <artifactId>parent-java</artifactId>
-        <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../../parent-java</relativePath>
-    </parent>
+	<parent>
+		<groupId>com.baeldung</groupId>
+		<artifactId>parent-java</artifactId>
+		<version>0.0.1-SNAPSHOT</version>
+		<relativePath>../../parent-java</relativePath>
+	</parent>

+	<dependencies>
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-lang3</artifactId>
+			<version>${commons-lang3.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>joda-time</groupId>
+			<artifactId>joda-time</artifactId>
+			<version>${joda-time.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>com.darwinsys</groupId>
+			<artifactId>hirondelle-date4j</artifactId>
+			<version>${hirondelle-date4j.version}</version>
+		</dependency>
+	</dependencies>
+	<properties>
+		<joda-time.version>2.10</joda-time.version>
+		<hirondelle-date4j.version>1.5.1</hirondelle-date4j.version>
+	</properties>
 </project>
@@ -0,0 +1,55 @@
+package com.baeldung.date.comparison;
+
+import java.text.SimpleDateFormat;
+import java.time.LocalDate;
+import java.time.ZoneId;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.TimeZone;
+
+import org.apache.commons.lang3.time.DateUtils;
+
+import hirondelle.date4j.DateTime;
+
+public class DateComparisonUtils {
+
+    public static boolean isSameDayUsingLocalDate(Date date1, Date date2) {
+        LocalDate localDate1 = date1.toInstant()
+            .atZone(ZoneId.systemDefault())
+            .toLocalDate();
+        LocalDate localDate2 = date2.toInstant()
+            .atZone(ZoneId.systemDefault())
+            .toLocalDate();
+        return localDate1.isEqual(localDate2);
+    }
+
+    public static boolean isSameDayUsingSimpleDateFormat(Date date1, Date date2) {
+        SimpleDateFormat fmt = new SimpleDateFormat("yyyyMMdd");
+        return fmt.format(date1)
+            .equals(fmt.format(date2));
+    }
+
+    public static boolean isSameDayUsingCalendar(Date date1, Date date2) {
+        Calendar calendar1 = Calendar.getInstance();
+        calendar1.setTime(date1);
+        Calendar calendar2 = Calendar.getInstance();
+        calendar2.setTime(date2);
+        return calendar1.get(Calendar.YEAR) == calendar2.get(Calendar.YEAR) && calendar1.get(Calendar.MONTH) == calendar2.get(Calendar.MONTH) && calendar1.get(Calendar.DAY_OF_MONTH) == calendar2.get(Calendar.DAY_OF_MONTH);
+    }
+
+    public static boolean isSameDayUsingApacheCommons(Date date1, Date date2) {
+        return DateUtils.isSameDay(date1, date2);
+    }
+
+    public static boolean isSameDayUsingJoda(Date date1, Date date2) {
+        org.joda.time.LocalDate localDate1 = new org.joda.time.LocalDate(date1);
+        org.joda.time.LocalDate localDate2 = new org.joda.time.LocalDate(date2);
+        return localDate1.equals(localDate2);
+    }
+
+    public static boolean isSameDayUsingDate4j(Date date1, Date date2) {
+        DateTime dateObject1 = DateTime.forInstant(date1.getTime(), TimeZone.getDefault());
+        DateTime dateObject2 = DateTime.forInstant(date2.getTime(), TimeZone.getDefault());
+        return dateObject1.isSameDayAs(dateObject2);
+    }
+}
@@ -0,0 +1,31 @@
+package com.baeldung.datetime;
+
+import java.time.DayOfWeek;
+import java.time.LocalDate;
+
+public class AddSubtractDaysSkippingWeekendsUtils {
+
+    public static LocalDate addDaysSkippingWeekends(LocalDate date, int days) {
+        LocalDate result = date;
+        int addedDays = 0;
+        while (addedDays < days) {
+            result = result.plusDays(1);
+            if (!(result.getDayOfWeek() == DayOfWeek.SATURDAY || result.getDayOfWeek() == DayOfWeek.SUNDAY)) {
+                ++addedDays;
+            }
+        }
+        return result;
+    }
+
+    public static LocalDate subtractDaysSkippingWeekends(LocalDate date, int days) {
+        LocalDate result = date;
+        int subtractedDays = 0;
+        while (subtractedDays < days) {
+            result = result.minusDays(1);
+            if (!(result.getDayOfWeek() == DayOfWeek.SATURDAY || result.getDayOfWeek() == DayOfWeek.SUNDAY)) {
+                ++subtractedDays;
+            }
+        }
+        return result;
+    }
+}
@@ -0,0 +1,53 @@
+package com.baeldung.date.comparison;
+
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.util.Date;
+
+import org.junit.Test;
+
+public class DateComparisonUtilsUnitTest {
+
+    private Date day1Morning = toDate(LocalDateTime.of(2019, 10, 19, 6, 30, 40));
+    private Date day1Evening = toDate(LocalDateTime.of(2019, 10, 19, 18, 30, 50));
+    private Date day2Morning = toDate(LocalDateTime.of(2019, 10, 20, 6, 30, 50));
+
+    private Date toDate(LocalDateTime localDateTime) {
+        return Date.from(localDateTime.atZone(ZoneId.systemDefault())
+            .toInstant());
+    }
+
+    @Test
+    public void givenDatesWithDifferentTime_whenIsSameDay_thenReturnsTrue() {
+        assertTrue(DateComparisonUtils.isSameDayUsingLocalDate(day1Morning, day1Evening));
+        assertTrue(DateComparisonUtils.isSameDayUsingSimpleDateFormat(day1Morning, day1Evening));
+        assertTrue(DateComparisonUtils.isSameDayUsingCalendar(day1Morning, day1Evening));
+        assertTrue(DateComparisonUtils.isSameDayUsingApacheCommons(day1Morning, day1Evening));
+        assertTrue(DateComparisonUtils.isSameDayUsingJoda(day1Morning, day1Evening));
+        assertTrue(DateComparisonUtils.isSameDayUsingDate4j(day1Morning, day1Evening));
+    }
+
+    @Test
+    public void givenDates_whenIsDifferentDay_thenReturnsFalse() {
+        assertFalse(DateComparisonUtils.isSameDayUsingLocalDate(day1Morning, day2Morning));
+        assertFalse(DateComparisonUtils.isSameDayUsingLocalDate(day1Evening, day2Morning));
+
+        assertFalse(DateComparisonUtils.isSameDayUsingSimpleDateFormat(day1Morning, day2Morning));
+        assertFalse(DateComparisonUtils.isSameDayUsingSimpleDateFormat(day1Evening, day2Morning));
+
+        assertFalse(DateComparisonUtils.isSameDayUsingCalendar(day1Morning, day2Morning));
+        assertFalse(DateComparisonUtils.isSameDayUsingCalendar(day1Evening, day2Morning));
+
+        assertFalse(DateComparisonUtils.isSameDayUsingApacheCommons(day1Morning, day2Morning));
+        assertFalse(DateComparisonUtils.isSameDayUsingApacheCommons(day1Evening, day2Morning));
+
+        assertFalse(DateComparisonUtils.isSameDayUsingJoda(day1Morning, day2Morning));
+        assertFalse(DateComparisonUtils.isSameDayUsingJoda(day1Evening, day2Morning));
+
+        assertFalse(DateComparisonUtils.isSameDayUsingDate4j(day1Morning, day2Morning));
+        assertFalse(DateComparisonUtils.isSameDayUsingDate4j(day1Evening, day2Morning));
+    }
+}
@@ -0,0 +1,27 @@
+package com.baeldung.datetime;
+
+import static org.junit.Assert.assertEquals;
+
+import org.junit.Test;
+
+import java.time.LocalDate;
+
+public class AddSubtractDaysSkippingWeekendsUtilsUnitTest {
+
+    @Test
+    public void givenLocalDateAndDaysToAdd_thenAddDaysSkippingWeekends() {
+        LocalDate initialDate = LocalDate.of(2019, 11, 7);
+        LocalDate expectedDate = LocalDate.of(2019, 11, 13);
+        LocalDate result = AddSubtractDaysSkippingWeekendsUtils.addDaysSkippingWeekends(initialDate, 4);
+        assertEquals(expectedDate, result);
+    }
+
+    @Test
+    public void givenLocalDateAndDaysToSubtract_thenSubtractDaysSkippingWeekends() {
+        LocalDate initialDate = LocalDate.of(2019, 11, 7);
+        LocalDate expectedDate = LocalDate.of(2019, 11, 1);
+        LocalDate result = AddSubtractDaysSkippingWeekendsUtils.subtractDaysSkippingWeekends(initialDate, 4);
+        assertEquals(expectedDate, result);
+    }
+
+}
@@ -7,15 +7,9 @@ import org.junit.Test;
 import com.baeldung.datetime.sql.TimeUtils;

 import java.text.ParseException;
-import java.util.Date;

 public class TimeUtilsUnitTest {

-    @Test
-    public void givenCurrentTime_thenNowIsReturned() {
-        assertEquals(TimeUtils.getNow(), new Date());
-    }
-
    @Test(expected = IllegalArgumentException.class)
    public void givenTimeAsString_whenPatternIsNotRespected_thenExceptionIsThrown() {
        TimeUtils.getTime("10 11 12");
@@ -1,3 +1,5 @@
-# Intellij
-.idea/
-*.iml
+0.*
+
+# Files generated by integration tests
+# *.txt
+/temp
@@ -1,7 +1,15 @@
+## Core Java IO

-### Relevant Articles:
+This module contains articles about core Java input and output (IO)

+### Relevant Articles: 
 - [Create a File in a Specific Directory in Java](https://www.baeldung.com/java-create-file-in-directory)
- [A Guide to the Java FileReader Class](https://www.baeldung.com/java-filereader)
- [The Java File Class](https://www.baeldung.com/java-io-file)
- [Java FileWriter](https://www.baeldung.com/java-filewriter)
+- [How to Read a Large File Efficiently with Java](https://www.baeldung.com/java-read-lines-large-file)
+- [Java – Write to File](https://www.baeldung.com/java-write-to-file)
+- [FileNotFoundException in Java](https://www.baeldung.com/java-filenotfound-exception)
+- [Delete the Contents of a File in Java](https://www.baeldung.com/java-delete-file-contents)
+- [List Files in a Directory in Java](https://www.baeldung.com/java-list-directory-files)
+- [Java – Append Data to a File](https://www.baeldung.com/java-append-to-file)
+- [How to Copy a File with Java](https://www.baeldung.com/java-copy-file)
+- [Create a Directory in Java](https://www.baeldung.com/java-create-directory)
+- [[<-- Prev]](/core-java-modules/core-java-io)
--- a/Show More
+++ b/Show More