线程池详解

Author: Snailclimb

code/java/ThreadPoolExecutorDemo/.idea/uiDesigner.xml

@@ -0,0 +1,49 @@
+package callable;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Future;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+import static common.ThreadPoolConstants.CORE_POOL_SIZE;
+import static common.ThreadPoolConstants.KEEP_ALIVE_TIME;
+import static common.ThreadPoolConstants.MAX_POOL_SIZE;
+import static common.ThreadPoolConstants.QUEUE_CAPACITY;
+
+public class CallableDemo {
+    public static void main(String[] args) {
+        //使用阿里巴巴推荐的创建线程池的方式
+        //通过ThreadPoolExecutor构造函数自定义参数创建
+        ThreadPoolExecutor executor = new ThreadPoolExecutor(
+                CORE_POOL_SIZE,
+                MAX_POOL_SIZE,
+                KEEP_ALIVE_TIME,
+                TimeUnit.SECONDS,
+                new ArrayBlockingQueue<>(QUEUE_CAPACITY),
+                new ThreadPoolExecutor.CallerRunsPolicy());
+
+        List<Future<String>> futureList = new ArrayList<>();
+        Callable<String> callable = new MyCallable();
+        for (int i = 0; i < 10; i++) {
+            //提交任务到线程池
+            Future<String> future = executor.submit(callable);
+            //将返回值 future 添加到 list，我们可以通过 future 获得 执行 Callable 得到的返回值
+            futureList.add(future);
+        }
+        for (Future<String> fut : futureList) {
+            try {
+                System.out.println(new Date() + "::" + fut.get());
+            } catch (InterruptedException | ExecutionException e) {
+                e.printStackTrace();
+            }
+        }
+        //关闭线程池
+        executor.shutdown();
+    }
+}
+

code/java/ThreadPoolExecutorDemo/out/production/ThreadPoolExecutorDemo/ThreadPoolExecutorDemo.class

@@ -0,0 +1,13 @@
+package callable;
+
+import java.util.concurrent.Callable;
+
+public class MyCallable implements Callable<String> {
+
+    @Override
+    public String call() throws Exception {
+        Thread.sleep(1000);
+        //返回执行当前 Callable 的线程名字
+        return Thread.currentThread().getName();
+    }
+}