CountDownLatch并发测试

CountDownLatch并发测试CountDownLatch是并发容器JUC下的类,允许一个或多个线程等待直到在其他线程中执行的一组操作完成的同步辅助。使用给定的计数初始化CountDownWatch。由于调用了countdown()方法,wait方法将一直阻塞,直到当前计数为零。之后,所有等待线程都被释放,任何随后的wait调用都会立即返回。这是一种一次性现象——计数无法重置。如果您需要重置计数的版本,请考虑使用cyclic…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全家桶1年46,售后保障稳定

CountDownLatch是并发容器JUC下的类,允许一个或多个线程等待直到在其他线程中执行的一组操作完成的同步辅助。
使用给定的计数初始化CountDownWatch。由于调用了countdown()方法,wait方法将一直阻塞,直到当前计数为零。之后,所有等待线程都被释放,任何随后的wait调用都会立即返回。这是一种一次性现象——计数无法重置。如果您需要重置计数的版本,请考虑使用cyclicBarrier。
CountDownLatch是一种通用的同步工具,可用于多种用途。用一个计数初始化的Countdownloatch用作一个简单的开/关闩锁。或:所有调用的线程都等待在入口等待,直到被调用的线程打开为止。countDown()。一个CountDownLatch初始化为N可以用来做一个线程等待,直到N线程完成一些动作,或某些动作已经完成N次。
Countdownloatch的一个有用属性是,它不要求调用countdown的线程在继续之前等待计数达到零, 它只是防止任何线程在所有线程都可以通过之前继续经过等待。
CountDownLatch 官方API

HttpClientUtil是自己写的一个发送http请求的工具类

public class CountDownLatchTest { 
   

	public static void main(String[] args) { 
   
		final long time = System.currentTimeMillis();
		final String url = "http://localhost/user/";
		int len = 10;
		final CountDownLatch latch = new CountDownLatch(len);
		for (int i = 0; i < len; i++) { 
   
			final int id = i;
			new Thread(new Runnable() { 
   
				public void run() { 
   
					try{ 
   
						Thread.sleep(1000 * id);
						System.out.println("第" + id + "个请求已到位");
						latch.countDown();
						latch.await();
					} catch (InterruptedException e){ 
   
						e.printStackTrace();
					}
					HttpClientUtil.sendGet(url + id);
					long usetime = System.currentTimeMillis() - time;
					System.out.println("到第" + id + "个请求已用时:" + usetime / 1000 + "秒");
				}
			}).start();
		}
	}

}

Jetbrains全家桶1年46,售后保障稳定

主要使用两个方法

public void await()

除非线程被中断,否则导致当前线程等待锁存器倒计数到零。, 导致当前线程等待,直到锁存器倒计数至零,除非线程被中断。
如果当前计数为零,则此方法立即返回。
如果当前计数大于零,则当前线程将被禁用以进行线程调度,并且在发生以下两种情况之一之前处于休眠状态:, 如果当前计数大于零,则当前线程的线程调度目的就退出,一直处于休眠状态的两种情况之一发生:
由于countDown()方法的调用,计数达到零;要么
其他一些线程会中断当前线程。
如果当前线程:
在进入此方法时设置其中断状态;要么
在等待时被打断
然后抛出InterruptedException并清除当前线程的中断状态。

public void countDown()

减少锁存器的计数,如果计数达到零则释放所有等待的线程。
如果当前计数大于零,则递减。如果新计数为零,则重新启用所有等待线程以进行线程调度。
如果当前计数等于零,则没有任何反应。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/234070.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • hashmap线程安全吗 什么解决方案_HashMap的底层实现原理

    hashmap线程安全吗 什么解决方案_HashMap的底层实现原理我们都知道HashMap是线程不安全的,在多线程环境中不建议使用,应该使用ConcurrentHashMap,但是其线程不安全体现在什么地方,可能并没有深入理解,本文将对该问题进行解密。

    2025年7月1日
    4
  • idea社区版免费吗_intellij idea community edition

    idea社区版免费吗_intellij idea community edition背景#t#v2m”K2R!E’V#d5Y:n,B.q5H#c2v-F%K#u0o#p;n6m”m&b作为一个java企业开发者,现在IntelliJIDEA付费版的激活方法越来越难找。即使找到了,过段时间也会激活失效。付费版是费用对我的现在情况来说还是太贵:按年付费,很多功能都没用到。3e/@9K,}0g8H&I这让我…

    2022年9月16日
    5
  • Java中Ajax学习「建议收藏」

    Java中Ajax学习「建议收藏」1.Ajax:异步js和xml异步刷新:如果网页中某一个地方需要修改,异步刷新可以使,只刷新该需要修改的地方,而页面其他中的地方保持不变。例如:百度搜索框,视频的点赞等实现(两种方式):Js:XMLHttpRequest对象XMLHttpRequest对象的方法:open(方法名【提交方式get或者post】,服务器地址,ture【是否选用异步刷新,99%都是ture】):与服务端建立连接send():get: send(null)post: send(参数值)setRequestHe

    2022年7月7日
    26
  • animate.css的使用

    animate.css的使用[1]引入[2]效果演示[3]实际应用

    2022年6月30日
    26
  • GO Excel 转 JSON (完整代码)[通俗易懂]

    GO Excel 转 JSON (完整代码)[通俗易懂]packagemainimport( “fmt” “github.com/xuri/excelize/v2” “io/ioutil” “os” “path/filepath”)funcinit(){}//配置文件目录varconfigPathstring=”../../Configs”varoutjsonPathstring=”./json/”funcgetFileList(pathstring)[]string{ varall_f.

    2022年5月8日
    49
  • 基于云平台的物联网架构和原理设计_物联网的架构

    基于云平台的物联网架构和原理设计_物联网的架构基于云平台的物联网架构和原理云的服务架构云计算是通过各种技术手段服务客户的一种方式,包括三层服务模式,即最底层的IaaS(基础设施即服务),中间层的PaaS(平台即服务),和顶层的SaaS(软件即服务)。IaaS:最底层,为客户提供基础设施资源,包括计算、存储、网络等,这是构建云平台和云应用的硬件支撑,同时它本身作为一种服务,面向使用者(如单纯的存储数据)和开发者(如使用服务器)。P…

    2022年9月17日
    3

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号