Java并发：Executor线程池框架简介

Author: cicadasmile

java-se-base-parent/model-multy-thread/src/main/java/com/multy/thread/block08executor/Executor01.java

@@ -0,0 +1,47 @@
+package com.multy.thread.block08executor;
+import java.util.concurrent.*;
+
+public class Executor01 {
+    // 定义线程池
+    private static ThreadPoolExecutor poolExecutor = new ThreadPoolExecutor(
+                    3,10,5000,TimeUnit.SECONDS,
+                    new SynchronousQueue<>(),Executors.defaultThreadFactory(),new ExeHandler());
+    public static void main(String[] args) {
+        for (int i = 0 ; i < 100 ; i++){
+            poolExecutor.execute(new PoolTask(i));
+            //带返回值：poolExecutor.submit(new PoolTask(i));
+        }
+    }
+}
+// 定义线程池任务
+class PoolTask implements Runnable {
+
+    private int numParam;
+
+    public PoolTask (int numParam) {
+        this.numParam = numParam;
+    }
+    @Override
+    public void run() {
+        try {
+            System.out.println("PoolTask "+ numParam+" begin...");
+            Thread.sleep(5000);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+    public int getNumParam() {
+        return numParam;
+    }
+    public void setNumParam(int numParam) {
+        this.numParam = numParam;
+    }
+}
+// 定义异常处理
+class ExeHandler implements RejectedExecutionHandler {
+    @Override
+    public void rejectedExecution(Runnable runnable, ThreadPoolExecutor executor) {
+        System.out.println("ExeHandler "+executor.getCorePoolSize());
+        executor.shutdown();
+    }
+}

java-se-base-parent/model-multy-thread/src/main/java/com/multy/thread/block08executor/Executor02.java

@@ -0,0 +1,65 @@
+package com.multy.thread.block08executor;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+
+public class Executor02 {
+
+    public static void main(String[] args) {
+        // 初始化校验任务
+        List<CheckTask> checkTaskList = new ArrayList<>() ;
+        initList(checkTaskList);
+        // 定义线程池
+        ExecutorService executorService ;
+        if (checkTaskList.size() < 10){
+            executorService = Executors.newFixedThreadPool(checkTaskList.size());
+        }else{
+            executorService = Executors.newFixedThreadPool(10);
+        }
+        // 批量处理
+        List<Future<Boolean>> results = new ArrayList<>() ;
+        try {
+            results = executorService.invokeAll(checkTaskList);
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+        }
+        // 查看结果
+        for (Future<Boolean> result : results){
+            try {
+                System.out.println(result.get());
+                // System.out.println(result.get(10000,TimeUnit.SECONDS));
+            } catch (Exception e) {
+                e.printStackTrace() ;
+            }
+        }
+        // 关闭线程池
+        executorService.shutdownNow();
+    }
+
+    private static void initList (List<CheckTask> checkTaskList){
+        checkTaskList.add(new CheckTask("root","123")) ;
+        checkTaskList.add(new CheckTask("root1","1234")) ;
+        checkTaskList.add(new CheckTask("root2","1235")) ;
+    }
+}
+// 校验任务
+class CheckTask implements Callable<Boolean> {
+    private String userName ;
+    private String passWord ;
+    public CheckTask(String userName, String passWord) {
+        this.userName = userName;
+        this.passWord = passWord;
+    }
+    @Override
+    public Boolean call() throws Exception {
+        // 校验账户+密码
+        if (userName.equals("root") && passWord.equals("123")){
+            return Boolean.TRUE ;
+        }
+        return Boolean.FALSE ;
+    }
+}