• 首页 首页 icon
  • 工具库 工具库 icon
    • IP查询 IP查询 icon
  • 内容库 内容库 icon
    • 快讯库 快讯库 icon
    • 精品库 精品库 icon
    • 问答库 问答库 icon
  • 更多 更多 icon
    • 服务条款 服务条款 icon

java如何等待线程池中任务全部完成

武飞扬头像
Heaven-Wang
帮助960

一、等待线程池所有线程完成:

有时候我们需要等待java thread pool中所有任务完成后再做某些操作,如想要等待所有任务完成,仅需调用threadPool.awaitTermination()方法即可,请查看如下代码:

ExecutorService threadPool = Executors.newFixedThreadPool(ConfigUtil.ACCESSDB_THREAD_POOL_SIZE);
		for(String key:noneExsitKeys){
			  ConcurrentAccessDBJob job = new ConcurrentAccessDBJob(key,userLevel,dao,service);  
			  threadPool.submit(job); 
		}
		threadPool.shutdown();  
		try {//等待直到所有任务完成
			threadPool.awaitTermination(Long.MAX_VALUE, TimeUnit.MINUTES);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}

二、等待线程池指定线程完成:

如果我们仅仅想等待某些线程完成,我们可以利用Future,调用future.get()可以阻塞主线程等待子线程完成。通过把调用每个线程的Future放入Map或List中,然后遍历需要等待完成线程的Future,调用future.get() 方法:

Map<String, Future<?>> jobFutureMap=new HashMap<String, Future<?>>();
		for(String key:noneExsitKeys){
			ConcurrentAccessDBJob job = new ConcurrentAccessDBJob(key,userLevel, dao, service);
			Future<?> future = threadPool.submit(job);
			jobFutureMap.put(key, future);
		}
		for(String key:noneExsitKeys){
			Future<?> future =jobFutureMap.get(key);
			future.get();//调用此方法会使主线程等待子线程完成
			System.out.println("---future.idDone()" future.isDone());
		}	



这篇好文章是转载于:学新通技术网

  • 版权申明: 本站部分内容来自互联网,仅供学习及演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,请提供相关证据及您的身份证明,我们将在收到邮件后48小时内删除。
  • 本站站名: 学新通技术网
  • 本文地址: /boutique/detail/tanffaij
系列文章
更多 icon
同类精品
更多 icon
继续加载