、慕白

基本演示了線程池和隊(duì)列的應(yīng)用

  public class WorkQueue { 
   

   private final int nThreads;//線程池的大小 
   private final PoolWorker[] threads;//用數(shù)組實(shí)現(xiàn)線程池 
   private final LinkedList queue;//任務(wù)隊(duì)列 

  public WorkQueue(int nThreads){ 
     this.nThreads = nThreads; 
     queue = new LinkedList(); 
     threads = new PoolWorker[nThreads]; 

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

         threads[i] = new PoolWorker(); 
         threads[i].start();//啟動(dòng)所有工作線程 
      } 
  } 

  public void execute(Runnable r) {//任務(wù) 
    synchronized(queue) { 
            queue.addLast(r); 
            queue.notify(); 
    } 
  } 

  private class PoolWorker extends Thread {//工作線程類 
        public void run() { 
               Runnable r; 
               while (true) { 
                    synchronized(queue) { 
                      while (queue.isEmpty()) {//如果任務(wù)隊(duì)列中沒有任務(wù)，等待 
                        try{ 
                          queue.wait(); 
                        }catch (InterruptedException ignored){} 
                      }    
                       r = (Runnable) queue.removeFirst();//有任務(wù)時(shí)，取出任務(wù) 
                   } 
                   try { 
                       r.run();//執(zhí)行任務(wù) 
                   }catch (RuntimeException e) { 
                      // You might want to log something here 
                  } 
              } 
      } 
   } 


 public static void main(String args[]){ 
      WorkQueue wq=new WorkQueue(10);//10個(gè)工作線程 
      Mytask r[]=new Mytask[20];//20個(gè)任務(wù) 
   
      for(int i=0;i<20;i++){ 
           r[i]=new Mytask(); 
           wq.execute(r[i]); 
      }       
 } 
} 
class Mytask implements Runnable{//任務(wù)接口 
         public void run(){ 
              String name=Thread.currentThread().getName(); 
              try{ 
                  Thread.sleep(100);//模擬任務(wù)執(zhí)行的時(shí)間 
              }catch(InterruptedException e){} 
              System.out.println(name+" executed OK"); 
         } 
  }