From 1c5e81fa34cb4876dcca0b8498bc6142d5cf9bee Mon Sep 17 00:00:00 2001 From: uzma Date: Thu, 30 Nov 2023 01:31:02 +0000 Subject: [PATCH 1/4] [BAEL-7073] code for executor service --- .../executorservice/ExecuteExample.java | 25 ++++++++++++++ .../executorservice/SubmitExample.java | 34 +++++++++++++++++++ 2 files changed, 59 insertions(+) create mode 100644 core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java create mode 100644 core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java diff --git a/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java b/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java new file mode 100644 index 0000000000..8331ff84fc --- /dev/null +++ b/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java @@ -0,0 +1,25 @@ +package com.baeldung.concurrent.executorservice; + +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; + +public class ExecuteExample { + public static void main(String[] args) + { + ExecutorService executorService = Executors.newFixedThreadPool(2); + // Task using Runnable + Runnable task = () -> + { + int[] numbers = {1, 2, 3, 4, 5}; + int sum = 0; + for (int num : numbers) { + sum += num; + } + System.out.println("Sum calculated using execute:" + sum); + }; + // Submit the task using execute + executorService.execute(task); executorService.shutdown(); + + } + +} diff --git a/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java b/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java new file mode 100644 index 0000000000..93fa77be1d --- /dev/null +++ b/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java @@ -0,0 +1,34 @@ +package com.baeldung.concurrent.executorservice; + +import java.util.concurrent.Callable; +import java.util.concurrent.ExecutionException; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.Future; + +public class SubmitExample { + public static void main(String[] args) + { + ExecutorService executorService = Executors.newFixedThreadPool(2); + Callable task = () -> + { + int[] numbers = {1, 2, 3, 4, 5}; + int sum = 0; + for (int num : numbers) { + sum += num; + } + return sum; + }; + // Submit the task and obtain a Future + Future result = executorService.submit(task); + try { + // Get the result + int sum = result.get(); + System.out.println("Sum calculated using submit:" + sum); + } catch (InterruptedException | ExecutionException e) + { + e.printStackTrace(); + } + executorService.shutdown(); + } +} \ No newline at end of file From 596c10de0acbd550c61b374f03cd78241b7a01ae Mon Sep 17 00:00:00 2001 From: uzma Date: Sun, 3 Dec 2023 22:23:51 +0000 Subject: [PATCH 2/4] [BAEL-7073] fix code style --- .../executorservice/ExecuteExample.java | 31 +++++++------ .../executorservice/SubmitExample.java | 43 +++++++++---------- 2 files changed, 35 insertions(+), 39 deletions(-) diff --git a/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java b/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java index 8331ff84fc..6b6d6e3e8a 100644 --- a/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java +++ b/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java @@ -4,22 +4,21 @@ import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class ExecuteExample { - public static void main(String[] args) - { - ExecutorService executorService = Executors.newFixedThreadPool(2); - // Task using Runnable - Runnable task = () -> - { - int[] numbers = {1, 2, 3, 4, 5}; - int sum = 0; - for (int num : numbers) { - sum += num; - } - System.out.println("Sum calculated using execute:" + sum); - }; - // Submit the task using execute - executorService.execute(task); executorService.shutdown(); + public static void main(String[] args) { + ExecutorService executorService = Executors.newFixedThreadPool(2); + // Task using Runnable + Runnable task = () -> { + int[] numbers = { 1, 2, 3, 4, 5 }; + int sum = 0; + for (int num : numbers) { + sum += num; + } + System.out.println("Sum calculated using execute:" + sum); + }; + // Submit the task using execute + executorService.execute(task); + executorService.shutdown(); - } + } } diff --git a/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java b/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java index 93fa77be1d..cd715edcc0 100644 --- a/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java +++ b/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java @@ -7,28 +7,25 @@ import java.util.concurrent.Executors; import java.util.concurrent.Future; public class SubmitExample { - public static void main(String[] args) - { - ExecutorService executorService = Executors.newFixedThreadPool(2); - Callable task = () -> - { - int[] numbers = {1, 2, 3, 4, 5}; - int sum = 0; - for (int num : numbers) { - sum += num; - } - return sum; - }; - // Submit the task and obtain a Future - Future result = executorService.submit(task); - try { - // Get the result - int sum = result.get(); - System.out.println("Sum calculated using submit:" + sum); - } catch (InterruptedException | ExecutionException e) - { - e.printStackTrace(); + public static void main(String[] args) { + ExecutorService executorService = Executors.newFixedThreadPool(2); + Callable task = () -> { + int[] numbers = { 1, 2, 3, 4, 5 }; + int sum = 0; + for (int num : numbers) { + sum += num; + } + return sum; + }; + // Submit the task and obtain a Future + Future result = executorService.submit(task); + try { + // Get the result + int sum = result.get(); + System.out.println("Sum calculated using submit:" + sum); + } catch (InterruptedException | ExecutionException e) { + e.printStackTrace(); + } + executorService.shutdown(); } - executorService.shutdown(); - } } \ No newline at end of file From efb004602538fd3d9bd1240855a764c479a53adc Mon Sep 17 00:00:00 2001 From: uzma Date: Sun, 17 Dec 2023 16:41:12 +0000 Subject: [PATCH 3/4] [BAEL-7073] change location of code --- .../executorservice/ExecuteExample.java | 24 ++++++++++++++ .../executorservice/SubmitExample.java | 31 +++++++++++++++++++ 2 files changed, 55 insertions(+) create mode 100644 core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java create mode 100644 core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java diff --git a/core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java b/core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java new file mode 100644 index 0000000000..6b6d6e3e8a --- /dev/null +++ b/core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java @@ -0,0 +1,24 @@ +package com.baeldung.concurrent.executorservice; + +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; + +public class ExecuteExample { + public static void main(String[] args) { + ExecutorService executorService = Executors.newFixedThreadPool(2); + // Task using Runnable + Runnable task = () -> { + int[] numbers = { 1, 2, 3, 4, 5 }; + int sum = 0; + for (int num : numbers) { + sum += num; + } + System.out.println("Sum calculated using execute:" + sum); + }; + // Submit the task using execute + executorService.execute(task); + executorService.shutdown(); + + } + +} diff --git a/core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java b/core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java new file mode 100644 index 0000000000..cd715edcc0 --- /dev/null +++ b/core-java-modules/core-java-concurrency-basic-3/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java @@ -0,0 +1,31 @@ +package com.baeldung.concurrent.executorservice; + +import java.util.concurrent.Callable; +import java.util.concurrent.ExecutionException; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.Future; + +public class SubmitExample { + public static void main(String[] args) { + ExecutorService executorService = Executors.newFixedThreadPool(2); + Callable task = () -> { + int[] numbers = { 1, 2, 3, 4, 5 }; + int sum = 0; + for (int num : numbers) { + sum += num; + } + return sum; + }; + // Submit the task and obtain a Future + Future result = executorService.submit(task); + try { + // Get the result + int sum = result.get(); + System.out.println("Sum calculated using submit:" + sum); + } catch (InterruptedException | ExecutionException e) { + e.printStackTrace(); + } + executorService.shutdown(); + } +} \ No newline at end of file From ee4679456f5936a1cbab06bff7f0394fe3884c98 Mon Sep 17 00:00:00 2001 From: uzma Date: Sun, 17 Dec 2023 16:44:23 +0000 Subject: [PATCH 4/4] [BAEL-7073] delete code from old module --- .../executorservice/ExecuteExample.java | 24 -------------- .../executorservice/SubmitExample.java | 31 ------------------- 2 files changed, 55 deletions(-) delete mode 100644 core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java delete mode 100644 core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java diff --git a/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java b/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java deleted file mode 100644 index 6b6d6e3e8a..0000000000 --- a/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/ExecuteExample.java +++ /dev/null @@ -1,24 +0,0 @@ -package com.baeldung.concurrent.executorservice; - -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; - -public class ExecuteExample { - public static void main(String[] args) { - ExecutorService executorService = Executors.newFixedThreadPool(2); - // Task using Runnable - Runnable task = () -> { - int[] numbers = { 1, 2, 3, 4, 5 }; - int sum = 0; - for (int num : numbers) { - sum += num; - } - System.out.println("Sum calculated using execute:" + sum); - }; - // Submit the task using execute - executorService.execute(task); - executorService.shutdown(); - - } - -} diff --git a/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java b/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java deleted file mode 100644 index cd715edcc0..0000000000 --- a/core-java-modules/core-java-concurrency-simple/src/main/java/com/baeldung/concurrent/executorservice/SubmitExample.java +++ /dev/null @@ -1,31 +0,0 @@ -package com.baeldung.concurrent.executorservice; - -import java.util.concurrent.Callable; -import java.util.concurrent.ExecutionException; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; -import java.util.concurrent.Future; - -public class SubmitExample { - public static void main(String[] args) { - ExecutorService executorService = Executors.newFixedThreadPool(2); - Callable task = () -> { - int[] numbers = { 1, 2, 3, 4, 5 }; - int sum = 0; - for (int num : numbers) { - sum += num; - } - return sum; - }; - // Submit the task and obtain a Future - Future result = executorService.submit(task); - try { - // Get the result - int sum = result.get(); - System.out.println("Sum calculated using submit:" + sum); - } catch (InterruptedException | ExecutionException e) { - e.printStackTrace(); - } - executorService.shutdown(); - } -} \ No newline at end of file