threadpool.java

线程池的开发,创建一个池来提高资源利用率

import java.util.LinkedList;
public class ThreadPool extends ThreadGroup
{
	private boolean isClosed=false;   //线程池是否关闭
	private LinkedList<Runnable> workQueue; //表示工作队列
	private static int threadPoolID;   //表示工作线程ID
	private int threadID;   //表示工作线程ID
	public ThreadPool(int poolSize)
	{
		super("ThreadPool-"+(threadPoolID++));
		setDaemon(true);
		workQueue=new LinkedList<Runnable>();//创建工作队列
		for(int i=0;i<poolSize;i++)
		new WorkThread().start();             //创建并启动工作线程
	}
		
		/**向工作队列中加入一个新的任务，由工作线程去执行该任务*/
		public synchronized void execute(Runnable task)
		{
			if(isClosed)  //线程池被关闭则抛出IllegalStateException异常
			{
				throw new IllegalStateException();
			}
			if(task!=null)
			{
				System.out.println("execute");
				workQueue.add(task);
				notifyAll();    //唤醒正在getTask()方法中等待任务的工作线程
				System.out.println("accept1");
			}
		}
		
		
		/** 从工作队列中取出一个任务，工作线程会调用此方法*/
		protected synchronized Runnable getTask()throws InterruptedException
		{	
		    System.out.println("noTask");
			while(workQueue.size()==0)
			{
				if(isClosed) return null;
				System.out.println("noTask");
				wait();
			
			}
			System.out.println("getTask");
			return workQueue.removeFirst();
		}
		
		/**关闭线程池*/
		public synchronized void close()
		{
			if(!isClosed)
			{
				isClosed=true;
				workQueue.clear();  //清空工作队列
				interrupt();  //中断所有的工作线程，该方法继承自ThreadGroup类
			}
		}
				
				
		/**等待工作线程把所有任务执行完*/
		public void join()
		{
			synchronized(this)
			{
				isClosed=true;
				notifyAll()	;  //唤醒正在getTask()方法中等待任务的工作线程
			}
			
			
			Thread[] threads=new Thread[activeCount()];
			int count=enumerate(threads);
			for(int i=0;i<count;i++)  //等待所有工作进程运行结束
			{
				try{
					threads[i].join();
				}catch(InterruptedException ex){}
			}
		}
		
		private class WorkThread extends Thread
		{
			
			//加入到当前的ThreadPool线程组中
			public WorkThread()
			{
				super(ThreadPool.this,"WorkThread-"+(threadID++));
			}
			
			
			
			public void run()
			{
				while(isInterrupted())
				{
					Runnable task=null;
					try{
						
						task=getTask();
						System.out.println("task run");
					}catch(InterruptedException ex){}
					
					if(task==null) return;
					
					try{//运行任务，异常在catch代码块中捕获
						task.run();
						System.out.println("task run1");
					}catch(Throwable t){
						t.printStackTrace();
						}
					}  //#while()
				}//#run()
			}//WorkThread类
		
	}