Java 并发编程学习笔记(3) ----Semaphore-tryAcquire()的使用

2024-04-20 17:38

本文主要是介绍Java 并发编程学习笔记(3) ----Semaphore-tryAcquire()的使用,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

tryAcquire()的使用

参数使用

当前时刻tryAcquire(int permits)Acquires the given number of permits from this semaphore, only if all are available at the time of invocation.尝试去从这个信号量获取指定数量的在调用时都是可用的许可 。如果不使用permits 参数,tryAcquire()表示获取一个许可。指定时间tryAcquire(int permits, long timeout, TimeUnit unit)Acquires the given number of permits from this semaphore,if all become available within the given waiting time and the current thread has not been interrupted.在指定的时间内尝试去从这个信号量获取指定数量的许可 ,同时这段时间内,这个线程没有被中断。如果不使用permits 参数,tryAcquire(long timeout, TimeUnit unit)表示获取一个许可。  

代码


package com.lhc.concurrent.semaphore;import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;public class TryAcquireService {private Semaphore semaphore = new Semaphore(8);public void doSomething() {try {/*** tryAcquire(int permits)* Acquires the given number of permits from this semaphore, only if all are available at the time of invocation.* 尝试去从这个信号量获取指定数量的在调用时都是可用的许可 。* 如果不使用permits 参数,tryAcquire()表示获取一个许可。*/if (semaphore.tryAcquire(2)) {System.out.println(Thread.currentThread().getName() + "获得锁,时间:" + System.currentTimeMillis());Thread.sleep(100);semaphore.release(2);}else {System.out.println(Thread.currentThread().getName() + "没有获得锁,时间:" + System.currentTimeMillis());}}catch (InterruptedException e){e.printStackTrace();}}public void doThing() {try {/*** tryAcquire(int permits, long timeout, TimeUnit unit)* Acquires the given number of permits from this semaphore,* if all become available within the given waiting time and the current thread has not been interrupted.* 在指定的时间内尝试去从这个信号量获取指定数量的许可 ,同时这段时间内,这个线程没有被中断。* 如果不使用permits 参数,tryAcquire(long timeout, TimeUnit unit)表示获取一个许可。*/if (semaphore.tryAcquire(2, 1, TimeUnit.SECONDS)) {System.out.println(Thread.currentThread().getName() + "获得锁,时间:" + System.currentTimeMillis());Thread.sleep(1000);System.out.println(Thread.currentThread().getName() + "释放锁,时间:" + System.currentTimeMillis());semaphore.release(2);}else {System.out.println(Thread.currentThread().getName() + "没有获得锁,时间:" + System.currentTimeMillis());}}catch (InterruptedException e){e.printStackTrace();}}
}

测试类


package com.lhc.concurrent.semaphore;public class TryAcquireThread extends Thread{private TryAcquireService tryAcquireService;public TryAcquireThread(TryAcquireService tryAcquireService, String name) {super();this.tryAcquireService = tryAcquireService;this.setName(name);}public static void main(String[] args){TryAcquireService tryAcquireService = new TryAcquireService();for (int i = 0; i < 10; i++) {TryAcquireThread tryAcquireThread = new TryAcquireThread(tryAcquireService, "线程" + i);tryAcquireThread.start();}}@Overridepublic void run() {//tryAcquireService.doSomething();tryAcquireService.doThing();}
}

测试结果

获取当前时刻

线程0获得锁,时间:1555145916044
线程4没有获得锁,时间:1555145916044
线程2获得锁,时间:1555145916044
线程1获得锁,时间:1555145916044
线程6没有获得锁,时间:1555145916044
线程5没有获得锁,时间:1555145916044
线程3获得锁,时间:1555145916044
线程7没有获得锁,时间:1555145916044
线程8没有获得锁,时间:1555145916044
线程9没有获得锁,时间:1555145916044

获取指定时间内

线程9获得锁,时间:1555146046722
线程7获得锁,时间:1555146046722
线程1获得锁,时间:1555146046722
线程6获得锁,时间:1555146046722
线程6释放锁,时间:1555146047722
线程9释放锁,时间:1555146047722
线程5获得锁,时间:1555146047722
线程4获得锁,时间:1555146047722
线程3没有获得锁,时间:1555146047722
线程1释放锁,时间:1555146047722
线程7释放锁,时间:1555146047722
线程0没有获得锁,时间:1555146047722
线程8没有获得锁,时间:1555146047722
线程2没有获得锁,时间:1555146047722
线程5释放锁,时间:1555146048723
线程4释放锁,时间:1555146048723

这篇关于Java 并发编程学习笔记(3) ----Semaphore-tryAcquire()的使用的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/920914

相关文章

springboot自定义注解RateLimiter限流注解技术文档详解

《springboot自定义注解RateLimiter限流注解技术文档详解》文章介绍了限流技术的概念、作用及实现方式,通过SpringAOP拦截方法、缓存存储计数器,结合注解、枚举、异常类等核心组件,... 目录什么是限流系统架构核心组件详解1. 限流注解 (@RateLimiter)2. 限流类型枚举 (

Java Thread中join方法使用举例详解

《JavaThread中join方法使用举例详解》JavaThread中join()方法主要是让调用改方法的thread完成run方法里面的东西后,在执行join()方法后面的代码,这篇文章主要介绍... 目录前言1.join()方法的定义和作用2.join()方法的三个重载版本3.join()方法的工作原

Spring AI使用tool Calling和MCP的示例详解

《SpringAI使用toolCalling和MCP的示例详解》SpringAI1.0.0.M6引入ToolCalling与MCP协议,提升AI与工具交互的扩展性与标准化,支持信息检索、行动执行等... 目录深入探索 Spring AI聊天接口示例Function CallingMCPSTDIOSSE结束语

Linux系统之lvcreate命令使用解读

《Linux系统之lvcreate命令使用解读》lvcreate是LVM中创建逻辑卷的核心命令,支持线性、条带化、RAID、镜像、快照、瘦池和缓存池等多种类型,实现灵活存储资源管理,需注意空间分配、R... 目录lvcreate命令详解一、命令概述二、语法格式三、核心功能四、选项详解五、使用示例1. 创建逻

Java获取当前时间String类型和Date类型方式

《Java获取当前时间String类型和Date类型方式》:本文主要介绍Java获取当前时间String类型和Date类型方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录Java获取当前时间String和Date类型String类型和Date类型输出结果总结Java获取

Spring Boot Actuator应用监控与管理的详细步骤

《SpringBootActuator应用监控与管理的详细步骤》SpringBootActuator是SpringBoot的监控工具,提供健康检查、性能指标、日志管理等核心功能,支持自定义和扩展端... 目录一、 Spring Boot Actuator 概述二、 集成 Spring Boot Actuat

OpenCV在Java中的完整集成指南分享

《OpenCV在Java中的完整集成指南分享》本文详解了在Java中集成OpenCV的方法,涵盖jar包导入、dll配置、JNI路径设置及跨平台兼容性处理,提供了图像处理、特征检测、实时视频分析等应用... 目录1. OpenCV简介与应用领域1.1 OpenCV的诞生与发展1.2 OpenCV的应用领域2

在Java中使用OpenCV实践

《在Java中使用OpenCV实践》用户分享了在Java项目中集成OpenCV4.10.0的实践经验,涵盖库简介、Windows安装、依赖配置及灰度图测试,强调其在图像处理领域的多功能性,并计划后续探... 目录前言一 、OpenCV1.简介2.下载与安装3.目录说明二、在Java项目中使用三 、测试1.测

go动态限制并发数量的实现示例

《go动态限制并发数量的实现示例》本文主要介绍了Go并发控制方法,通过带缓冲通道和第三方库实现并发数量限制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录带有缓冲大小的通道使用第三方库其他控制并发的方法因为go从语言层面支持并发,所以面试百分百会问到

Go语言并发之通知退出机制的实现

《Go语言并发之通知退出机制的实现》本文主要介绍了Go语言并发之通知退出机制的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1、通知退出机制1.1 进程/main函数退出1.2 通过channel退出1.3 通过cont