求 经典的线程池代码(考虑到线程泄露和死锁的)

rt  
  希望大家把自己用的都贴出来对比一下 问题点数：100、回复次数：4Top

1 楼zmm042（密码12345678）回复于 2006-03-07 11:00:02 得分 0

developerWorks有一个   贴出来做个引子吧  
  public   class   WorkQueue  
  {  
          private   final   int   nThreads;  
          private   final   PoolWorker[]   threads;  
          private   final   LinkedList   queue;  
   
          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();  
                  }  
          }  
   
          public   void   execute(Runnable   r)   {  
                  synchronized(queue)   {  
                          queue.addLast(r);  
                          queue.notify();  
                  }  
          }  
   
          private   class   PoolWorker   extends   Thread   {  
                  public   void   run()   {  
                          Runnable   r;  
   
                          while   (true)   {  
                                  synchronized(queue)   {  
                                          while   (queue.isEmpty())   {  
                                                  try  
                                                  {  
                                                          queue.wait();  
                                                  }  
                                                  catch   (InterruptedException   ignored)  
                                                  {  
                                                  }  
                                          }  
   
                                          r   =   (Runnable)   queue.removeFirst();  
                                  }  
   
                                  //   If   we   don't   catch   RuntimeException,    
                                  //   the   pool   could   leak   threads  
                                  try   {  
                                          r.run();  
                                  }  
                                  catch   (RuntimeException   e)   {  
                                          //   You   might   want   to   log   something   here  
                                  }  
                          }  
                  }  
          }  
  }Top

2 楼zmm043（密码12345678）回复于 2006-03-08 13:54:11 得分 0

没有人要分么？Top

3 楼zhzhl0（太极）回复于 2006-03-08 14:04:51 得分 50

想要分呢，可惜没有这方面的，就帮楼主顶下吧！Top

4 楼pigo（）回复于 2006-03-08 14:43:58 得分 50

 
  jdk1.5里的java.util.concurrent.ThreadPoolExecutor   非常好用。  
   
  Top

相关问题

• nthreads
• poolworker
• workqueue
• linkedlist
• queue
• private final
• threads

• 帖主：zmm042
• zhzhl0
• pigo

• CSDN Java频道
• Java类图书
• Java类源码下载