您当前的位置:首页 > 电脑百科 > 程序开发 > 语言 > JAVA

Java中有哪些无锁技术来解决并发问题?如何使用?

时间:2019-12-05 10:50:25  来源:  作者:

Java中有哪些无锁技术来解决并发问题?如何使用?

 

除了使用 synchronized、Lock 加锁之外,JAVA 中还有很多不需要加锁就可以解决并发问题的工具类

一、原子工具类

JDK 1.8 中,java.util.concurrent.atomic 包下类都是原子类,原子类都是基于 sun.misc.Unsafe 实现的。

  • CPU 为了解决并发问题,提供了 CAS 指令,全称 Compare And Swap,即比较并交互
  • CAS 指令需要 3 个参数,变量、比较值、新值。当变量的当前值与比较值相等时,才把变量更新为新值
  • CAS 是一条 CPU 指令,由 CPU 硬件级别上保证原子性
  • java.util.concurrent.atomic 包中的原子分为:原子性基本数据类型、原子性对象引用类型、原子性数组、原子性对象属性更新器和原子性累加器

原子性基本数据类型:AtomicBoolean、AtomicInteger、AtomicLong

原子性对象引用类型:AtomicReference、AtomicStampedReference、AtomicMarkableReference

原子性数组:AtomicIntegerArray、AtomicLongArray、AtomicReferenceArray

原子性对象属性更新:AtomicIntegerFieldUpdater、AtomicLongFieldUpdater、AtomicReferenceFieldUpdater

原子性累加器:DoubleAccumulator、DoubleAdder、LongAccumulator、LongAdder

修改我们之前测试原子性问题的类,使用 AtomicInteger 的简单例子

package constxiong.concurrency.a026;

import java.util.concurrent.atomic.AtomicInteger;

/**
 * 测试 原子类 AtomicInteger
 * 
 * @author ConstXiong
 */
public class TestAtomicInteger {

 // 计数变量
 static volatile AtomicInteger count = new AtomicInteger(0);

 public static void main(String[] args) throws InterruptedException {
 // 线程 1 给 count 加 10000
 Thread t1 = new Thread(() -> {
 for (int j = 0; j <10000; j++) {
 count.incrementAndGet();
 }
 System.out.println("thread t1 count 加 10000 结束");
 });

 // 线程 2 给 count 加 10000
 Thread t2 = new Thread(() -> {
 for (int j = 0; j <10000; j++) {
 count.incrementAndGet();
 }
 System.out.println("thread t2 count 加 10000 结束");
 });

 // 启动线程 1
 t1.start();
 // 启动线程 2
 t2.start();

 // 等待线程 1 执行完成
 t1.join();
 // 等待线程 2 执行完成
 t2.join();

 // 打印 count 变量
 System.out.println(count.get());
 }

}

打印结果如预期

thread t2 count 加 10000 结束
thread t1 count 加 10000 结束
20000
Java中有哪些无锁技术来解决并发问题?如何使用?

 

二、线程本地存储

  • java.lang.ThreadLocal 类用于线程本地化存储。
  • 线程本地化存储,就是为每一个线程创建一个变量,只有本线程可以在该变量中查看和修改值。
  • 典型的使用例子就是,spring 在处理数据库事务问题的时候,就用了 ThreadLocal 为每个线程存储了各自的数据库连接 Connection。
  • 使用 ThreadLocal 要注意,在不使用该变量的时候,一定要调用 remove() 方法移除变量,否则可能造成内存泄漏的问题。

示例

package constxiong.concurrency.a026;

/**
 * 测试 原子类 AtomicInteger
 * 
 * @author ConstXiong
 */
public class TestThreadLocal {

 // 线程本地存储变量
 private static final ThreadLocal<Integer> THREAD_LOCAL_NUM = new ThreadLocal<Integer>() {
 @Override
 protected Integer initialValue() {//初始值
 return 0;
 }
 };

 public static void main(String[] args) {
 for (int i = 0; i <3; i++) {// 启动三个线程
 Thread t = new Thread() {
 @Override
 public void run() {
 add10ByThreadLocal();
 }
 };
 t.start();
 }
 }

 /**
 * 线程本地存储变量加 5
 */
 private static void add10ByThreadLocal() {
 try {
 for (int i = 0; i <5; i++) {
 Integer n = THREAD_LOCAL_NUM.get();
 n += 1;
 THREAD_LOCAL_NUM.set(n);
 System.out.println(Thread.currentThread().getName() + " : ThreadLocal num=" + n);
 }
 } finally {
 THREAD_LOCAL_NUM.remove();// 将变量移除
 }
 }
}

每个线程最后一个值都打印到了 5

Thread-0 : ThreadLocal num=1
Thread-2 : ThreadLocal num=1
Thread-1 : ThreadLocal num=1
Thread-2 : ThreadLocal num=2
Thread-0 : ThreadLocal num=2
Thread-2 : ThreadLocal num=3
Thread-0 : ThreadLocal num=3
Thread-1 : ThreadLocal num=2
Thread-0 : ThreadLocal num=4
Thread-2 : ThreadLocal num=4
Thread-0 : ThreadLocal num=5
Thread-1 : ThreadLocal num=3
Thread-2 : ThreadLocal num=5
Thread-1 : ThreadLocal num=4
Thread-1 : ThreadLocal num=5

 

Java中有哪些无锁技术来解决并发问题?如何使用?

 

三、copy-on-write

  • 根据英文名称可以看出,需要写时复制,体现的是一种延时策略。
  • Java 中的 copy-on-write 容器包括:CopyOnWriteArrayList、CopyOnWriteArraySet。
  • 涉及到数组的全量复制,所以也比较耗内存,在写少的情况下使用比较适合。

简单的 CopyOnWriteArrayList 的示例,这里只是说明 CopyOnWriteArrayList 怎么用,并且是线程安全的。这个场景并不适合使用 CopyOnWriteArrayList,因为写多读少

package constxiong.concurrency.a026;

import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.CopyOnWriteArrayList;

/**
 * 测试 copy-on-write
 * @author ConstXiong
 */
public class TestCopyOnWrite {

 private static final Random R = new Random();
 
 private static CopyOnWriteArrayList<Integer> cowList = new CopyOnWriteArrayList<Integer>();
// private static ArrayList<Integer> cowList = new ArrayList<Integer>();
 
 public static void main(String[] args) throws InterruptedException {
 List<Thread> threadList = new ArrayList<Thread>();
 //启动 1000 个线程,向 cowList 添加 5 个随机整数
 for (int i = 0; i <1000; i++) {
 Thread t = new Thread(() -> {
 for (int j = 0; j <5; j++) {
 //休眠 10 毫秒,让线程同时向 cowList 添加整数,引出并发问题
 try {
 Thread.sleep(10);
 } catch (InterruptedException e) {
 e.printStackTrace();
 }
 cowList.add(R.nextInt(100));
 }
 }) ;
 t.start();
 threadList.add(t);
 }
 
 for (Thread t : threadList) {
 t.join();
 }
 System.out.println(cowList.size());
 }
}

打印结果

5000

如果把

private static CopyOnWriteArrayList<Integer> cowList = new CopyOnWriteArrayList<Integer>();

改为

private static ArrayList<Integer> cowList = new ArrayList<Integer>();

打印结果就是小于 5000 的整数了



Tags:Java 无锁技术   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,如有任何标注错误或版权侵犯请与我们联系(Email:2595517585@qq.com),我们将及时更正、删除,谢谢。
▌相关推荐
除了使用 synchronized、Lock 加锁之外,Java 中还有很多不需要加锁就可以解决并发问题的工具类一、原子工具类JDK 1.8 中,java.util.concurrent.atomic 包下类都是原子类,原...【详细内容】
2019-12-05  Tags: Java 无锁技术  点击:(70)  评论:(0)  加入收藏
▌简易百科推荐
面向对象的特征之一封装 面向对象的特征之二继承 方法重写(override/overWrite) 方法的重载(overload)和重写(override)的区别: 面向对象特征之三:多态 Instanceof关键字...【详细内容】
2021-12-28  顶顶架构师    Tags:面向对象   点击:(2)  评论:(0)  加入收藏
一、Redis使用过程中一些小的注意点1、不要把Redis当成数据库来使用二、Arrays.asList常见失误需求:把数组转成list集合去处理。方法:Arrays.asList 或者 Java8的stream流式处...【详细内容】
2021-12-27  CF07    Tags:Java   点击:(3)  评论:(0)  加入收藏
文章目录 如何理解面向对象编程? JDK 和 JRE 有什么区别? 如何理解Java中封装,继承、多态特性? 如何理解Java中的字节码对象? 你是如何理解Java中的泛型的? 说说泛型应用...【详细内容】
2021-12-24  Java架构师之路    Tags:JAVA   点击:(5)  评论:(0)  加入收藏
大家好!我是老码农,一个喜欢技术、爱分享的同学,从今天开始和大家持续分享JVM调优方面的经验。JVM调优是个大话题,涉及的知识点很庞大 Java内存模型 垃圾回收机制 各种工具使用 ...【详细内容】
2021-12-23  小码匠和老码农    Tags:JVM调优   点击:(12)  评论:(0)  加入收藏
前言JDBC访问Postgresql的jsonb类型字段当然可以使用Postgresql jdbc驱动中提供的PGobject,但是这样在需要兼容多种数据库的系统开发中显得不那么通用,需要特殊处理。本文介绍...【详细内容】
2021-12-23  dingle    Tags:JDBC   点击:(13)  评论:(0)  加入收藏
Java与Lua相互调用案例比较少,因此项目使用需要做详细的性能测试,本内容只做粗略测试。目前已完成初版Lua-Java调用框架开发,后期有时间准备把框架进行抽象,并开源出来,感兴趣的...【详细内容】
2021-12-23  JAVA小白    Tags:Java   点击:(11)  评论:(0)  加入收藏
Java从版本5开始,在 java.util.concurrent.locks包内给我们提供了除了synchronized关键字以外的几个新的锁功能的实现,ReentrantLock就是其中的一个。但是这并不意味着我们可...【详细内容】
2021-12-17  小西学JAVA    Tags:JAVA并发   点击:(11)  评论:(0)  加入收藏
一、概述final是Java关键字中最常见之一,表示“最终的,不可更改”之意,在Java中也正是这个意思。有final修饰的内容,就会变得与众不同,它们会变成终极存在,其内容成为固定的存在。...【详细内容】
2021-12-15  唯一浩哥    Tags:Java基础   点击:(17)  评论:(0)  加入收藏
1、问题描述关于java中的日志管理logback,去年写过关于logback介绍的文章,这次项目中又优化了下,记录下,希望能帮到需要的朋友。2、解决方案这次其实是碰到了一个问题,一般的情况...【详细内容】
2021-12-15  软件老王    Tags:logback   点击:(19)  评论:(0)  加入收藏
本篇文章我们以AtomicInteger为例子,主要讲解下CAS(Compare And Swap)功能是如何在AtomicInteger中使用的,以及提供CAS功能的Unsafe对象。我们先从一个例子开始吧。假设现在我们...【详细内容】
2021-12-14  小西学JAVA    Tags:JAVA   点击:(22)  评论:(0)  加入收藏
最新更新
栏目热门
栏目头条