【Java并发编程十一】同步控制三

2023-11-22 23:28

本文主要是介绍【Java并发编程十一】同步控制三,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

LockSupport 线程阻塞工具

 LockSupport的unpark() 方法可以先执行。

import java.util.ArrayList;
import java.util.Random;
import java.util.concurrent.*;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.LockSupport;
import java.util.concurrent.locks.ReentrantLock;
public class myTest implements Runnable{public static void main(String[] args) throws InterruptedException {Thread thread = new Thread(new myTest());thread.start();Thread.sleep(3000);// 继续执行子线程LockSupport.unpark(thread);}@Overridepublic void run() {System.out.println(Thread.currentThread().getId()+"已被阻塞");// 线程被阻塞LockSupport.park();System.out.println("继续执行");}
}

ReadWriteLock 读写锁

 将读写操作分离,从而提高程序执行的效率。这个可以使多个线程可以同时读取数据。

ReentrantReadWriteLock.readLock() 读锁

 当这个方法开启的时候,在休眠一秒后加了锁,按道理来说,18个线程至少要等18秒才能运行完成,但是对于锁类型是读写锁的线程而言,可以被多个线程重复进入,重入锁和读写锁的区别在于,重入锁是对于本线程的行为可以被重复进入而不加锁,读写锁则是对于多个不进行修改操作的线程,都可以进入而不加锁

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
public class myTest{// 可重入锁private static Lock lock = new ReentrantLock();// 可重入的读写锁private static ReentrantReadWriteLock reentrantReadWriteLock = new ReentrantReadWriteLock();// 读锁private static Lock read = reentrantReadWriteLock.readLock();private int value = 0;public static void main(String[] args) {final myTest test = new myTest();Runnable readrunnable = new Runnable() {@Overridepublic void run() {test.handleRead(read);}};for (int i = 0; i < 18; i++) {new Thread(readrunnable).start();}}public Object handleRead(Lock lock) {try {lock.lock();Thread.sleep(1000);System.out.println("what");return value;} catch (InterruptedException e) {throw new RuntimeException(e);}// 该块代码块无论如何都会被执行finally {lock.unlock();return value;}}
}

ReentrantReadWriteLock.writeLock() 写锁

 写锁是一个排它锁,只能被一个线程所获取,这个锁的主要方法,也来自于AQS同步器。

package myTest;import jdk.jshell.EvalException;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
public class myTest{// 可重入的读写锁private static ReentrantReadWriteLock lock = new ReentrantReadWriteLock();private static int value = 0;// 读操作public static void readFile(Thread thread) {Lock read = lock.readLock();read.lock();if(!lock.isWriteLocked()) {System.out.println(thread.getName()+": 当前为读锁");}try {for (int i = 0; i < 5; i++) {try {Thread.sleep(20);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println(thread.getName()+"正在读取读取");}System.out.println(thread.getName()+": 读取完毕" + value);//setValue();} finally {System.out.println(thread.getName()+": 释放读锁");read.unlock();}}public static void setValue()  {value ++;}// 写操作public static void writeFile(Thread thread) {Lock write = lock.writeLock();if(lock.isWriteLocked()) {System.out.println(thread.getName()+"当前为写锁");}try {for (int i = 0; i < 5; i++) {try {Thread.sleep(20);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println(thread.getName()+": 正在写");}value ++;System.out.println(thread.getName()+": 写完毕");} finally {System.out.println(thread.getName()+ ": 释放写锁");write.unlock();}}public static void main(String[] args) {ExecutorService service = Executors.newCachedThreadPool();service.execute(new Runnable() {@Overridepublic void run() {readFile(Thread.currentThread());}});service.execute(new Runnable() {@Overridepublic void run() {writeFile(Thread.currentThread());}});service.execute(new Runnable() {@Overridepublic void run() {readFile(Thread.currentThread());}});service.execute(new Runnable() {@Overridepublic void run() {readFile(Thread.currentThread());}});service.execute(new Runnable() {@Overridepublic void run() {writeFile(Thread.currentThread());}});service.execute(new Runnable() {@Overridepublic void run() {readFile(Thread.currentThread());}});}}

锁降级

 写锁可以降级为读锁,读锁不能降级为写锁。

import jdk.jshell.EvalException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
public class myTest{// 可重入的读写锁private static ReentrantReadWriteLock lock = new ReentrantReadWriteLock();static Lock readLock = lock.readLock();static Lock writeLock = lock.writeLock();public static void main(String[] args) {// 1. 获取写锁writeLock.lock();System.out.println("获取写锁");// 2. 获取读锁readLock.lock();System.out.println("获取读锁");// 3. 释放写锁writeLock.unlock();// 4. 释放读锁readLock.unlock();}
}

 如下面代码所示。但是在持有读锁时,在有读锁,就会报错。

import jdk.jshell.EvalException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
public class myTest{// 可重入的读写锁private static ReentrantReadWriteLock lock = new ReentrantReadWriteLock();static Lock readLock = lock.readLock();static Lock writeLock = lock.writeLock();public static void main(String[] args) {// 2. 获取读锁readLock.lock();System.out.println("获取读锁");        // 1. 获取写锁writeLock.lock();System.out.println("获取写锁");// 3. 释放写锁writeLock.unlock();// 4. 释放读锁readLock.unlock();}
}

这篇关于【Java并发编程十一】同步控制三的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/413673

相关文章

Spring boot整合dubbo+zookeeper的详细过程

《Springboot整合dubbo+zookeeper的详细过程》本文讲解SpringBoot整合Dubbo与Zookeeper实现API、Provider、Consumer模式,包含依赖配置、... 目录Spring boot整合dubbo+zookeeper1.创建父工程2.父工程引入依赖3.创建ap

SpringBoot结合Docker进行容器化处理指南

《SpringBoot结合Docker进行容器化处理指南》在当今快速发展的软件工程领域,SpringBoot和Docker已经成为现代Java开发者的必备工具,本文将深入讲解如何将一个SpringBo... 目录前言一、为什么选择 Spring Bootjavascript + docker1. 快速部署与

Spring Boot spring-boot-maven-plugin 参数配置详解(最新推荐)

《SpringBootspring-boot-maven-plugin参数配置详解(最新推荐)》文章介绍了SpringBootMaven插件的5个核心目标(repackage、run、start... 目录一 spring-boot-maven-plugin 插件的5个Goals二 应用场景1 重新打包应用

SpringBoot+EasyExcel实现自定义复杂样式导入导出

《SpringBoot+EasyExcel实现自定义复杂样式导入导出》这篇文章主要为大家详细介绍了SpringBoot如何结果EasyExcel实现自定义复杂样式导入导出功能,文中的示例代码讲解详细,... 目录安装处理自定义导出复杂场景1、列不固定,动态列2、动态下拉3、自定义锁定行/列,添加密码4、合并

Spring Boot集成Druid实现数据源管理与监控的详细步骤

《SpringBoot集成Druid实现数据源管理与监控的详细步骤》本文介绍如何在SpringBoot项目中集成Druid数据库连接池,包括环境搭建、Maven依赖配置、SpringBoot配置文件... 目录1. 引言1.1 环境准备1.2 Druid介绍2. 配置Druid连接池3. 查看Druid监控

Java中读取YAML文件配置信息常见问题及解决方法

《Java中读取YAML文件配置信息常见问题及解决方法》:本文主要介绍Java中读取YAML文件配置信息常见问题及解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要... 目录1 使用Spring Boot的@ConfigurationProperties2. 使用@Valu

创建Java keystore文件的完整指南及详细步骤

《创建Javakeystore文件的完整指南及详细步骤》本文详解Java中keystore的创建与配置,涵盖私钥管理、自签名与CA证书生成、SSL/TLS应用,强调安全存储及验证机制,确保通信加密和... 目录1. 秘密键(私钥)的理解与管理私钥的定义与重要性私钥的管理策略私钥的生成与存储2. 证书的创建与

浅析Spring如何控制Bean的加载顺序

《浅析Spring如何控制Bean的加载顺序》在大多数情况下,我们不需要手动控制Bean的加载顺序,因为Spring的IoC容器足够智能,但在某些特殊场景下,这种隐式的依赖关系可能不存在,下面我们就来... 目录核心原则:依赖驱动加载手动控制 Bean 加载顺序的方法方法 1:使用@DependsOn(最直

SpringBoot中如何使用Assert进行断言校验

《SpringBoot中如何使用Assert进行断言校验》Java提供了内置的assert机制,而Spring框架也提供了更强大的Assert工具类来帮助开发者进行参数校验和状态检查,下... 目录前言一、Java 原生assert简介1.1 使用方式1.2 示例代码1.3 优缺点分析二、Spring Fr

java使用protobuf-maven-plugin的插件编译proto文件详解

《java使用protobuf-maven-plugin的插件编译proto文件详解》:本文主要介绍java使用protobuf-maven-plugin的插件编译proto文件,具有很好的参考价... 目录protobuf文件作为数据传输和存储的协议主要介绍在Java使用maven编译proto文件的插件