diff --git a/core-java-modules/core-java-lambdas/src/main/java/com/baeldung/lambdas/LambdaVariables.java b/core-java-modules/core-java-lambdas/src/main/java/com/baeldung/lambdas/LambdaVariables.java deleted file mode 100644 index 5c1201150f..0000000000 --- a/core-java-modules/core-java-lambdas/src/main/java/com/baeldung/lambdas/LambdaVariables.java +++ /dev/null @@ -1,88 +0,0 @@ -package com.baeldung.lambdas; - -import java.util.Random; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; -import java.util.function.Supplier; -import java.util.stream.IntStream; - -/** - * Class with examples about working with capturing lambdas. - */ -public class LambdaVariables { - - private volatile boolean run = true; - private int start = 0; - - private ExecutorService executor = Executors.newFixedThreadPool(3); - - public static void main(String[] args) { - new LambdaVariables().localVariableMultithreading(); - } - - Supplier incrementer(int start) { - return () -> start; // can't modify start parameter inside the lambda - } - - Supplier incrementer() { - return () -> start++; - } - - public void localVariableMultithreading() { - boolean run = true; - executor.execute(() -> { - while (run) { - // do operation - } - }); - // commented because it doesn't compile, it's just an example of non-final local variables in lambdas - // run = false; - } - - public void instanceVariableMultithreading() { - executor.execute(() -> { - while (run) { - // do operation - } - }); - - run = false; - } - - /** - * WARNING: always avoid this workaround!! - */ - public void workaroundSingleThread() { - int[] holder = new int[] { 2 }; - IntStream sums = IntStream - .of(1, 2, 3) - .map(val -> val + holder[0]); - - holder[0] = 0; - - System.out.println(sums.sum()); - } - - /** - * WARNING: always avoid this workaround!! - */ - public void workaroundMultithreading() { - int[] holder = new int[] { 2 }; - Runnable runnable = () -> System.out.println(IntStream - .of(1, 2, 3) - .map(val -> val + holder[0]) - .sum()); - - new Thread(runnable).start(); - - // simulating some processing - try { - Thread.sleep(new Random().nextInt(3) * 1000L); - } catch (InterruptedException e) { - throw new RuntimeException(e); - } - - holder[0] = 0; - } - -} diff --git a/core-java-modules/core-java-lambdas/src/main/java/com/baeldung/java8/lambda/serialization/NotSerializableLambdaExpression.java b/core-java-modules/core-java-lambdas/src/main/java/com/ossez/java8/lambda/serialization/NotSerializableLambdaExpression.java similarity index 81% rename from core-java-modules/core-java-lambdas/src/main/java/com/baeldung/java8/lambda/serialization/NotSerializableLambdaExpression.java rename to core-java-modules/core-java-lambdas/src/main/java/com/ossez/java8/lambda/serialization/NotSerializableLambdaExpression.java index 38f87e4ba9..feb8224fb5 100644 --- a/core-java-modules/core-java-lambdas/src/main/java/com/baeldung/java8/lambda/serialization/NotSerializableLambdaExpression.java +++ b/core-java-modules/core-java-lambdas/src/main/java/com/ossez/java8/lambda/serialization/NotSerializableLambdaExpression.java @@ -1,4 +1,4 @@ -package com.baeldung.java8.lambda.serialization; +package com.ossez.java8.lambda.serialization; public class NotSerializableLambdaExpression { public static Object getLambdaExpressionObject() { diff --git a/core-java-modules/core-java-lambdas/src/test/java/com/baeldung/java8/lambda/serialization/LambdaSerializationUnitTest.java b/core-java-modules/core-java-lambdas/src/test/java/com/baeldung/java8/lambda/serialization/LambdaSerializationUnitTest.java index bb71e3bdb9..a8991c104a 100644 --- a/core-java-modules/core-java-lambdas/src/test/java/com/baeldung/java8/lambda/serialization/LambdaSerializationUnitTest.java +++ b/core-java-modules/core-java-lambdas/src/test/java/com/baeldung/java8/lambda/serialization/LambdaSerializationUnitTest.java @@ -1,5 +1,6 @@ package com.baeldung.java8.lambda.serialization; +import com.ossez.java8.lambda.serialization.NotSerializableLambdaExpression; import org.junit.Test; import java.io.*; diff --git a/persistence-modules/activejdbc/pom.xml b/persistence-modules/activejdbc/pom.xml index 00290203cc..f12fddb09c 100644 --- a/persistence-modules/activejdbc/pom.xml +++ b/persistence-modules/activejdbc/pom.xml @@ -65,7 +65,7 @@ mysql mysql-connector-java - ${mysql.connector.version} + ${mysql-connector-j.version} @@ -75,7 +75,7 @@ 3.4-j11 development.test,development - 8.0.24 + 8.3.0 \ No newline at end of file