| | |
| | | |
| | | private static ThreadPool.Pool pool_short ;//短工作任务线程池,线程工作用时较短 |
| | | private static ThreadPool.Pool pool_long ;//长工作任务线程池,线程工作用时较长 |
| | | |
| | | |
| | | |
| | | public final static Integer[] pool_short_state(){ |
| | | Integer shortCurThread = 0 ;//短线程池当前线程数 |
| | | Integer shortMaxThread = 0 ;//短线程池最大线程数 |
| | | Integer shortMinThread = 0 ;//短线程池最小线程数 |
| | | shortCurThread = pool_short.size() ; |
| | | shortMaxThread = pool_short.maxThread() ; |
| | | shortMinThread = pool_short.minThread() ; |
| | | return new Integer[]{shortCurThread, shortMaxThread, shortMinThread} ; |
| | | } |
| | | |
| | | public final static Integer[] pool_long_state(){ |
| | | Integer longCurThread = 0 ;//短线程池当前线程数 |
| | | Integer longMaxThread = 0 ;//短线程池最大线程数 |
| | | Integer longMinThread = 0 ;//短线程池最小线程数 |
| | | longCurThread = pool_long.size() ; |
| | | longMaxThread = pool_long.maxThread() ; |
| | | longMinThread = pool_long.minThread() ; |
| | | return new Integer[]{longCurThread, longMaxThread, longMinThread} ; |
| | | } |
| | | /** |
| | | * 初始化线程池 |
| | | * @param poolName 线程池和线程名称 |
| | |
| | | } |
| | | /** |
| | | * 得到唯一线程池实例 |
| | | * @return |
| | | * @throws Exception |
| | | */ |
| | | public final static ThreadPool.Pool getThreadPoolShort() |
| | |
| | | } |
| | | /** |
| | | * 得到唯一线程池实例 |
| | | * @return |
| | | * @throws Exception |
| | | */ |
| | | public final static ThreadPool.Pool getThreadPoolLong() |
| | | throws Exception { |