Java 线程池的实现

package thread;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.*;


public class threadpool {
        
    static class ThreadPoolManager{
            private int MaxThread;
            private Vector ThreadQueue;
            
            public void setMaxThread(int count){
                this.MaxThread=count;
            }
            
            public ThreadPoolManager(int count){
                setMaxThread(count);
                System.out.println("Starting Thread Pool");
                ThreadQueue=new Vector();
                for(int i=0;i<=MaxThread;i++){
                    SimpleThread thread=new SimpleThread(i);
                    ThreadQueue.addElement(thread);
                    thread.start();
                }
            }
            
            public void process(String argument){
                int i;
                for(i=0;i<ThreadQueue.size();i++){
                    SimpleThread current=(SimpleThread) ThreadQueue.elementAt(i);
                    if(!current.isRunning()){
                        System.out.println("Thread"+(i+1)+"is processing:"+argument);
                        current.setArgument(argument);
                        current.setRunning(true);
                        return;
                    }
                }
                
                if(i==ThreadQueue.size()){
                    System.out.println("pool is full,try in anthor time");
                }
            }
            
    }
    
    
    static class SimpleThread extends Thread{
        private boolean RunningFlag;
        private String argument;
        public boolean isRunning(){
            return RunningFlag;
        }
        
        public synchronized void setRunning(Boolean Flag){
            RunningFlag=Flag;
            if(Flag){
                this.notify();
            }
        }
        
        public String getArgument(){
            return this.argument;
        }
        
        public void setArgument(String string){
            argument=string;
        }
        
        public SimpleThread(int threadNumber){
            RunningFlag=false;
            System.out.println("thread"+threadNumber+"started.");
        }
        
        public synchronized void run(){
            try {
                while(true){
                    if(!RunningFlag){
                        this.wait();
                    }
                    else{
                        System.out.println("process"+getArgument()+"……done!");
                        sleep(5000);
                        System.out.println("Thread is sleeping.");
                        setRunning(false);
                        
                    }
                }
            } catch (Exception e) {
                // TODO: handle exception
                System.out.println("Interrupt");
            }
        }
    }
    
    public static void main(String[] args) {
        try {
            BufferedReader brBufferedReader=new BufferedReader(new InputStreamReader(System.in));
            String string;
            ThreadPoolManager manager=new ThreadPoolManager(10);
            while((string=brBufferedReader.readLine())!=null){
                manager.process(string);
            }
        } catch (Exception e) {
            // TODO: handle exception
        }
    }
    
    
}