线程池管理（线程统⼀调度管理）
public final class ThreadPoolManager {
private static ThreadPoolManager sThreadPoolManager = new ThreadPoolManager();
// 线程池维护线程的最少数量
private static final int SIZE_CORE_POOL = 100;
// 线程池维护线程的最⼤数量
private static final int SIZE_MAX_POOL = 100;
/*
* 线程池单例创建⽅法
*/
public static ThreadPoolManager newInstance() {
属牛的是什么星座
return sThreadPoolManager;
}
/**************************************************************************************************************
* 常见的⼏种线程技术
**************************************************************************************************************
* Java通过Executors提供四种线程池，分别为：
* newCachedThreadPool创建⼀个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若⽆可回收，则新建线程。 * newFixedThreadPool 创建⼀个定长线程池，可控制线程最⼤并发数，超出的线程会在队列中等待。
* newScheduledThreadPool 创建⼀个定长线程池，⽀持定时及周期性任务执⾏。 newSingleThreadExecutor
* 创建⼀个单线程化的线程池，它只会⽤唯⼀的⼯作线程来执⾏任务，保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执⾏。
*
* 1、public static ExecutorService newFixedThreadPool(int nThreads) {
* return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); } *
* 2、 public static ExecutorService newSingleThreadExecutor() {
* return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>())); }
*
* 3、public static ExecutorService newCachedThreadPool() {
* return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); }
****************************************************************************************************************/
/
**
* 线程池
* @param corePoolSize - 池中所保存的线程数，包括空闲线程。
* @param maximumPoolSize - 池中允许的最⼤线程数。
* @param keepAliveTime - 当线程数⼤于核⼼时，此为终⽌前多余的空闲线程等待新任务的最长时间。
* @param unit - keepAliveTime 参数的时间单位。
* @param workQueue - 执⾏前⽤于保持任务的队列。此队列仅由保持 execute ⽅法提交的 Runnable 任务。
* @param handler - 由于超出线程范围和队列容量⽽使执⾏被阻塞时所使⽤的处理程序。
*/
// 实质就是newFixedThreadPool 创建⼀个定长线程池，可控制线程最⼤并发数，超出的线程会在队
列中等待
private final ThreadPoolExecutor mThreadPool = new ThreadPoolExecutor(SIZE_CORE_POOL, SIZE_MAX_POOL, 0L,
TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
/*
* 将构造⽅法访问修饰符设为私有，禁⽌任意实例化。
教师英语怎么写
*/
private ThreadPoolManager() {
}
/*
* 将线程池初始化，核⼼线程数量
*/
public void perpare() {
if (mThreadPool.isShutdown() && !mThreadPool.prestartCoreThread()) {
@SuppressWarnings("unud")
int startThread = mThreadPool.prestartAllCoreThreads();
int startThread = mThreadPool.prestartAllCoreThreads(); }
}
/*
* 向线程池中添加任务⽅法
*/
public void addExecuteTask(Runnable task) {
if (task != null) {说说心情句子
}
}
/*
* 判断是否是最后⼀个任务
*/
protected boolean isTaskEnd() {
if (ActiveCount() == 0) {
return true;
} el {
return fal;
}
}
/*
* 获取缓存⼤⼩
*/
public int getQueue(){
Queue().size();
梦见自己穿高跟鞋}
/*
* 获取线程池中的线程数⽬
*/
万泉达
public int getPoolSize(){
PoolSize();
}
/*
* 获取已完成的任务数
*/
public long getCompletedTaskCount(){
CompletedTaskCount();
}
/*
* 关闭线程池，不在接受新的任务，会把已接受的任务执⾏玩 */双赢
public void shutdown() {
站怎么组词mThreadPool.shutdown();
}
}
>胸疼怎么回事
