update

Author: yennanliu

src/main/java/Advances/Annotation/test1.java renamed to src/main/java/Advances/Annotation/Test1.java

@@ -6,7 +6,7 @@
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
 
-public class test1 {
+public class Test1 {
   private static Object[] array;
   private static int total;
 

src/main/java/threadDev/Fibonacci.java

@@ -0,0 +1,26 @@
+package threadDev;
+
+
+import java.io.Serializable;
+import java.util.concurrent.Callable;
+
+public class Fibonacci<Long> implements Callable<java.lang.Long>, Serializable {
+    int input = 0;
+
+    public Fibonacci() {
+    }
+
+    public Fibonacci(int input) {
+        this.input = input;
+    }
+
+    public java.lang.Long call() {
+        return calculate (input);
+    }
+
+    private long calculate (int n) {
+        if (Thread.currentThread().isInterrupted()) return 0;
+        if (n <= 1) return n;
+        else return calculate(n-1) + calculate(n-2);
+    }
+}

src/main/java/threadDev/Test1.java

@@ -0,0 +1,53 @@
+package threadDev;
+
+// https://docs.hazelcast.org/docs/1.9/manual/html/ch07s02.html
+
+import java.io.Serializable;
+import java.util.concurrent.*;
+
+public class Test1 {
+    public static void main(String[] args){
+
+        //ThreadPoolExecutor es = new ThreadPoolExecutor(10); //Hazelcast.getExecutorService();
+
+        final int _pcautoSchedulerPoolSize = 1000;
+        final int KEEP_ALIVE_TIME = 60;
+
+        final int MAX_POOL_SIZE = 1000;
+        final int CORE_POOL_SIZE = 500; // Example value, set according to your needs
+
+        ThreadPoolExecutor executor = new ThreadPoolExecutor(
+                CORE_POOL_SIZE,
+                MAX_POOL_SIZE,
+                KEEP_ALIVE_TIME,
+                TimeUnit.SECONDS,
+                new SynchronousQueue<>(),
+                new ThreadPoolExecutor.AbortPolicy() // DiscardPolicy
+        );
+
+        Test1 t1 = new Test1();
+        Fibonacci fibonacci = new Fibonacci();
+        int n = 10;
+        Future future = executor.submit(new Fibonacci(n));
+        
+        try {
+            //return future.get(3, TimeUnit.SECONDS);
+            future.get(3, TimeUnit.SECONDS);
+        } catch (TimeoutException e) {
+            future.cancel(true);
+        } catch (ExecutionException e) {
+            throw new RuntimeException(e);
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+
+        System.out.println(123);
+
+    }
+
+    public void myFunc(){
+       System.out.println(123);
+    }
+
+
+}