🔄Update: 创建线程池

README.md

@@ -1 +1 @@
-https://doc.hutool.cn/pages/ExecutorBuilder
+> 注意：Java ExecutorService 使用的默认等待队列是无限大小的 `LinkedBlockingQueue`，容易 OOM，不推荐使用

pom.xml

@@ -23,12 +23,6 @@
     </parent>
 
     <dependencies>
-        <dependency>
-            <groupId>cn.hutool</groupId>
-            <artifactId>hutool-core</artifactId>
-            <version>5.8.31</version>
-        </dependency>
-
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>

src/main/java/cn/hezhaohui/threadpool/ThreadPoolApplication.java

@@ -1,42 +1,34 @@
 package cn.hezhaohui.threadpool;
 
-import cn.hutool.core.thread.ExecutorBuilder;
 import lombok.extern.slf4j.Slf4j;
 
-import java.util.concurrent.ArrayBlockingQueue;
+import java.util.Random;
-import java.util.concurrent.RejectedExecutionHandler;
+import java.util.concurrent.ExecutorService;
-import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 
 @Slf4j
 public class ThreadPoolApplication {
-    public static void main(String[] args) {
+    public static void main(String[] args) throws InterruptedException {
-        ExecutorBuilder builder = new ExecutorBuilder();
+        ExecutorService executorService = Executors.newFixedThreadPool(2);
-        ThreadPoolExecutor executor = builder
+        for (int i = 0; i < 100000000; i++) {
-                .setCorePoolSize(5)
+            executorService.execute(() -> {
-                .setMaxPoolSize(10)
+                StringBuilder builder = new StringBuilder();
-                .setKeepAliveTime(0)
+                int random = new Random().nextInt(1000);
-                .setHandler(new RejectedExecutionHandler(){
+                for (int j = 1; j < random; j++) {
-                    @Override
+                    builder.append(j);
-                    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
-                        log.info(r.toString());
-                    }
-                })
-                .setWorkQueue(new ArrayBlockingQueue<>(100))
-                .build();
-
-        for (int i = 1; i <= 1000; i++) {
-            executor.execute(() -> {
-                log.info("Hello");
-                try {
-                    Thread.sleep(1000);
-                } catch (InterruptedException e) {
-                    throw new RuntimeException(e);
                 }
+                try {
+                    TimeUnit.HOURS.sleep(1);
+                } catch (InterruptedException e) {
+                    log.error("[Error]");
+                }
+                log.info(builder.toString());
+
             });
         }
 
-        executor.shutdown();
+        executorService.shutdown();
-
+        executorService.awaitTermination(1, TimeUnit.HOURS);
     }
 }