典型Java线程池的代码及其各部分功能介绍

（ ）根据xml文件来管理线程池的最大最小线程数（ ）对线程池通过Timer定期扫描以防止线程未激活 （ ）通过某一个变量（本程序中是freeThreadCount）来得到空闲线程的数目 一 配置xml（listen xml）是 <?xml version= encoding= UTF ?><config><ConsumeThreadPool><minPools></minPools>　<! 线程池李渗最小线程 ><maxPools></maxPools><! 线程池最大线程 ><checkThreadPeriod></checkThreadPeriod>　<! 检查线程池中线程的周期 分钟 ></ConsumeThreadPool></config>　哪贺脊　 二 对于ConsumeThreadPoolPara的javabean: import java io *public class ConsumeThreadPoolPara implements Serializable{private int minPoolsprivate int maxPoolsprivate int checkThreadPeriodpublic int getMinPools(){return minPools}public int getMaxPools(){return maxPools}public int getCheckThreadPeriod(){return checkThreadPeriod}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 String toString(){return minPools+ + maxPools+ +checkThreadPeriod}public ConsumeThreadPoolPara() {}public static void main(String[] args) {ConsumeThreadPoolPara consumeThreadPool = new ConsumeThreadPoolPara()}} 三 解析xml程序拍辩代码（生成ConsumeThreadPoolPara） 使用jdom解析 import jdom *import jdom input SAXBuilderimport java io *import java util *public class ParseConfig {static Hashtable Listens = nullstatic ConnPara connpara = nullstatic ConsumeThreadPoolPara consumeThreadPoolPara = nullprivate static String configxml = listen xml static{getConsumeThreadPoolPara()　//得到消费的线程池的参数}/*** 装载文档* @return 返回根结点* @throws JDOMException*/public static Element loadDocument() throws JDOMException{SAXBuilder parser = new SAXBuilder()// 新建立构造器try {Document document = parser build(configxml)Element root = document getRootElement()return root}catch(JDOMException e){logger error( listen xml文件格式非法！ )throw new JDOMException()}}public static ConsumeThreadPoolPara getConsumeThreadPoolPara(){if(consumeThreadPoolPara ==null){try {Element root = loadDocument()Element consumeThreadPool = root getChild( ConsumeThreadPool )if (consumeThreadPool != null) { //代表有数据库配置consumeThreadPoolPara = new ConsumeThreadPoolPara()Element minPools = consumeThreadPool getChild( minPools )consumeThreadPoolPara setMinPools(Integer parseInt(minPools getTextTrim()))Element maxPools = consumeThreadPool getChild( maxPools )consumeThreadPoolPara setMaxPools(Integer parseInt(maxPools getTextTrim()))Element checkThreadPeriod = consumeThreadPool getChild( checkThreadPeriod )consumeThreadPoolPara setCheckThreadPeriod(Integer parseInt(checkThreadPeriod getTextTrim()))}}catch (JDOMException e) {}}return consumeThreadPoolPara}} 四 线程池源代码 import java util */*** <p>Title: 线程池</p>* <p>Description: 采集消费模块</p>* <p>Copyright: Copyright (c) </p>* <p>Company: </p>* @author 张荣斌* @version */public class ThreadPool {private static int minPools = //最小连接池数目private static int maxPools = //最大连接池数目private static int checkThreadPeriod = //检查连接池的周期ArrayList m_ThreadList　//工作线程列表LinkedList m_RunList = null　//工作任务列表int totalThread = 　//总线程数static int freeThreadCount = 　//未被使用的线程数目private java util Timer timer = null　//定时器static Object o = new Object()static{　//先初始化线程池的参数ConsumeThreadPoolPara consumeThreadPoolPara = ParseConfig getConsumeThreadPoolPara()if(consumeThreadPoolPara!=null){minPools = consumeThreadPoolPara getMinPools()maxPools = consumeThreadPoolPara getMaxPools()checkThreadPeriod = consumeThreadPoolPara getCheckThreadPeriod()* * }}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() {m_ThreadList=new ArrayList()m_RunList=new LinkedList()for(int i= i<minPoolsi++){WorkerThread temp=new WorkerThread()totalThread = totalThread + m_ThreadList add(temp)temp start()try{Thread sleep( )}catch(Exception e){}}timer = new Timer(true)　//启动定时器timer schedule(new CheckThreadTask(this) checkThreadPeriod)}/*** 当有一个工作来的时候启动线程池的线程* 当空闲线程数为 的时候 看总线程是否小于最大线程池的数目 就new一个新的线程 否则sleep 直到有空闲线程为止* 当空闲线程不为 则将任务丢给空闲线程去完成* @param work*/public synchronized void run(String work){if (freeThreadCount == ) {if(totalThread<maxPools){WorkerThread temp = new WorkerThread()totalThread = totalThread + m_ThreadList add(temp)temp start()synchronized(m_RunList){m_RunList add(work)m_RunList notify()}}else{while (freeThreadCount == ) {try {Thread sleep( )}catch (InterruptedException e) {}}synchronized(m_RunList){m_RunList add(work)m_RunList notify()}}} else {synchronized(m_RunList){m_RunList add(work)m_RunList notify()}}}/*** 检查所有的线程的有效性*/public synchronized void checkAllThreads() {Iterator lThreadIterator = erator()while (lThreadIterator hasNext()) { //逐个遍厉WorkerThread lTestThread = (WorkerThread) lThreadIterator next()if (! (lTestThread isAlive())) { //如果处在非活动状态时lTestThread = new WorkerThread()//重新生成个线程lTestThread start()//启动}}}/*** 打印调试信息*/public void printDebugInfo(){System out println( totalThread= +totalThread)System out println( m_ThreadList size()= +m_ThreadList size())}/**** <p>Title: 工作线程类</p>* @author 张荣斌* @version */class WorkerThread extends Thread{boolean running = trueString workpublic void run(){while(running){synchronized(o){freeThreadCount++}synchronized(m_RunList){while(m_RunList size() == ){try{m_RunList wait()if(!running) return}catch(InterruptedException e){}<lishixinzhi/Article/program/Java/gj/201311/27379

1.Java是简单的

Java与C++极为相似，但却简单得多。高级编程语言的所有特性中，不是绝对需要的都已删去了。例如，Java没有算符过载、标题文件、预处理、指针运算、结构、联合、多维数组、模板及隐式类型变换。如果你知道一点C、C++或Pascal，你很快就会驾驭Java.这里是一个简单的 JavaHelloWorld程序：

publicclassHelloInternet{publicstaticvoidmain（Stringargv[]）{System.out.println（“HelloIn-ternet！”）}}

2.Java是面向对象的

Java是一种面向对象的编程语言。除了简单的类型，如雹缓数字和布尔算子之外，Java中的大部分都是对象。

正如任何面向对象的语言一样，Java代码也按类组织。每个类定义一组规定对象行为的方法。一个类可以继承另一个类的行为。在类的根层次上，通常是类对象。

Java支持单继承类层次结构。这就是说，每个类一次只能继承一个别的类。有些语言允许扰升多继承性，但这可能造成混乱，使语言不必要地复杂化。例如，难以想像，一个对象会继承两个完全不同的类的行为。

Java还支持摘要类的接口。这允许编程人员先定义接口的方法，而不必急于马上确定方法的实现。一个类可以施行多个接口，从而具有真正多继承性的许多优点。一个对象也可实施任意数量的接口。Java接口与IDL接口极其相似。很容易建立IDLJ编译器。这就是说，Java可用于CORBA对象系统来建立分布式对象系统。鉴于在许多计算机系统中都采用IDL接口和CORBA对象系统，这种兼容性是重要的。

3.Java是静态类型的

在一个Java程序中，必须定义所用对象（数字、字符、数组等）的类型。这有助于编程人员很快发现问题，因为当程序编译时可以检测类型错误。

不过，Java系统中的对象也有动态类型。要求一个对象为动态类型往往是可能的，所以编程人员写的程序可以对不同类型的对象做不同的事。

4.Java是编译型的

当运行Java程序时，它首先被编译成字节代码。字节代码非常类似于机器指令，所以Java程序非常高效。然而，字节代码并不专对一种特定的机器，所以Java程序无需重新编译便可在众多不同的计算机上执行。

Java源程序被编译成类文件，它相当于程序的字节代码表现。在一个Java类文件中，所有对方法及实例变量的参照均按名进行，并在第一次执行代码时加以分辨。这使得代码更通用，更不易受修改的影响，而仍具高效。

5.Java是体系结构中立的

Java语言对每种计算机都一样。比如，简单的类型都是不变的：整数总是32位，长整数总是64位。令人奇怪的是，诸如C及C++等时髦的编程语言却不是这样。由于这些语言定义如此自由，每种编译器及开发环境便各有不同了，这使程序的移植成为讨厌的问题。Java程序的移植却很容易，而且不源李模需要进行重新编译。

6.Java是健全的

Java程序不可能造成计算机崩溃。Java系统仔细检测对内存的每次访问，确认它是合法的，而且不致引起任何问题。

不过，即使Java程序也可能有错误。如果出现某种出乎意料之事，程序不会崩溃，而把该例外抛弃。程序会发现这类例外，并加以处理。

传统的程序可以访问计算机的全部内存。程序可能（无意识地）修改内存中的任何值，这就会造成问题。Java程序只能访问内存中允许它们访问的那些部分，所以Java程序不可能修改不拟修改的值。

7.Java是小巧的

由于Java的设计是要在小的计算机上运行，作为一种编程语言来说其系统是相对较小的。它能有效地在4MB以上RAM的PC机上运行。Java翻译器只占用几百KB.这种翻译器对Java的平台无关性和可移植性是可靠的。

由于Java很小，它对内存很小的计算机，如基于Java的PC机，以及电视机、烤箱、电话机及家用计算机等，是很理想的。

8.Java是多线程的

Java程序可以执行一个以上的线程。比如，它可以在一个线程中完成某一耗时的计算，而其它线程与用户进行交互对话。所以用户不必停止工作，等待Java程序完成耗时的计算。

在多线程环境中的编程通常是困难的，因为许多东西可能同时出现。但是，Java提供了易于使用的同步特性，使编程更为方便。

Java线程通常被映射为实际的 *** 作系统线程，只要底层 *** 作系统支持这种映射。因此，用Java写的应用程序可说是“MP热”。这就是说，如果它们在多处理器机器上运行，它们更将表现不凡。

9.Java是可收集无用的存储单元的

用C及C++写软件的编程人员必须仔细跟踪所用的内存块。当一个块不再使用时，他们务必让程序释放它，从而方可再用。在大的项目中，这可能很困难，并往往成为出错和内存不足的根源。

在Java的情况下，编程人员不必为内存管理 *** 心。Java系统有一个叫做“无用单元收集器”的内置程序，它扫描内存，并自动释放那些不再使用的内存块。

10.Java是快速的

Java比典型的脚本语言大为有效，但它比C慢20倍。这对大多数应用是可接受的。

不久的将来，代码生成器就可供利用了，这将使Java程序几近于用C或C++编写的程序那么快。

11.Java是安全的

Java程序没有指针，而且象这样的字节代码程序强在类型上，所以在执行之前它可能验证Java程序。被验证的Java程序得以保证不突破Java语言的任何限制，而且可以安全地执行。Java字节代码验证被Web浏览器用来确保小程序不含病毒。

12.Java是可扩展的

Java程序可与用其它语言编写的现存程序库连接。由于Java数据结构与C的数据结构的类型极为相似，这是相当方便的。的问题在于，现有多线程程序库为数不多。

Java程序可以声明某些方法是内部的，然后，把这些内部方法映射成软件库所定义的功能，从而动态地链接到虚拟机。

package com.zpppublic class Charge {

public static void main(String [] args) {

if(args.length ==0) {

System.out.println("parameter error!")

System.out.println("java com.zpp.Charge [int]"庆陵)

return

}

int min = Integer.parseInt(args[0])

double money = 0.0

if (min <= 0) {

money =0.0

System.out.println("not money")

} else if (min <= 60) {

money = 2.0

} else {

money = 2.0 + (min - 60) * 0.01

}

System.out.println("please pay: "猛差茄 + money)

}

} 编枝察译：javac -d . Charge.java运行：java com.zpp.Charge 111

---