Callable接口通过FutureTask包装器

CPU-Code · CPU-Code · commit 9520927f5157 · 2021-07-23T22:45:20.000+08:00
diff --git a/thread/README.md b/thread/README.md
@@ -85,6 +85,7 @@
 
 - [x] [继承Thread类创建线程](src/main/java/com/cpucode/java/application/thread/MyThread.java)
 - [x] [实现Runnable接口创建线程](src/main/java/com/cpucode/java/application/thread/MyRunnable.java)
+- [x] [Callable接口通过FutureTask包装器](src/main/java/com/cpucode/java/application/thread/CallableDemo.java)
 
 
 - [返回文件目录](#文件目录)
diff --git a/thread/src/main/java/com/cpucode/java/application/thread/CallableDemo.java b/thread/src/main/java/com/cpucode/java/application/thread/CallableDemo.java
@@ -0,0 +1,34 @@
+package com.cpucode.java.application.thread;
+
+import java.util.concurrent.*;
+
+/**
+ * 实现 Callable 接口通过 FutureTask 包装器来创建 Thread 线程
+ *
+ * @author : cpucode
+ * @date : 2021/7/23
+ * @time : 22:41
+ * @github : https://github.com/CPU-Code
+ * @csdn : https://blog.csdn.net/qq_44226094
+ */
+public class CallableDemo implements Callable<String> {
+    public static void main(String[] args) throws ExecutionException, InterruptedException {
+        ExecutorService executorService = Executors.newFixedThreadPool(1);
+
+        CallableDemo callableDemo = new CallableDemo();
+        Future<String> future = executorService.submit(callableDemo);
+
+        System.out.println(future.get());
+        executorService.shutdown();
+    }
+
+    @Override
+    public String call() throws Exception {
+        int a = 1;
+        int b = 2;
+
+        System.out.println(a + b);
+
+        return "执行结果:" + (a + b);
+    }
+}
