Java_多种线程池与判断线程是否全部执行完毕

痛定思痛。 2023-05-30 03:49 72阅读 0赞

摘要：

当任务量较大时，我们需要开启线程执行任务，但是在一些特定需求下，我们需要在全部任务执行后获取执行结束标识等信息，此时就需要判断任务分配的线程是否全部结束。

# 目录： #

1.  四种线程池
2.  判断线程是否全部执行完毕(CountDownLatch)
3.  CountDownLatch示例

# 1.声明线程池的方法 #

开启线程的方法有很多：

1.spring管理的ThreadPoolTaskExecutor线程池

**2.Java通过Executors提供的四种线程**

这里主要推荐Executor提供的四种线程池，也是使用较多的线程池。

我看到一篇介绍特别好的博文，在这里把链接放上：[https://www.jianshu.com/p/cf2dd6c203a2][https_www.jianshu.com_p_cf2dd6c203a2]

# 2.CountDownLatch判断线程是否全部结束 #

*  CountDownLatch可以理解为是一个计数器;
 *  该计数器的总数量是需要主动声明的；
 *  每当某个线程完成时，可以调用该计数器的**countDown()**方法来将计数器中的任务数减一；
 *  当计数器中的数字为0时，即表示所有任务已完成;
 *  使用**await()**来阻塞主线程往下面执行，知道计数器为0
 *  计数器关键方法如下图：
    
        //调用await()方法的线程会被挂起，它会等待直到count值为0才继续执行
        public void await() throws InterruptedException { 
        
        };   
        //和await()类似，只不过等待一定的时间后count值还没变为0的话就会继续执行
        public boolean await(long timeout, TimeUnit unit) throws InterruptedException {
        
        };  
        //将count值减1
        public void countDown() { 
        
        };

# 3.Spring示例 #

创建一个处理任务的线程：

import java.util.concurrent.CountDownLatch;
    
    public class TestRunnal implements Runnable {
    
        private final CountDownLatch countDownLatch;  //传入计数器
        private int i;
         
    	@Override
    	public void run() {
    		// TODO Auto-generated method stub
    		work();  //处理任务
    		countDownLatch.countDown();//任务处理完成后,调用方法，将计数器数量-1
    	}
    
        // 声明构造函数,在new该线程的时候，传入构造器 和 需要处理的i
    	public TestRunnal(CountDownLatch countDownLatch, int i) {
    		super();
    		this.countDownLatch= countDownLatch;
    		this.i = i;
    	}
    	
    	private void work(){
    		for(int a=0;a<3;a++){
    			System.out.println("a:"+a);
    			try {
    				Thread.sleep(500);
    			} catch (InterruptedException e) {
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    			}
    			
    		}
    	}
    	
    }

创建分配任务类，并测试

public class Test {
     
    
    	public static void main(String[] args) {
    
            // 声明计数器,并指定计数器的最大值
            CountDownLatch countDownLatch= new CountDownLatch(5);
    
            // 声明三个线程
    		ExecutorService executor = Executors.newFixedThreadPool(3);
            
    		for (int i = 0; i < TOTAL_TASKS; i++) {
                // 调用线程,通过构造器把计数器和任务传递给线程
    			executor.execute(new TestRunnal(countDownLatch, i));
    
    		}
    		try {
    			latch.await(); //线程阻塞,当latch中数量为0时，放行
    		} catch (InterruptedException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    
    		System.out.println("此时全部线程均执行结束：over");
    		executor.shutdown();  //关闭线程池
    
    	}
    }

测试结果如下图：

![20191107104636549.png][]

[https_www.jianshu.com_p_cf2dd6c203a2]: https://www.jianshu.com/p/cf2dd6c203a2
[20191107104636549.png]: https://img-blog.csdnimg.cn/20191107104636549.png