Java定制化线程池

一、ThreadPoolExecutor.execute

public class CustomThreadPool {

    public static ThreadPoolExecutor getThreadPoolExecutor() {
        AtomicInteger threadNumber = new AtomicInteger();
        return new ThreadPoolExecutor(4,
                8,
                1,
                TimeUnit.MINUTES,
                new ArrayBlockingQueue(1000),
                r -> {
                    Thread thread = new Thread(r,"jak-custom-thread-pool-" + threadNumber.getAndIncrement());
                    if (thread.isDaemon()) {
                        thread.setDaemon(true);
                    }
                    return thread;
                });
    }

    public static ThreadPoolExecutor getThreadPoolExecutorNoLambda() {
        AtomicInteger threadNumber = new AtomicInteger();
        return new ThreadPoolExecutor(4,
                8,
                1,
                TimeUnit.MINUTES,
                new ArrayBlockingQueue(1000),
                new ThreadFactory() {
                    @Override
                    public Thread newThread(@NotNull Runnable r) {
                        Thread thread = new Thread(r, "jak-custom-thread-pool-" + threadNumber.getAndIncrement());
                        if (thread.isDaemon()) {
                            thread.setDaemon(false);
                        }
                        return null;
                    }
                });
    }


    private static void asyncPrint() {
        System.out.println(Thread.currentThread().getName() + "-jak");
    }

    public static void main(String[] args) throws InterruptedException {
        System.out.println("开始");

        ThreadPoolExecutor threadPoolExecutor = getThreadPoolExecutor();
        for (int i = 0; i  asyncPrint());
        }

        Thread.sleep(1000);

        System.out.println("结束");
    }
}

public class CustomThreadPool {

    public static ThreadPoolExecutor getThreadPoolExecutor() {
        AtomicInteger threadNumber = new AtomicInteger();
        return new ThreadPoolExecutor(4,
                8,
                1,
                TimeUnit.MINUTES,
                new ArrayBlockingQueue(1000),
                r -> {
                    Thread thread = new Thread(r,"jak-custom-thread-pool-" + threadNumber.getAndIncrement());
                    if (thread.isDaemon()) {
                        thread.setDaemon(true);
                    }
                    return thread;
                });
    }

    public static void main(String[] args) throws InterruptedException {
        System.out.println("开始");

        ThreadPoolExecutor threadPoolExecutor = getThreadPoolExecutor();
        for (int i = 0; i  {
                    Thread thread = new Thread(r,"jak-custom-thread-pool-" + threadNumber.getAndIncrement());
                    if (thread.isDaemon()) {
                        thread.setDaemon(true);
                    }
                    return thread;
                });
    }

    public static void main(String[] args) throws InterruptedException, ExecutionException {
        System.out.println("开始");

        ThreadPoolExecutor threadPoolExecutor = getThreadPoolExecutor();
        for (int i = 0; i