Update FixedThreadPoolEx.java

jstobigdata · May 5, 2023 · a3b009f · a3b009f
1 parent 4be8733
commit a3b009f
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/...hreading-01-executors/src/main/java/c/jbd/multithreading/executors/FixedThreadPoolEx.java b/...hreading-01-executors/src/main/java/c/jbd/multithreading/executors/FixedThreadPoolEx.java
@@ -11,11 +11,16 @@ public FixedThreadPoolEx(int taskId) {
 
     @Override
     public void run() {
-        System.out.println("Task: %d is running".formatted(taskId));
+        try {
+            Thread.sleep(5000);
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+        System.out.println("Task: %d is running in %s".formatted(taskId, Thread.currentThread().getName()));
     }
 
     public static void main(String[] args) {
-        ExecutorService executor = Executors.newFixedThreadPool(6);
+        ExecutorService executor = Executors.newFixedThreadPool(3);
 
         for (int i = 0; i < 10; i++) {
             executor.submit(new FixedThreadPoolEx(i));