枚举线程源码

1. 请高手帮忙解释下这多线程的源代码，每句注释下 #include <stdio.h> #include <stdlib.h>

首先这是一个生产者和消费者问题。

生产者procer负责产生数据，然后通过put操作将数据放到缓冲区buf中。

消费者consumer负责显示数据，通过get操作从缓冲区buf中读取数据。

========》

先看主函数main（），

生产者和消费者分别用两个线程来实现。

主函数中的pthread_create()函数就是用来创建这两个线程的。

开始定义了两个变量th_a,th_b用来记录这两个线程的线程号。

线程的程序体分别是procer，consumer。

接下来的pthread_join用来等待两个线程结束。因为如果不等待，main函数的主线程会立即结束，而两个子线程还来不及完全执行。

=======》

下面来分别看procer，consumer这两个线程。

procer循环一百次，每次调用put往buffer中放数据，最后放一个OVER；

consumer循环用get从buffer中读到数据并打印，直到读取的数据位OVER数据时结束。

=======》

我们再分别来看put操作和get操作。

由于put和get都要访问buf，buf就是一个临界资源，为了解决这个临界资源，在使用buf之前，要对它加锁。

pthread_mutex_lock(b->lock)一个为信号量加锁的函数。每个信号量只能加锁一次（我说的可能不准确），如果执行该函数的时候,参数中的信号量已经被加锁，则该函数阻塞，直到信号量被解锁才继续执行。这样就能保证信号量所保护的临界资源能够被互斥的访问。

structprodcons{

intbuffer[BUFFER_SIZE];/*这个就是循环缓冲区*/

pthread_mutex_tlock;/*这个是信号量，用来保证对缓冲区的互斥访问*/

intreadpos,writepos;/*这两个成员分别表示读位置和写位置*/

pthread_cond_tnotempty;/*这是表示缓冲区“非空”的条件信号量*/

pthread_cond_tnotfull;/*这是表示缓冲区“非满”的条件信号量*/

};

buf是一个循环的缓冲区，我们先来看缓冲区为空和满这两种状态时，读、写标记（readpos，writepos）的位置。

缓冲区为空时，readpos和writepos指在同一位置；

换从去为满时，writepos位置的下一个位置就是readpos。

/*put负责把数据放到缓冲区*/

voidput(structprodcons*b,intdata)

{

//首先对互斥信号量进行加锁

pthread_mutex_lock(&b->lock);

/*这里就是判断缓冲区有没有满，用writepos+1与readpos比较，可以参考附图。

*因为是循环缓冲区，所以要模BUFFER_SIZE。

*如果缓冲区满，将在while中等待，直到缓冲区非满，再继续执行。

*/

while((b->writepos+1)%BUFFER_SIZE==b->readpos){

printf("waitfornotfull ");

//如果已经满了，则等待消费者读取了数据后发出“非满”信号。

pthread_cond_wait(&b->notfull,&b->lock);

}

/*当缓冲区非满时，将数据写入缓冲区中writepos对应的位置*/

b->buffer[b->writepos]=data;

//更新writepos到下一个位置

b->writepos++;

//循环利用缓冲区空间，如果超过了最大值，则从头开始。

if(b->writepos>=BUFFER_SIZE)b->writepos=0;

/*向消费者发送信号，告诉消费者缓冲取非空*/

pthread_cond_signal(&b->notempty);

//对互斥信号进行解锁。

pthread_mutex_unlock(&b->lock);

}

/*--------------------------------------------------------*/

/*get负责从缓冲区中读取数据*/

intget(structprodcons*b)

{

intdata;

//对互斥信号量进行加锁

pthread_mutex_lock(&b->lock);

/*判断缓冲区是否为空，为空则等待*/

while(b->writepos==b->readpos){

printf("waitfornotempty ");

pthread_cond_wait(&b->notempty,&b->lock);

}

/*读取readpos位置的数据*/

data=b->buffer[b->readpos];

//更新readpos到下一个位置。

b->readpos++;

//循环利用缓冲区，回拨指针

if(b->readpos>=BUFFER_SIZE)b->readpos=0;

/*发信号给生产者，缓冲区非满，可以放数据了*/

pthread_cond_signal(&b->notfull);

//对互斥信号量进行解锁

pthread_mutex_unlock(&b->lock);

returndata;

}

2. 枚举的属性和方法

  枚举在java中是一个类 ，代表着类的一一列举。要想知道枚举具体的使用首先要先知道它的具体的 属性 和 方法 才可以。虽然说我们在实际应用中很少去关注它的属性和方法，而是更多的关注它的 特性 ，利用它本身的特性去满足各种有意思的场景。

 由于上篇内容讲了我们自定义的枚举其实经过编译之后，实际继承的是lang包下的Enum类。虽然我们自定义的枚举类中可能存在不定义私有属性的情况，但继承的Enum类中自身就带有着两个属性，name属性、和ordinal属性。Enum类的源码

 name为我们枚举值的名称，而ordinal这个词的意思是“序数”或者说“有顺序的”，其实就是序数。我们知道枚举所代表的就是包含一个以上枚举值的集合，既然是集合它就是有顺序的，而大多数我们使用的时候往往忽略了它的序数这个属性，似乎忘了枚举是枚举这件事了。
 枚举中的序号是根据我们的枚举中显示的顺序决定的，其实是是语法糖转换时初始化枚举值时决定了枚举值的序数，枚举中，第一个枚举值的序数总是小于后面枚举值的序数，且序数是从0开始的。

 接着上面讲的序数ordinal，针对序数我们先讲枚举的values()方法。

作为一个枚举值的集合，所必须要有的操作肯定是遍历，这也是静态常量所没有的支持的。values()其实就是获取我们枚举值的数组：

 虽然我们自定义的枚举类是可以使用这个方法的，但继承的Enum类却没有这个方法，其实values()这个方法是很特殊的一个方法，之前说过枚举是一种语法糖，在它真正编译后，就会产生values()这个方法，所以我们自定义的枚举类是可以使用这个方法的，而且values()方法所返回的其实是一个浅拷贝；

 前面说到枚举有两个属性，name和ordinal，但实际上枚举只提供了根据name来获取具体枚举值的方法，却没有提供根据ordinal来获取具体枚举值的方法，但是values()方法也算是另外一种弥补了，根据values()得到的数据再根据ordinal序数获取具体的枚举值其实也是一样的效果。valueOf()方法就是那个根据name获取具体枚举值的方法，使用案例：

可选姿势为两种，一参和两参，具体看案例。

3. 典型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 minPools;private int maxPools;private int checkThreadPeriod;public 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 SAXBuilder;import java io *;import java util *;public class ParseConfig {static Hashtable Listens = null;static ConnPara connpara = null;static ConsumeThreadPoolPara consumeThreadPoolPara = null;private 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<minPools;i++){WorkerThread temp=new WorkerThread();totalThread = totalThread + ;m_ThreadList add(temp);temp start();try{Thread sleep( );}catch(Exception e){}}timer = new Timer(true);//启动定时器timer schele(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 = true;String work;public void run(){while(running){synchronized(o){freeThreadCount++;}synchronized(m_RunList){while(m_RunList size() == ){try{m_RunList wait();if(!running) return;}catch(InterruptedException e){}< lishixin/Article/program/Java/gj/201311/27379