Executors - JiyangM/spring GitHub Wiki

    public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue<Runnable>());
    }

    public static ExecutorService newSingleThreadExecutor() {
        return new FinalizableDelegatedExecutorService
            (new ThreadPoolExecutor(1, 1,
                                    0L, TimeUnit.MILLISECONDS,
                                    new LinkedBlockingQueue<Runnable>()));
    }

    public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue<Runnable>());
    }

    public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
        return new ScheduledThreadPoolExecutor(corePoolSize);
    }

public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(2);

        //线程池的饱和策略
        System.out.println(service.getRejectedExecutionHandler());

        for (int i = 0; i < 10; i++) {
            service.execute(new Task(i));
            System.out.println("ActiveCount: " + service.getActiveCount());
            System.out.println("CompletedTaskCount: " + service.getCompletedTaskCount());
            System.out.println("QueueSize: " + service.getQueue().size());
            System.out.println("*****************************************");
        }
    }

    static class Task implements Runnable {

        int id;

        public Task(int id) {
            this.id = id;
        }

        @Override
        public void run() {
            try {
                Thread.sleep(50L);
                System.out.println("完成：" + id);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

   //创建一个固定线程的线程池
        ThreadPoolExecutor service = new ThreadPoolExecutor(2, 2, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingDeque<>(1));
        //饱和策略
        System.out.println(service.getRejectedExecutionHandler());

        for (int i = 0; i < 5; i++) {
            service.execute(new Task(i));
            System.out.println("ActiveCount: " + service.getActiveCount());
            System.out.println("CompletedTaskCount: " + service.getCompletedTaskCount());
            System.out.println("QueueSize: " + service.getQueue().size());
            System.out.println("*****************************************");
        }
    }

public static void main(String[] args) {
        //创建一个固定线程的线程池
        ThreadPoolExecutor service =  new ThreadPoolExecutor(0, Integer.MAX_VALUE, 30L, TimeUnit.SECONDS,
                new SynchronousQueue<>());

        //线程池的饱和策略
        System.out.println(service.getRejectedExecutionHandler());


        for (int i = 0; i < 10; i++) {
            service.execute(new Task(i));
            System.out.println("ActiveCount: " + service.getActiveCount());
            System.out.println("CompletedTaskCount: " + service.getCompletedTaskCount());
            System.out.println("QueueSize: " + service.getQueue().size());
            System.out.println("*****************************************");
        }
    }