Go语言视频零基础入门到精通

webs

package aa;



import java.util.Random;



public class DownThread extends Thread {



    private boolean runFlag;



    public boolean isRunFlag() {

       return runFlag;

    }

    public DownThread(){

       System.out.println(this.getName()+" 初始化");

       this.setRunFlag(false);

    }



    public synchronized void setRunFlag(boolean runFlag) {

       this.runFlag=runFlag;

       if(runFlag)this.notify();

    }



    public synchronized void run(){

       while (true){

           if(!this.isRunFlag()){

              try{

                  this.wait();

              }catch(InterruptedException e){

                  e.printStackTrace();

              }

           }

           System.out.println(this.getName()+"doing something!");

           Random ran=new Random();

           try{

              long l=10001*(ran.nextInt(10)+1);

               System.out.println("这活要干 "+l+"毫秒");

              sleep(l);

           }catch(InterruptedException e){

              e.printStackTrace();

           }

           System.out.println(this.getName()+"done!");

           this.setRunFlag(false);

           System.out.println(this.getName()+"回收");

           ThreadPool.removeThread(this);

       }

    }

}


============================================================================



package aa;



import java.util.LinkedList;



public class ThreadPool {



    final static int MaxLength=20;

   

    private static LinkedList pool=null;

   

    public ThreadPool(){

       System.out.println("初始化线程池="+MaxLength);

       pool=new LinkedList();

       for(int i=0;i<MaxLength;i++){

             DownThread thread=new DownThread();   

             removeThread(thread);

             thread.start();

       }

    }



    public boolean isFull(){

       return pool.isEmpty();

    }

   

    public void addThread(){

       synchronized (pool) {

           while(this.isFull()){

              System.out.println("线程池满，等待中。。。。。");

              try{

                  pool.wait();

              }catch(InterruptedException e){

                  e.printStackTrace();

              }

           }

           DownThread thread=(DownThread)pool.removeFirst();

           if(!thread.isRunFlag()){

              System.out.println(thread.getName()+"is processing");

              thread.setRunFlag(true);

           }

       }

    }

   

    public static void removeThread(DownThread downThread) {

        synchronized (pool) {

           pool.addLast(downThread);

           pool.notify();

       }

    }

   

    public static void main(String[] args){

       ThreadPool test=new ThreadPool();

       for(int i=0;i<1000;i++){

           test.addThread();

       }

    }

}

package aa;



public class TestThread  extends Thread{



    public static void main(String args[]){

       Runner r=new Runner();

       Thread t1=new Thread(r);

       Thread t2=new Thread(r);

       t1.start();

       t2.start();

    }

}

    class Runner implements Runnable{

       public Runner(){

           super();

       }

       public void run(){

           for(int i=0;i<20;i++){

              System.out.println("NO."+i);

           }

       }

    }