线程池管理类

2019-11-09 18:18:41

字体：大中小

来源：转载

供稿：网友

/** * 线程管理器 * */public class ThreadManager { PRivate static ThreadPool mThreadPool; public static ThreadPool getThreadPool() { if (mThreadPool == null) { synchronized (ThreadManager.class) { if (mThreadPool == null) { int cpuCount = Runtime.getRuntime().availableProcessors();// 获取cpu数量 System.out.println("cup个数:" + cpuCount); int threadCount = cpuCount * 2 + 1;//线程个数 mThreadPool = new ThreadPool(threadCount, threadCount, 1L); } } } return mThreadPool; } // 线程池 public static class ThreadPool { private int corePoolSize;// 核心线程数 private int maximumPoolSize;// 最大线程数 private long keepAliveTime;// 休息时间 private ThreadPoolExecutor executor; private ThreadPool(int corePoolSize, int maximumPoolSize, long keepAliveTime) { this.corePoolSize = corePoolSize; this.maximumPoolSize = maximumPoolSize; this.keepAliveTime = keepAliveTime; } // 线程池几个参数的理解: // 比如去火车站买票, 有10个售票窗口, 但只有5个窗口对外开放. 那么对外开放的5个窗口称为核心线程数, // 而最大线程数是10个窗口. // 如果5个窗口都被占用, 那么后来的人就必须在后面排队, 但后来售票厅人越来越多, 已经人满为患, 就类似于线程队列已满. // 这时候火车站站长下令, 把剩下的5个窗口也打开, 也就是目前已经有10个窗口同时运行. 后来又来了一批人, // 10个窗口也处理不过来了, 而且售票厅人已经满了, 这时候站长就下令封锁入口,不允许其他人再进来, 这就是线程异常处理策略. // 而线程存活时间指的是, 允许售票员休息的最长时间, 以此限制售票员偷懒的行为. public void execute(Runnable r) { if (executor == null) { executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), Executors.defaultThreadFactory(), new AbortPolicy()); // 参1:核心线程数;参2:最大线程数;参3:线程休眠时间;参4:时间单位;参5:线程队列;参6:生产线程的工厂;参7:线程异常处理策略 } // 线程池执行一个Runnable对象, 具体运行时机线程池说了算 executor.execute(r); } // 取消任务 public void cancel(Runnable r) { if (executor != null) { // 从线程队列中移除对象 executor.getQueue().remove(r); } } }}

调用：ThreadManager.getThreadPool.execute(new runnable(){ //自己要执行的代码 })；

上一篇：saas系统架构经验总结

下一篇：cocos2dx重力反应延时解决方案