java 自旋方法_JAVA循环使用CAS实现自旋操作

大家碰到了实现一个线程安全的计数器的需求改怎么做呢?根据经验你应该知道我们要在多线程中实现共享变量的原子性和可见性问题,于是锁成为一个不可避免的话题,下文讨论的是与之对应的无锁CAS。

为什么要无锁

我们一想到在多线程下保证安全的方式,肯定是锁,不管从硬件、操作系统层面都或多或少在使用锁。锁有优缺点吗?

8584d950a4baba5b5f21e2e457970098.png

使用锁就需要获得锁、释放锁,CPU需要通过上下文切换和调度管理来进行这个操作,对于一个独占锁,一个线程在持有锁后没有执行结束,其他线程就必须等待,等到前面的线程执行完毕,CPU就会把锁拿出来给其他线程来抢了。锁的这种概念基于一种悲观机制,它总是认为数据会被修改,所以,你在操作一部分代码块之前先加一把锁,操作完成后再释放,这样就安全了。

什么是 CAS

比较并交换(compare and swap,CAS),是原子操作的一种,可用于在多线程编程中实现不被打断的数据交换操作,从而避免多线程同时改写某一数据时由于执行顺序不确定性以及中断的不可预知性产生的数据不一致性问题。该操作通过将内存中的值与指定的数据进行比较,当数值一样时,将内存中的数据替换成新值。

JAVA如何实现

package com.concurrent.program;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.List;

import java.util.concurrent.atomic.AtomicInteger;

public class Counter {

private AtomicInteger atomicI = new AtomicInteger(0);

private int i = 0;

public static void main(String[] args) {

final Counter cas = new Counter();

Listts = new ArrayList(10);

long start = System.currentTimeMillis();

for (int j=0;j < 100; j++){

Thread t = new Thread(new Runnable() {

@Override

public void run() {

for (int i=0;i<10000; i++){

cas.count();

cas.safeCount();

}

}

});

ts.add(t);

}

for (Thread t : ts) {

t.start();

}

//等待所有线程执行完成

for (Thread t:ts){

try {

t.join();

} catch (InterruptedException e){

e.printStackTrace();

}

}

System.out.println(cas.i);

System.out.println(cas.atomicI.get());

System.out.println(System.currentTimeMillis() - start);

}

/**

* 使用CAS实现线程安全计数器

*/

private void safeCount(){

for(;;){

int i = atomicI.get();

boolean suc = atomicI.compareAndSet(i, ++i);

if (suc) {

break;

}

}

}

/**

* 非线程安全计数器

*/

private void count(){

i++;

}

}

以上代码实现了一个基于CAS线程安全的计数器方法safeCount和一个非线程安全的计数器方法count,读者可以自行运行,运行结果如下:

非线程安全计数器: 971850

使用CAS实现线程安全计数器: 1000000

执行时间:78ms

CAS存在的问题

1.ABA问题。因为CAS需要在操作值的时候,检查值有没有发生变化,如果没有则更新。但是如果原来一个值是A,变成了B,又变成A,那么使用CAS进行检查时会发现它的值没有发生变化,但是实际发生了变化了。ABA解决问题的思路就是使用版本号。在变量前面追加版本号,每次变量更新的时候把版本号加1,那么A→B→A就会变成1A→2B→3A。从JAVA1.5开始,JDK的Atomic包里提供了一个类AtomicStampedReference来解决ABA问题。

2.循环时间长,开销大。CAS长时间不成功,会给CPU带来非常大的执行开销。如果JVM能支持处理器提供的pause指令,那么效率会有一定的提示。

3.只能保证一个共享变量的原子操作。对多个共享变量操作时,CAS可以把多个共享变量合并成一个共享变量来操作。比如,有两个共享变量i=2,j=a,合并成ij=2a,然后用CAS来操作ij。从JAVA1.5开始,JDK的Atomic包里面提供了一个类AtomicReference类来保证引用对象之间的原子性,就可以把多个变量放在一个对象里面来进行CAS操作。

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

java变量小明扑克牌_算法练习篇之:扑克牌顺子

该楼层疑似违规已被系统折叠 隐藏此楼查看此楼代码实现import java.util.Arrays;public class isContinuous {//扑克牌顺子(必须连续的五个数字)public boolean continuous(int[] num){int zero0,dis0;//zero为大小王的个数&#xff0c;dis为不连续序列中两个数字相隔距离if (n…

java stream foreach_Java 8 Lambda Stream forEach具有多个语句

我仍在学习Lambda&#xff0c;请原谅我做错了什么final Long tempId 12345L;List updatedEntries new LinkedList<>();for (Entry entry : entryList) {entry.setTempId(tempId);updatedEntries.add(entityManager.update(entry, entry.getId()));}//entryList.stream(…

java tls 实例_grpc加密TLS初体验(go、java版本)

grpc加密TLS初体验(go、java版本)grpc-go、java的安装编译helloworld可以参考如下文章openssl的安装、生成秘钥证书可以参考如下文章示例代码go版本服务端代码package mainimport ("fmt""log""net"pb "github.com/grpc/grpc-common/go/hell…

java的svn插件maver_项目版本管理工具---MAVENSVN

在进行实际项目开发时往往不是由一个人去完成一整个项目&#xff0c;而是分模块进行完成最后将所有项目进行聚合&#xff0c;那么就可以用到maven和svn。MAVEN是用来管理项目的&#xff0c;我认为它最大的优势就在于依赖和聚合吧&#xff0c;而svn的优势就在于版本控制&#xf…

java第一次上机_java第一次上机实验--验证码

1 package javashiyan;23 import java.awt.Color;4 import java.awt.event.ActionEvent;5 import java.awt.event.ActionListener;67 import javax.swing.*;89 public class Yanzhen extends JFrame10 {11 //定义成员变量12 private Mypanel mp;13 private JButton b;14 privat…

java实现extended smtp_java实现发送邮件(SMTP)

1.pom引入包javax.mailmail1.4.72.Email实体类import lombok.Data;import lombok.EqualsAndHashCode;import lombok.experimental.Accessors;import java.util.List;import java.util.Map;/*** ClassName: Email* author: mxy* Description: Email的实体类*/DataEqualsAndHashC…

java实现封装的三步是_JAVA基础-封装

封装的概念 通常情况下可以在测试类给成员变量赋值一些合法但不合理的数值(比如年龄是500). 无论是编译阶段还是运行阶段都不会报错或者给出提示, 此时与现实生活不符 为了避免上述错误的发生, 就需要对成员变量进行密封包装处理,来隐藏成员变量的细节以及保证成员变量数值的合…

java中广告维护轮播图怎么做_Banner广告轮播图

需求描述轮播图也是大部分app都有的效果&#xff0c;商品类跟新闻类的app是肯定会有的。轮播图的效果跟第一次启动时的引导页类似&#xff0c;不过轮播图在引导页的基础上多了几个功能:在第一页也能向左滑动,在最后一页也能向右滑动有个计时器&#xff0c;每隔一段时间滚动轮播…

java addcallback函数_java中怎么使用callback函数?

UYOU在很多场景&#xff0c;作为开发都会想到&#xff0c;在执行完毕一个任务的时候&#xff0c;能执行一个callback函数是多么好的事情。现在模拟一下这个情景&#xff1a;定义三个类。分别是主函数类。callback函数的接口类。业务处理类。在业务处理类中&#xff0c;处理完业…

oracle 数据抽取 java_oracle数据抽取步骤

oracle数据抽取步骤Database links:1、 在本地计算机上&#xff0c;新建一个连接远程数据库的连接&#xff0c;并记住这个连接的服务名(例如&#xff1a;jzfx_remote)&#xff1b;2、 返回远程数据库的GLOBAL_NAME&#xff1a;执行&#xff1a;SELECT * FROM GLOBA…

在java中的交换方法有哪些_java中交换两个变量的值有哪几种方法,交换两个变量a和b的值...

java中交换两个变量的值有哪几种方法在Java中&#xff0c;有哪些方法可以交换两个变量的值&#xff0c;方法&#xff1a;1.定义临时变量2.没有必要定义临时变量3.使用位运算符(学习视频分享&#xff1a;java课程)代码示例&#xff1a;公共类SwapTest {公共静态void main(String…

java修改原有txt文件_(转)Java创建txt文件并进行读、写、修改操作

Creation date: 2007-12-18 - 下午06:48:45 */ public class ReadWriteFile { public static BufferedReader bufread; //指定文件路径和名称 private static String path "D:/suncity.txt"; private static File filename new File(path); private static String …

java暂停另一个线程_如何从另一个线程终止或暂停Rust线程?

对于终止和挂起线程&#xff0c;您可以使用通道 .外部终止在工作循环的每次迭代中&#xff0c;我们检查是否有人通过渠道通知我们 . 如果是&#xff0c;或者如果通道的另一端超出范围&#xff0c;我们就会打破循环 .use std::io::{self, BufRead};use std::sync::mpsc::{self, …

java 7 jboss_JBoss7 入门指南

1、下载地址&#xff1a; http://www.jboss.org/jbossas/downloads &#xff0c;下载Certified Java EE 6 Full Profile版本。2、解压 jboss-as-7.1.1.Final.zip 到 D:\programs。3、设置环境变量如下&#xff1a;系统变量->新建->变量名&#xff1a;JAVA_HOME C:\Java以…

java实现bloom filter_Java BloomFilter.add方法代码示例

import org.apache.hadoop.util.bloom.BloomFilter; //导入方法依赖的package包/类Overridepublic int run(String[] args) throws Exception {if (args.length ! 4) {System.err.println("Usage: Trainer ");return 1;}// Parse command line argumentsPath inputFi…

java系统项目分为哪五大层次?控制层_业务_一个项目中说系统分为表现层、控制层、逻辑层、DAO层和最终数据库五层架构-转...

表现层就是看到的东西&#xff0c;比如你现在看到的当前页面控制层就将你的请求从页面传到后台代码逻辑层就是处理你的请求的代码DAO层就是将数据存到数据库中的代码数据库就是数据库了&#xff0c;存东西用的&#xff0c;DAO层就是将访问数据库的代码&#xff0c;数据库层是数…

opc客户端读取数据品质是bad_听说看了这篇文章就彻底搞懂了什么是OPC(上)

从2000年初以来&#xff0c;我们就一直在使用OPC软件互操作性标准&#xff0c;而那些正准备踏入和想要踏入工业自动化领域的人们却对这些含义感到困惑。所以在本中&#xff0c;我将系统地为你梳理OPC知识。OPC首字母缩写词代表什么&#xff1f;问一个OPC老手&#xff0c;他们或…

java怎么将程序保存在桌面_在Java桌面应用程序中保留数据的最佳方法是什么?...

我的桌面应用程序中有一大堆Java对象,我试图决定将文件作为文件系统的最佳方式.我曾经有过一些想法&#xff1a;>使用DataOutputStream滚动我自己的串行器&#xff1a;这将给我最大的控制文件中的内容,但是以微量管理为代价.>使用ObjectOutputStream及其各种相关类的直接…

JAVA实现inotify一样的功能_WPF实现INotifyPropertyChanged

我已经设置了一个属性并实现了INotifyPropertyChanged像这样......public event PropertyChangedEventHandler PropertyChanged;public FlowProcess LastSelectedFlowProcess{get { return _lastSelectedFlowProcess; }set{_lastSelectedFlowProcess value;Notify("LastS…

php导入json文件_[php]导入超大json文件

前言在之前的文章《做一个twitter的插件玩玩》中&#xff0c;我做了一个批量删除推文(转发推文)的工具&#xff0c;该工具能够删除前3200条推文&#xff0c;但因为总数太多(4.3万条)&#xff0c;api接口不支持获取所有的推文&#xff0c;所以我采用了下载的方式&#xff0c;直接…