Java版线程池实现

矫情吗；* 2024-03-16 20:32 6阅读 0赞

Java版线程池实现  
线程池调度技术原理：  
  
package test.threadpool;  
import java.util.\*;  
import test.cfg.\*;  
public class ThreadPool \{  
private int reserve = 0; //保留线程  
 private int minPools = 10; //最小连接池数目，预启动线程数目  
 private int maxActive = 70; //最多活动线程数目  
 private int maxPools = 100; //最大连接池数目  
 private int checkThreadPeriod = 5; //检查连接池的周期  
 ArrayList m\_ThreadList; //工作线程列表  
 ArrayList m\_ReserveList; //保留线程链表  
 LinkedList m\_RunList = null; //工作任务列表  
 int freeThreadCount = 0;//未被使用的线程数目  
 private java.util.Timer timer = null;//定时器  
 static Object o = new Object();  
public void setMinPools(int minPools) \{  
this.minPools = minPools;  
\}  
public void setMaxPools(int maxPools) \{  
this.maxPools = maxPools;  
\}  
public void setCheckThreadPeriod(int checkThreadPeriod) \{  
this.checkThreadPeriod = checkThreadPeriod;  
\}  
/\*\*  
\* 初始化线程池，由于各个线程启动的时候是有一定的时间间隔，启动的时候会有一定的时间  
 \*  
\*/  
public ThreadPool() \{  
// reserve = Integer.parseInt(FtpConfig.getValue("reserve"); //从配置文件中获取参数  
 // minPools = Integer.parseInt(FtpConfig.getValue("minPools"); //从配置文件中获取参数  
 //maxActive = Integer.parseInt(FtpConfig.getValue("maxActive"); //从配置文件中获取参数  
 //maxPools = Integer.parseInt(FtpConfig.getValue("maxPools"); //从配置文件中获取参数  
  
 //checkThreadPeriod = Integer.parseInt(FtpConfig  
// .getValue("monitorPeriod") \* 60 \* 1000; //以分为轮询单位  
 m\_ThreadList = new ArrayList(); //初始化工作线程链表  
 m\_ReserveList = new ArrayList();  
m\_RunList = new LinkedList(); //初始化任务列表  
 ArrayList list = null;  
if (reserve > 0)  
list = (ArrayList) FtpConfig.getProValueList("reserveList";  
  
for (int i = 0; i < reserve; i++) \{ //启动保留线程，根据配置链表中的线程列表启动对应的保留线程.保存的是线程的全路径  
 //class name  
try \{  
Thread thr = (Thread) Class.forName((String) list.get(i))  
.newInstance();  
  
m\_ReserveList.add(i, thr);  
thr.start();  
  
Thread.sleep(10);  
  
\} catch (Exception e) \{  
e.printStackTrace();  
\}  
  
\}  
  
for (int i = 0; i < minPools; i++) \{ //初始化空闲线程  
 WorkerThread temp = new WorkerThread();  
  
m\_ThreadList.add(temp); //将线程添加到线程链表中  
 temp.start(); //启动工作线程  
 try \{  
Thread.sleep(10); //每个100us启动一个线程  
 \} catch (Exception e) \{  
\}  
\}  
  
printDebugInfo();  
timer = new Timer(true);//启动定时器  
 timer.schedule(new CheckThreadTask(this), 0, checkThreadPeriod); //设置定时器调度线程池  
 \}  
  
  
/\*\*  
\* 应用程序调用入口，可以是一个封装好的job类，具体视应用而定  
 \* @param work  
\*/  
  
public synchronized void run(Object work) \{  
  
  
synchronized (m\_RunList) \{ //添加任务到任务链表中  
 m\_RunList.add(work);  
m\_RunList.notify();  
\}  
  
  
  
  
\}  
  
/\*\*  
\* monitor 所要采取的动作（轮询）  
 \*  
\*/  
public synchronized void checkAllThreads() \{  
  
  
//printDebugInfo();  
  
  
  
//如果空闲线程数少于预启动线程数目，并且没有达到最大的活动线程数时则增加空闲线程  
 if(freeThreadCount<minPools && m\_ThreadList.size()<maxPools)\{  
  
int count=(minPools-freeThreadCount)>(maxActive-m\_ThreadList.size())?(maxActive-m\_ThreadList.size())minPools-freeThreadCount);  
  
for(int i=0;i<count;i++)\{  
  
  
Thread thr=null;