Java多线程-ThreadPool线程池（三） 线程池Java

/**
 * 工人
 */
public class Worker {
    /**
     * 干活
     */
    public void dosomething() {
        try {
            TimeUnit.SECONDS.sleep(2);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("挖坑");
    }
}

/**
 * 经理
 */
public class Manager implements Runnable {
    private Worker worker;

    public Worker getWorker() {
        return worker;
    }

    public void setWorker(Worker worker) {
        this.worker = worker;
    }

    /**
     * 经理动嘴，工人动手
     */
    @Override
    public void run() {
        worker.dosomething();
    }
}

/**
 * 项目组
 */
public class ManagerGroup {
    private static ExecutorService projectGroup = new ThreadPoolExecutor(
            3, // 核心小队数量
            3, // 最多能容纳多少个小队
            30, // 多久没活干就请出项目组
            TimeUnit.SECONDS, // 时间单位
            new ArrayBlockingQueue<Runnable>(3),// 有多少个项目经理就不再接收入组申请
            new ThreadPoolExecutor.CallerRunsPolicy() // 项目组拒绝响应时怎么处理
    );

    // 项目组增加工作小队
    public static void addTask(Manager manager) {
        projectGroup.execute(manager);
    }

    public static void main(String[] args) {
        Manager manager1 = new Manager();
        Worker worker1 = new Worker();
        manager1.setWorker(worker1);

        Manager manager2 = new Manager();
        Worker worker2 = new Worker();
        manager2.setWorker(worker2);

        Manager manager3 = new Manager();
        Worker worker3 = new Worker();
        manager3.setWorker(worker3);

        // 申请进入项目组有活干才可能不被优化
        ManagerGroup.addTask(manager1);
        ManagerGroup.addTask(manager2);
        ManagerGroup.addTask(manager3);
    }
}