h-hub · November 2, 2021 06:05 · Nov 2, 2021
diff --git a/CallableExample.java b/CallableExample.java
@@ -0,0 +1,40 @@
+public class CallableExample {
+
+    public static void main(String[] args) {
+
+        ExecutorService executor = Executors.newFixedThreadPool(10);
+
+        List<Future<String>> list = new ArrayList<>();
+
+        Callable<String> callable = new HelloCallable();
+
+        for(int i=0; i< 100; i++){
+            Future<String> future = executor.submit(callable);
+            list.add(future);
+        }
+
+        for(Future<String> fut : list){
+            try {
+                System.out.println(fut.get());
+            } catch (InterruptedException | ExecutionException e) {
+                System.out.println("Exception thrown: "+e.getMessage());
+            }
+        }
+
+        executor.shutdown();
+    }
+}
+
+class HelloCallable implements Callable<String> {
+
+    @Override
+    public String call() throws Exception {
+        LocalDateTime now =  LocalDateTime.now();
+        long nanos = now.toInstant(OffsetDateTime.now().getOffset())
+                .toEpochMilli();
+        if(nanos % 2 == 0){
+            throw new Exception("even time: "+nanos);
+        }
+        return LocalDateTime.now().toString();
+    }
+}