Java多线程常见案例分析线程池与单例模式及阻塞队列

//类加载的时候创建对象，确保只能有一个实例对象
class Singleton {
    private static Singleton instance = new Singleton();
    //私有的构造方法
    private Singleton() {}
    //只能通过getInstance（）方法获取到同一个实例对象
    public static Singleton getInstance() {
        return instance;
    }
}

class Singleton {
    private static Singleton instance = null;
    private Singleton() {}
    public static Singleton getInstance() {
        //第一次使用时，创建实例
        if (instance == null) {
            instance = new Singleton();
        }
        //后面使用时，直接返回第一次创建的实例
        return instance;
    }
}

class Singleton {
    private static Singleton instance = null;
    private Singleton() {}
    //加锁保证不会有多个线程同时访问改代码块
    public synchronized static Singleton getInstance() {
        if (instance == null) {
            instance = new Singleton();
        }
        return instance;
    }
}

class Singleton {
    //使用volatile修饰变量
    private static volatile Singleton instance = null;
    private Singleton() {};
    public static Singleton getInstance() {
        if (instance == null) {
            //只给写操作的相关代码加锁
            synchronized (Singleton.class) {
                //需要双重if判断，防止在多线程中加锁前instance发生变化
                if (instance == null) {
                    instance = new Singleton();
                }
            }
        }
        return instance;
    }
}

public class BlockingQueue{
    //使用循环数组来实现阻塞队列
    private int[] array;
    //队列中已经存放元素的个数
    private int size;
    //放入元素的下标
    private int putIndex;
    //取元素的下标
    private int takeIndex;
    //在构造方法中指定队列的大小
    public BlockingQueue(int capacity){
        array=new int[capacity];
    }
    /*放元素：需要保证线程安全，如果队列满了，线程进入等待*/
    public synchronized void put(int m) throws InterruptedException {
        //队列满，线程等待
        if(size==array.length){
            //需要注意的是，进行等待的是当显得实例对象，不是类对象
            this.wait();
        }
        //放元素，同时更新下标
        array[putIndex]=m;
        putIndex=(putIndex+1)%array.length;
        size++;
        //通知等待的线程
        notifyAll();
    }
    /*取元素：保证线程安全。如果队列为空，线程等待*/
    public synchronized int take() throws InterruptedException {
        //队列为空，线程等待
        if(size==0){
            this.wait();
        }
        //取元素，同时更新下标
        int ret=array[takeIndex];
        takeIndex=(takeIndex+1)%array.length;
        size--;
        //通知等待的线程
        notifyAll();
        return ret;
    }
}

        //使用ThreadPoolExecutor创建线程池
        ThreadPoolExecutor threadPool1=new ThreadPoolExecutor(
                5,
                10,
                3,
                //自由线程无任务时最大存活时间单位：分
                TimeUnit.MINUTES,
                //一般不使用无边界的阻塞队列，内存有限
                new ArrayBlockingQueue<>(100),
                //规定创建线程的标准
                Executors.defaultThreadFactory(),
                //拒绝策略：一般最多使用CallerRunsPolicy(),或自己实现
                new ThreadPoolExecutor.CallerRunsPolicy()
        );

        //Executors的四种创建线程的方法
        //没有临时线程的线程池
        ExecutorService threadPool2= Executors.newFixedThreadPool(10);
        //线程数目动态增长的线程池
        ExecutorService threadPool3=Executors.newCachedThreadPool();
        //创建单个线程的线程池
        ExecutorService threadPool4=Executors.newSingleThreadExecutor();
        //计划线程池
        ExecutorService threadPool5=Executors.newScheduledThreadPool(7);