package com.nanjing.water.common.util;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * 线程池管理类
 */
public final class ThreadPoolUtil {
    /**
     * 多线程允许最大并发线程数的默认大小
     */
    private static final Integer THREAD_DEFAULT_MAXQUANTITY = 50;

    /**
     * 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。
     */
    private static ExecutorService THREADPOOL_DEFAULT = Executors.newFixedThreadPool(THREAD_DEFAULT_MAXQUANTITY);

    /**
     * 获取默认线程池
     * @return
     */
    public static ExecutorService getDefaultPool() {
        return THREADPOOL_DEFAULT;
    }
}