多线程 - （五）Executor框架

偏执的太偏执、 2022-05-23 12:14 283阅读 0赞

## Executor框架详解 ##

**转载内容：**[转载内容][Link 1]

## Executor框架应用 ##

**使用Executor框架解决仓库配货时的并发问题**

基本思路：

*  因为仓库出库单出库配货时，存在资源共享问题（商品共享），所以多线程并发配货时存在同步问题
 *  解决思路一：加锁
 *  解决思路二：将配货动作封装成任务，交由单线程处理，即请求配货的过程是允许并发的，但真正的配货动作是有顺序的，依据队列的顺序一个一个的进行

package com.ahut.threadPool;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.*;
    
    /** * @author cheng * @className: ThreadPoolTest * @description: * @dateTime 2018/6/8 9:42 */
    public class ThreadPoolTest implements Callable<Boolean> { 
    
        /** * @description: 主函数 * @author cheng * @dateTime 2018/6/8 9:42 */
        public static void main(String[] args) throws ExecutionException, InterruptedException {
            // 创建一个线程的线程池
            ExecutorService executorService = Executors.newSingleThreadExecutor();
    
            // 任务集合
            List<Callable<Boolean>> list = new ArrayList<>();
            for (int i = 0; i < 10; i++) {
                Callable<Boolean> callable = new ThreadPoolTest("Thread-" + i, i);
                list.add(callable);
            }
    
            // 结果集合
            List<Future<Boolean>> futureList = new ArrayList<>();
            for (Callable<Boolean> callable : list) {
                Future<Boolean> future = executorService.submit(callable);
                futureList.add(future);
            }
    
            // 获取结果
            for (Future<Boolean> future : futureList) {
                Boolean flag = future.get();
                if (flag) {
                    System.out.println("配货成功");
                } else {
                    System.out.println("配货失败");
                }
            }
    
        }
    
        /** * 线程名称 */
        private String name;
        /** * 线程编号 */
        private int num;
    
        public ThreadPoolTest(String name, int num) {
            this.name = name;
            this.num = num;
        }
    
        /** * @description: 任务 * @author cheng * @dateTime 2018/6/8 15:25 */
        @Override
        public Boolean call() throws Exception {
            System.out.println("====>" + name + "配货开始");
            try {
                // 模拟配货耗时
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("====>" + name + "配货结束");
            // 模拟配货成功和失败
            if (num % 2 == 0) {
                return true;
            }
            return false;
        }
    }

运行结果：

====>Thread-0配货开始 ====>Thread-0配货结束 配货成功
    ====>Thread-1配货开始 ====>Thread-1配货结束 配货失败
    ====>Thread-2配货开始 ====>Thread-2配货结束 配货成功
    ====>Thread-3配货开始 ====>Thread-3配货结束 ====>Thread-4配货开始 配货失败
    ====>Thread-4配货结束 配货成功
    ====>Thread-5配货开始 ====>Thread-5配货结束 配货失败
    ====>Thread-6配货开始 ====>Thread-6配货结束 配货成功
    ====>Thread-7配货开始 ====>Thread-7配货结束 配货失败
    ====>Thread-8配货开始 ====>Thread-8配货结束 配货成功
    ====>Thread-9配货开始 ====>Thread-9配货结束 配货失败

[Link 1]: https://www.cnblogs.com/study-everyday/archive/2017/04/20/6737428.html#autoid-0-0-0