feat: 增加热点代码

niumoo · niumoo · commit 45ef97b4fba7 · 2023-02-25T16:24:01.000+08:00
diff --git a/tool-java-hotcode/src/main/java/com/wdbyte/hotcode/HotCode.java b/tool-java-hotcode/src/main/java/com/wdbyte/hotcode/HotCode.java
@@ -21,26 +21,43 @@ public class HotCode {
     public static void main(String[] args) {
         // 模拟 CPU 过高
         cpuHigh();
-        // 模拟线程阻塞，线程池容量为1，塞入两个线程，会有一个一直等待
-        thread();
+        // 生成大长度数组
+        allocate();
         // 模拟线程死锁
         deadThread();
         // 不断的向 hashSet 集合增加数据，内存缓慢增长
         addHashSetThread();
-        // 生成大长度数组
-        allocate();
+        // 模拟线程阻塞，线程池容量为1，塞入两个线程，会有一个一直等待
+        thread();
     }
 
+    /**
+     * 消耗CPU的线程
+     * 不断循环进行浮点运算
+     */
+    private static void cpuHigh() {
+        Thread thread = new Thread(() -> {
+            Thread.currentThread().setName("cpu_high_thread");
+            while (true){
+                double pi = 0;
+                for (int i = 0; i < Integer.MAX_VALUE; i++) {
+                    pi += Math.pow(-1, i) / (2 * i + 1);
+                }
+                System.out.println("Pi: " + pi * 4);
+            }
+        });
+        thread.start();
+    }
     private static Object array;
 
     /**
      * 生成大长度数组
      */
     private static void allocate() {
         new Thread(() -> {
+            Thread.currentThread().setName("memory_allocate_thread_1");
             int index = 1;
             while (true) {
-                Thread.currentThread().setName("memory_allocate_thread");
                 array = new int[1 * index * 1000];
                 array = new Integer[1 * index * 1000];
                 try {
@@ -54,6 +71,7 @@ private static void allocate() {
         }).start();
 
         new Thread(()->{
+            Thread.currentThread().setName("memory_allocate_thread_2");
             List<String> list = new ArrayList<>();
             for (int i = 0; i < 1000000; i++) {
                 try {
@@ -66,64 +84,6 @@ private static void allocate() {
         }).start();
     }
 
-    /**
-     * 不断的向 hashSet 集合添加数据，每秒100个字符串
-     */
-    public static void addHashSetThread() {
-        // 初始化常量
-        new Thread(() -> {
-            int count = 0;
-            while (true) {
-                Thread.currentThread().setName("add_hash_set_thread");
-                try {
-                    hashSet.add("count" + count);
-                    Thread.sleep(10);
-                    count++;
-                } catch (InterruptedException e) {
-                    e.printStackTrace();
-                }
-            }
-        }).start();
-    }
-
-    /**
-     * 极度消耗CPU的线程
-     * 死循环
-     */
-    private static void cpuHigh() {
-        Thread thread = new Thread(() -> {
-            Thread.currentThread().setName("cpu_high_thread");
-            while (true){
-                double pi = 0;
-                for (int i = 0; i < Integer.MAX_VALUE; i++) {
-                    pi += Math.pow(-1, i) / (2 * i + 1);
-                }
-                System.out.println("Pi: " + pi * 4);
-            }
-        });
-        thread.start();
-    }
-
-    /**
-     * 模拟线程阻塞
-     * 线程池容量为1，但是向线程池中塞入两个线程
-     */
-    private static void thread() {
-        Thread thread = new Thread(() -> {
-            while (true) {
-                System.out.println("executorService thread start");
-                try {
-                    Thread.sleep(1000);
-                } catch (InterruptedException e) {
-                    e.printStackTrace();
-                }
-            }
-        });
-        // 添加到线程
-        executorService.submit(thread);
-        executorService.submit(thread);
-    }
-
     /**
      * 死锁线程
      * 线程 dead_thread_A 与 线程 dead_thread_B 互相锁死
@@ -167,4 +127,55 @@ private static void deadThread() {
         threadA.start();
         threadB.start();
     }
+
+
+    /**
+     * 不断的向 hashSet 集合添加数据，每秒100个字符串
+     */
+    public static void addHashSetThread() {
+        // 初始化常量
+        new Thread(() -> {
+            Thread.currentThread().setName("add_hash_set_thread");
+            int count = 0;
+            while (true) {
+                try {
+                    hashSet.add("count" + count);
+                    Thread.sleep(10);
+                    count++;
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            }
+        }).start();
+    }
+
+    /**
+     * 模拟线程阻塞
+     * 线程池容量为1，但是向线程池中塞入两个线程
+     */
+    private static void thread() {
+        Thread thread = new Thread(() -> {
+            System.out.println("executorService thread start");
+            while (true) {
+                try {
+                    Thread.sleep(1000);
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            }
+        });
+        // 添加到线程
+        executorService.submit(thread);
+        executorService.submit(thread);
+        executorService.submit(thread);
+        executorService.submit(thread);
+    }
+
+    /**
+     * 运行缓慢的方法
+     */
+    public static void runSlowThread(){
+        new Thread(() -> {
+        }).start();
+    }
 }
