3-13 自由编程

同学你好，代码完成的不错，很棒呐，这里可以通过改变线程池大小以及线程池中允许的最大线程数来控制输出的语句

如：

​

祝学习愉快~

package threadpool;

import java.util.List;
import java.util.concurrent.*;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;

public class WaterThread extends ThreadPoolExecutor {

    private final ReentrantLock lock = new ReentrantLock();
    private boolean isStoped;
    private Condition unStoped = lock.newCondition();

    public WaterThread(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
    }

    public WaterThread(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory);
    }

    public WaterThread(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, handler);
    }

    public WaterThread(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, handler);
    }

    @Override
    protected void beforeExecute(Thread t, Runnable r) {
        super.beforeExecute(t, r);
        lock.lock();
        try{
            while (isStoped){
                unStoped.await();
                System.out.println("暂停放水中");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }
    }

    private void stop(){
        lock.lock();
        try {
            isStoped = true;
        }finally {
            lock.unlock();
        }
    }

    private void work(){
        lock.lock();
        try{
            isStoped = false;
            unStoped.signalAll();
        } finally {
            lock.unlock();
        }
    }

    public static void main(String[] args) throws InterruptedException {
        WaterThread waterThread = new WaterThread(1, 1, 20l,
                TimeUnit.SECONDS, new LinkedBlockingDeque<>());
        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(10);
                } catch (InterruptedException e) {
                    System.out.println("开始停水正常");
                }
                System.out.println("正在放水");
            }
        };
        System.out.println("上班啦，水池放入1000吨水;");
        for(int i = 0; i < 1000; i++){
            waterThread.execute(runnable);
        }
        Thread.sleep(200);
        waterThread.stop();
        System.out.print("中午啦，回家吃饭啦，水池被暂停啦");
        System.out.println("水池还剩" + waterThread.getQueue().size() + "吨水");
        Thread.sleep(200);
        System.out.println("下午啦，开始放水啦");
        waterThread.work();
        Thread.sleep(200);
        waterThread.shutdown();
        if(waterThread.isShutdown()){
            System.out.println("下午5点啦 开始停水！将在10s后强制停水");
        }
        if(waterThread.awaitTermination(100l, TimeUnit.MILLISECONDS)){
            System.out.println("停水正常，水池也没有水了");
        }else{
            List<Runnable> list= waterThread.shutdownNow();
            System.out.println("启动强制停水");
            System.out.println("水池还剩" + list.size() + "吨水");
        }
    }
}

​