//實(shí)現(xiàn)工作線程 - 工作線程中維護(hù)了公有的任務(wù)隊(duì)列（阻塞）, 工作線程的執(zhí)行邏輯。 循環(huán)取隊(duì)列中的任務(wù)去執(zhí)行處理。
class Worker extends Thread {
    //阻塞任務(wù)隊(duì)列 - 可以保證多個(gè)線程對(duì)隊(duì)列操作， 線程安全
    private BlockingQueue<Runnable> queue = null;
    //每個(gè)工作線程都會(huì)有一個(gè)阻塞隊(duì)列，這個(gè)隊(duì)列中保存了所有的任務(wù)
    public Worker(BlockingQueue<Runnable> queue, int id) {
        this.queue = queue;
     //   Thread.currentThread().setName("郝夢(mèng)武" + id + "號(hào)工作線程");
    }
    
    //工作線程執(zhí)行內(nèi)容
    @Override
    public void run() {
        //每個(gè)線程通過(guò)isInterrupted()判斷線程異常狀態(tài)。
        try {
            while (!Thread.currentThread().isInterrupted()) {
                //如果線程正常， 返回false, 出現(xiàn)異常， 返回true， 該狀態(tài)默認(rèn)為false
                Runnable command = queue.take();    //如果隊(duì)列為空， take會(huì)讓線程阻塞
                System.out.println(Thread.currentThread().getName() + "正在處理任務(wù)" + command.hashCode());
                command.run();
            }
        }
        catch(InterruptedException e) {
            System.out.println(Thread.currentThread().getName() + "被中止了");
        //    e.printStackTrace();      //不需要拋出異常
        }
    }
}

//線程池 - 維護(hù)很多個(gè)線程， 當(dāng)來(lái)一個(gè)任務(wù)時(shí)， 從線程池中獲取一個(gè)線程去處理執(zhí)行。
//好處： 防止線程頻繁開(kāi)辟和銷(xiāo)毀帶來(lái)的性能損耗
class MyThreadPool {
    //創(chuàng)建任務(wù)線程安全的隊(duì)列, 保證多個(gè)線程對(duì)這個(gè)隊(duì)列操作時(shí)是線程安全的
    private BlockingQueue<Runnable> queue = new LinkedBlockingQueue<>();
    //線程管理列表 - 這個(gè)列表保存了所有線程對(duì)象的引用， 方便后續(xù)的管理
    private List<Worker> Wokers = new ArrayList<>();
    private final static int maxWorkerCount = 10;   //線程池最大允許的個(gè)數(shù)

    //execute方法
    public void execute(Runnable command) throws InterruptedException {
        if(Wokers.size() < maxWorkerCount) {
            //創(chuàng)建一個(gè)新的工作線程
            Worker worker = new Worker(queue, Wokers.size());   //創(chuàng)建工作線程
            worker.start();                      //創(chuàng)建的工程線程啟動(dòng)
            Wokers.add(worker);                  //添加到管理列表中
        }
        queue.put(command);                      //添加任務(wù)到線程安全的隊(duì)列中
    }

    //銷(xiāo)毀所有線程 - 將每個(gè)線程中狀態(tài)置為中斷狀態(tài)方法， 并且
    public void shutDown() throws InterruptedException {
        for(Worker worker : Wokers) {
            worker.interrupt();                  //將線程的狀態(tài)置為中斷， 調(diào)用isInterruptd()返回值為true
        }
        //并且讓主線程join阻塞等待所有工作線程
        for(Worker worker : Wokers) {
            worker.join();                       //join方法可以讓調(diào)用的線程處于阻塞狀態(tài)， 知道等待的線程結(jié)束完畢之后就會(huì)恢復(fù)
        }
        //執(zhí)行到這塊， 代表所有的線程銷(xiāo)毀完畢
        System.out.println("所有工作線程銷(xiāo)毀完畢!");
    }
}

class MyRunnable implements Runnable {
    private int num;
    MyRunnable(int num) {
        this.num = num;
    }
    @Override
    public void run() {
        System.out.println("正在執(zhí)行任務(wù): " + num);
    }
}

public static void main(String[] args) throws InterruptedException {
     MyThreadPool myThreadPool = new MyThreadPool();
     for(int i = 0; i < 1000; i++) {
         myThreadPool.execute(new MyRunnable(i + 1));
     }
     Thread.sleep(2000);   //主線程休眠2s
     myThreadPool.shutDown();  //銷(xiāo)毀所有工作線程
     System.out.println("線程池已經(jīng)被銷(xiāo)毀了");
     }