ThreadPoolExecutor 有关java5线程池的问题

Question

有如下的一个线程池
threadPoolExecutor = new ThreadPoolExecutor(1, 50, 1000L, TimeUnit.SECONDS, new BlockingQueueOfExecutor(500, true));
 while(true){
 for(Iterator iterator = taskList.iterator(); iterator.hasNext();)
                        {
                            SfCollecttask task = (SfCollecttask)iterator.next();
                            Runnable run = new CollectThread(task, collecttaskDao, collectinfoDao, dslamDAO, statitemparaDAO,collectionNum, threadPoolExecutor);
                            threadPoolExecutor.execute(run);
                       
                        }
  }
如果线程池里面有800 个线程,,,如果有5个线程执行完了之后 也就是?CollectThread 的run方法完成之后,我要将所有的线程给停止了,那么我该真么做呢

Answer 1

CollectThread 主要是连接socket的方式连接,和发送数据,都是对同样的一个端口,如果有前5个连接都超时了,那么后面的线程就不执行了

Answer 2

设置一个标志状态，当true时,run执行，false时，run停止
设置一个计数器，在run方法结束的时候更新。
添加一个Timer，定时去检测计数器中的值，如果大于5，将标志状态设置为false
切记，在计数器和标志状态的操作时加同步。