Code for CallableFuture Added

jstobigdata · May 5, 2023 · 4be8733 · 4be8733
1 parent ebb715b
commit 4be8733
Show file tree

Hide file tree

Showing 5 changed files with 55 additions and 25 deletions.
diff --git a/.gitignore b/.gitignore
@@ -12,4 +12,5 @@ buildNumber.properties
 /.idea/
 /Core-Java-Features/.idea/
 /Java-SE-17-Features/.idea/
-.DS_Store
+.DS_Store
+/.idea/sonarlint/
diff --git a/.idea/sonarlint/issuestore/index.pb b/.idea/sonarlint/issuestore/index.pb
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
diff --git a/Core-Java-Features/java-multithreading-01-executors/pom.xml b/Core-Java-Features/java-multithreading-01-executors/pom.xml
@@ -17,5 +17,13 @@
         <maven.compiler.target>17</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
+            <version>4.2.0</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
 
 </project>
diff --git a/...threading-01-executors/src/main/java/c/jbd/multithreading/executors/CallableFutureEx.java b/...threading-01-executors/src/main/java/c/jbd/multithreading/executors/CallableFutureEx.java
@@ -14,6 +14,7 @@ public CallableFutureEx(int taskId) {
 
     @Override
     public String call() throws Exception {
+        Thread.sleep(500); //just to imitate real work
         return "TaskId:"
             + this.taskId
             + " "
@@ -35,6 +36,8 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc
             System.out.println(f.get());
         }
 
+        executorService.shutdown();
+
     }
 }