diff --git a/core-java/src/main/java/com/baeldung/concurrent/Scheduledexecutorservice/ScheduledExecutorServiceDemo.java b/core-java/src/main/java/com/baeldung/concurrent/Scheduledexecutorservice/ScheduledExecutorServiceDemo.java
index 171f308c16..b77019eea5 100644
--- a/core-java/src/main/java/com/baeldung/concurrent/Scheduledexecutorservice/ScheduledExecutorServiceDemo.java
+++ b/core-java/src/main/java/com/baeldung/concurrent/Scheduledexecutorservice/ScheduledExecutorServiceDemo.java
@@ -1,6 +1,5 @@
 package com.baeldung.concurrent.Scheduledexecutorservice;
 
-import java.util.concurrent.Callable;
 import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
 import java.util.concurrent.ScheduledExecutorService;
@@ -12,32 +11,21 @@ public class ScheduledExecutorServiceDemo {
 	public void execute() {
 		ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
 
-		ScheduledFuture<?> scheduledFuture = executorService.schedule(new Runnable() {
-			@Override
-			public void run() {
-				// task details
-			}
+		ScheduledFuture<?> scheduledFuture = executorService.schedule(() -> {
+			// Task
 		}, 1, TimeUnit.SECONDS);
 
-		executorService.scheduleAtFixedRate(new Runnable() {
-			@Override
-			public void run() {
-				// task details
-			}
+		executorService.scheduleAtFixedRate(() -> {
+			// Task
 		}, 1, 10, TimeUnit.SECONDS);
 
-		executorService.scheduleWithFixedDelay(new Runnable() {
-			@Override
-			public void run() {
-				// task details
-			}
+		executorService.scheduleWithFixedDelay(() -> {
+			// Task
 		}, 1, 10, TimeUnit.SECONDS);
 
-		Future<String> future = executorService.schedule(new Callable<String>() {
-			@Override
-			public String call() throws Exception {
-				return "Hello World";
-			}
+		Future<String> future = executorService.schedule(() -> {
+			// Task
+			return "Hellow world";
 		}, 1, TimeUnit.SECONDS);
 
 		executorService.shutdown();
diff --git a/core-java/src/main/java/com/baeldung/concurrent/cyclicbarrier/CyclicBarrierExample.java b/core-java/src/main/java/com/baeldung/concurrent/cyclicbarrier/CyclicBarrierExample.java
index e6075c933e..85c0cf7680 100644
--- a/core-java/src/main/java/com/baeldung/concurrent/cyclicbarrier/CyclicBarrierExample.java
+++ b/core-java/src/main/java/com/baeldung/concurrent/cyclicbarrier/CyclicBarrierExample.java
@@ -5,11 +5,9 @@ import java.util.concurrent.CyclicBarrier;
 public class CyclicBarrierExample {
 
 	public void start() {
-		CyclicBarrier cyclicBarrier = new CyclicBarrier(3, new Runnable() {
-			@Override
-			public void run() {
-				System.out.println("All previous tasks are completed");
-			}
+		CyclicBarrier cyclicBarrier = new CyclicBarrier(3, () -> {
+			// Task
+			System.out.println("All previous tasks are completed");
 		});
 
 		Thread t1 = new Thread(new Task(cyclicBarrier), "T1");
diff --git a/core-java/src/main/java/com/baeldung/concurrent/executor/ExecutorDemo.java b/core-java/src/main/java/com/baeldung/concurrent/executor/ExecutorDemo.java
index 9392134bfb..84998cb489 100644
--- a/core-java/src/main/java/com/baeldung/concurrent/executor/ExecutorDemo.java
+++ b/core-java/src/main/java/com/baeldung/concurrent/executor/ExecutorDemo.java
@@ -6,11 +6,8 @@ public class ExecutorDemo {
 
 	public void execute() {
 		Executor executor = new Invoker();
-		executor.execute(new Runnable() {
-			@Override
-			public void run() {
-				// task to be performed
-			}
+		executor.execute(()->{
+			// task to be performed
 		});
 	}
 
diff --git a/core-java/src/main/java/com/baeldung/concurrent/executorservice/ExecutorServiceDemo.java b/core-java/src/main/java/com/baeldung/concurrent/executorservice/ExecutorServiceDemo.java
index 631ae140ab..ae2b279d9a 100644
--- a/core-java/src/main/java/com/baeldung/concurrent/executorservice/ExecutorServiceDemo.java
+++ b/core-java/src/main/java/com/baeldung/concurrent/executorservice/ExecutorServiceDemo.java
@@ -10,15 +10,10 @@ public class ExecutorServiceDemo {
 
 	public void execute() {
 
-		executor.execute(new Runnable() {
-			@Override
-			public void run() {
-				// task details
-			}
+		executor.submit(() -> {
+			new Task();
 		});
 
-		executor.submit(new Task());
-
 		executor.shutdown();
 		executor.shutdownNow();
 		try {
diff --git a/core-java/src/main/java/com/baeldung/concurrent/future/FutureDemo.java b/core-java/src/main/java/com/baeldung/concurrent/future/FutureDemo.java
index 89ce1a0a41..7cb611be0f 100644
--- a/core-java/src/main/java/com/baeldung/concurrent/future/FutureDemo.java
+++ b/core-java/src/main/java/com/baeldung/concurrent/future/FutureDemo.java
@@ -1,6 +1,5 @@
 package com.baeldung.concurrent.future;
 
-import java.util.concurrent.Callable;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -16,12 +15,10 @@ public class FutureDemo {
 
 		ExecutorService executorService = Executors.newFixedThreadPool(10);
 
-		Future<String> future = executorService.submit(new Callable<String>() {
-			@Override
-			public String call() throws Exception {
-				Thread.sleep(10000l);
-				return "Hello World";
-			}
+		Future<String> future = executorService.submit(() -> {
+			// Task
+			Thread.sleep(10000l);
+			return "Hellow world";
 		});
 
 		future.cancel(false);