计数器让主线程等待所有子线程完成后，再工作

public class ThreadPool {

    private static ExecutorService executor;
    private static int count = 0;

    static {
        executor = Executors.newFixedThreadPool(3);
    }

    public static void execute(Runnable run) {
        count++;
        executor.execute(run);
    }

    public static void close(){
        executor.shutdown();
    }

    public static boolean isClosed(){
        if(executor.isShutdown()){
            return true;
        }else{
            return false;
        }
    }

    public synchronized static void deleteCount(){
        count--;
        System.out.println(count);
    }

    public static int getCount(){
        return count;
    }

    public static void out(){
        System.out.println("最终的个数" + count);
    }
}

 

 

public class ThreadPoolTest {

    public static void main(String[] args){
        for(int i = 0; i< 5; i++){
            ThreadPool.execute(new Runnable(){

                public void run() {
                    System.out.println(Thread.currentThread().getName() + "开始了");
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException ex) {
                        Logger.getLogger(ThreadPoolTest.class.getName()).log(Level.SEVERE, null, ex);
                    }
                    System.out.println(Thread.currentThread().getName() + "完成了");
                    ThreadPool.deleteCount();
                    
                }

            });
        }
        while(ThreadPool.getCount() != 0){
            
            if(ThreadPool.getCount() == 0){
                break;
            }
        }
        System.out.println("全部完成了，结束");
        ThreadPool.close();
        
    }
}

 

评论

2 楼 mylove842658 2013-04-24  

1 楼 mylove842658 2013-04-24