AtomicBoolean的介绍与使用

2024-04-03 20:48
文章标签 使用 介绍 atomicboolean

本文主要是介绍AtomicBoolean的介绍与使用,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

AtomicBoolean是java.util.concurrent.atomic包下的原子变量,这个包里面提供了一组原子类。其基本的特性就是在多线程环境下,当有多个线程同时执行这些类的实例包含的方法时,具有排他性,即当某个线程进入方法,执行其中的指令时,不会被其他线程打断,而别的线程就像自旋锁一样,一直等到该方法执行完成,才由JVM从等待队列中选择一个另一个线程进入,这只是一种逻辑上的理解。实际上是借助硬件的相关指令来实现的,不会阻塞线程(或者说只是在硬件级别上阻塞了)。
例如AtomicBoolean,在这个Boolean值的变化的时候不允许在之间插入,保持操作的原子性。

方法和举例
compareAndSet(boolean expect, boolean update)。
这个方法主要两个作用

  1. 比较AtomicBoolean和expect的值,如果一致,执行方法内的语句。其实就是一个if语句
  2. 把AtomicBoolean的值设成update 比较最要的是这两件事是一气呵成的,这连个动作之间不会被打断,任何内部或者外部的语句都不可能在两个动作之间运行。为多线程的控制提供了解决的方案。
    看如下代码:
package zmx.atomic.test;import java.util.concurrent.TimeUnit;public class BarWorker implements Runnable {private static boolean exists = false;  private String name;  public BarWorker(String name) {   this.name = name;  }  @Override  public void run() {   if (!exists) {  try {  TimeUnit.SECONDS.sleep(1);  } catch (InterruptedException e1) {  // do nothing  }  exists = true;  System.out.println(name + " enter");  try {  System.out.println(name + " working");  TimeUnit.SECONDS.sleep(2);  } catch (InterruptedException e) {  // do nothing  }  System.out.println(name + " leave");  exists = false;  } else {  System.out.println(name + " give up");  }  } public static void main(String[] args) {BarWorker bar1 = new BarWorker("bar1");BarWorker bar2 = new BarWorker("bar2");new Thread(bar1).start();new Thread(bar2).start();}}

该代码使用static变量exists用来实现同一时间只有一个worker在工作. 但是假设exists的判断和exists = true;之间有了 其他指令呢? 输出如下:

bar1 enter
bar2 enter
bar1 working
bar2 working
bar1 leave
bar2 leave

可以看到两个线程同时工作了。这时可以用AtomicBoolean进行线程同步,代码如下:

package zmx.atomic.test;import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;public class BarWorker2 implements Runnable {private static AtomicBoolean exists = new AtomicBoolean(false);  private String name;  public BarWorker2(String name) {   this.name = name;  }  @Override  public void run() {   if (exists.compareAndSet(false, true)) {  System.out.println(name + " enter");  try {  System.out.println(name + " working");  TimeUnit.SECONDS.sleep(2);  } catch (InterruptedException e) {  // do nothing  }  System.out.println(name + " leave");  exists.set(false);    } else {  System.out.println(name + " give up");  }  } public static void main(String[] args) {BarWorker2 bar1 = new BarWorker2("bar1");BarWorker2 bar2 = new BarWorker2("bar2");new Thread(bar1).start();new Thread(bar2).start();}}

执行结果如下:

bar1 enter
bar1 working
bar2 give up
bar1 leave

可以看出仅仅一个线程进行工作,因为exists.compareAndSet(false, true)提供了原子性操作,比较和赋值操作组成了一个原子操作, 中间不会提供可乘之机。

这篇关于AtomicBoolean的介绍与使用的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

sky-take-out项目中Redis的使用示例详解

《sky-take-out项目中Redis的使用示例详解》SpringCache是Spring的缓存抽象层,通过注解简化缓存管理,支持Redis等提供者,适用于方法结果缓存、更新和删除操作,但无法实现... 目录Spring Cache主要特性核心注解1.@Cacheable2.@CachePut3.@Ca

C#下Newtonsoft.Json的具体使用

《C#下Newtonsoft.Json的具体使用》Newtonsoft.Json是一个非常流行的C#JSON序列化和反序列化库,它可以方便地将C#对象转换为JSON格式,或者将JSON数据解析为C#对... 目录安装 Newtonsoft.json基本用法1. 序列化 C# 对象为 JSON2. 反序列化

RabbitMQ 延时队列插件安装与使用示例详解(基于 Delayed Message Plugin)

《RabbitMQ延时队列插件安装与使用示例详解(基于DelayedMessagePlugin)》本文详解RabbitMQ通过安装rabbitmq_delayed_message_exchan... 目录 一、什么是 RabbitMQ 延时队列? 二、安装前准备✅ RabbitMQ 环境要求 三、安装延时队

Python ORM神器之SQLAlchemy基本使用完全指南

《PythonORM神器之SQLAlchemy基本使用完全指南》SQLAlchemy是Python主流ORM框架,通过对象化方式简化数据库操作,支持多数据库,提供引擎、会话、模型等核心组件,实现事务... 目录一、什么是SQLAlchemy?二、安装SQLAlchemy三、核心概念1. Engine(引擎)

Java Stream 并行流简介、使用与注意事项小结

《JavaStream并行流简介、使用与注意事项小结》Java8并行流基于StreamAPI,利用多核CPU提升计算密集型任务效率,但需注意线程安全、顺序不确定及线程池管理,可通过自定义线程池与C... 目录1. 并行流简介​特点:​2. 并行流的简单使用​示例:并行流的基本使用​3. 配合自定义线程池​示

Java中HashMap的用法详细介绍

《Java中HashMap的用法详细介绍》JavaHashMap是一种高效的数据结构,用于存储键值对,它是基于哈希表实现的,提供快速的插入、删除和查找操作,:本文主要介绍Java中HashMap... 目录一.HashMap1.基本概念2.底层数据结构:3.HashCode和equals方法为什么重写Has

GO语言中函数命名返回值的使用

《GO语言中函数命名返回值的使用》在Go语言中,函数可以为其返回值指定名称,这被称为命名返回值或命名返回参数,这种特性可以使代码更清晰,特别是在返回多个值时,感兴趣的可以了解一下... 目录基本语法函数命名返回特点代码示例命名特点基本语法func functionName(parameters) (nam

使用shardingsphere实现mysql数据库分片方式

《使用shardingsphere实现mysql数据库分片方式》本文介绍如何使用ShardingSphere-JDBC在SpringBoot中实现MySQL水平分库,涵盖分片策略、路由算法及零侵入配置... 目录一、ShardingSphere 简介1.1 对比1.2 核心概念1.3 Sharding-Sp

Java 正则表达式的使用实战案例

《Java正则表达式的使用实战案例》本文详细介绍了Java正则表达式的使用方法,涵盖语法细节、核心类方法、高级特性及实战案例,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要... 目录一、正则表达式语法详解1. 基础字符匹配2. 字符类([]定义)3. 量词(控制匹配次数)4. 边

Python Counter 函数使用案例

《PythonCounter函数使用案例》Counter是collections模块中的一个类,专门用于对可迭代对象中的元素进行计数,接下来通过本文给大家介绍PythonCounter函数使用案例... 目录一、Counter函数概述二、基本使用案例(一)列表元素计数(二)字符串字符计数(三)元组计数三、C