当前位置: 首页 > news >正文

003 ++ --

文章目录

    • ++ --
    • 为了解决这个问题,你可以使用 synchronized 关键字来确保每次只有一个线程可以访问 increment() 方法:
    • 或者,你也可以使用 AtomicInteger,这是一个线程安全的整数类:
    • 乐观锁

++ –

在Java中,++ 和 – 操作符并不是线程安全的。这意味着,如果在多线程环境中直接对这些操作符进行并发操作,可能会导致数据的不一致。


public class Counter {  private int count = 0;  public void increment() {  count++;  }  public int getCount() {  return count;  }  
}

如果有两个线程同时调用 increment() 方法,并且都读取了 count 的值(比如都是0),然后都对其加1,那么两个线程可能都会将 count 设置为1,而不是期望的2。这就是所谓的竞态条件(Race Condition),它导致了数据的不一致。

为了解决这个问题,你可以使用 synchronized 关键字来确保每次只有一个线程可以访问 increment() 方法:


public class Counter {  private int count = 0;  public synchronized void increment() {  count++;  }  public synchronized int getCount() {  return count;  }  
}

或者,你也可以使用 AtomicInteger,这是一个线程安全的整数类:

import java.util.concurrent.atomic.AtomicInteger;  public class Counter {  private AtomicInteger count = new AtomicInteger(0);  public void increment() {  count.incrementAndGet();  }  public int getCount() {  return count.get();  }  
}

在这两种情况下,你都可以确保在多线程环境中对 count 的操作是线程安全的

在Java中,++ 和 – 操作符本身并不具备线程安全性。线程安全性意味着在并发环境中,对共享数据的操作不会导致数据不一致或其他未定义的行为。++ 和 – 操作符的不安全性主要源于它们包含多个步骤,这些步骤在多线程环境中可能被其他线程的操作打断,从而导致数据竞争(data race)和竞态条件(race condition)。

具体来说,count++(或 count–)这样的操作实际上包含了三个步骤:

读取 count 的当前值。
对该值进行加1(或减1)操作。
将新值写回到 count。
在单线程环境中,这三个步骤是顺序执行的,因此不会出现问题。但在多线程环境中,如果有多个线程同时执行这些步骤,就可能发生以下情况:

两个线程可能几乎同时读取 count 的值,导致它们获取到相同的初始值。
然后,这两个线程可能都会对这个值进行加1(或减1)操作,并试图将结果写回 count。
最终,count 的值只会增加1(或减少1),而不是期望的增加2(或减少2),因为两个线程的操作互相覆盖了。
这种情况就是典型的竞态条件,它导致了数据的不一致性。

为了解决这个问题,需要确保对 count 的操作是原子的,即这些操作在执行过程中不会被其他线程打断。Java提供了几种方法来实现这一点:

使用 synchronized 关键字来同步方法或代码块,确保在同一时间只有一个线程可以执行这些操作。
使用Java的 java.util.concurrent.atomic 包中的原子类,如 AtomicInteger,这些类提供了线程安全的原子操作。
通过这些方法,可以确保在多线程环境中对共享数据的操作是线程安全的,从而避免数据竞争和竞态条件的发生。

乐观锁


import java.util.concurrent.atomic.AtomicStampedReference;  public class OptimisticLockCounter {  private AtomicStampedReference<Integer> countRef;  private static final int INITIAL_VALUE = 0;  private static final int INITIAL_STAMP = 0;  public OptimisticLockCounter() {  countRef = new AtomicStampedReference<>(INITIAL_VALUE, INITIAL_STAMP);  }  public boolean increment() {  int[] stampHolder = new int[1];  Integer oldValue, newValue;  do {  oldValue = countRef.get(stampHolder); // 获取当前值和邮戳  newValue = oldValue + 1; // 计算新值  // 尝试在邮戳未更改的情况下设置新值  } while (!countRef.compareAndSet(oldValue, newValue, stampHolder[0], stampHolder[0] + 1));  return true; // 如果成功更新,则返回true  }  public boolean decrement() {  int[] stampHolder = new int[1];  Integer oldValue, newValue;  do {  oldValue = countRef.get(stampHolder); // 获取当前值和邮戳  newValue = oldValue - 1; // 计算新值  // 尝试在邮戳未更改的情况下设置新值  } while (!countRef.compareAndSet(oldValue, newValue, stampHolder[0], stampHolder[0] + 1));  return true; // 如果成功更新,则返回true  }  public int getCount() {  return countRef.getReference(); // 获取当前计数值  }  // 新增一个尝试获取当前计数值和邮戳的方法,便于测试  public int[] getCountAndStamp() {  return new int[]{countRef.getReference(), countRef.getStamp()};  }  
}
http://www.lryc.cn/news/354980.html

相关文章:

  • DDR、LPDDR和GDDR的区别
  • 【附代码】@hydra.main 没有返回值,如何解决函数返回?
  • js深入理解对象的 属性(properties)的特殊 特性(attributes)
  • 【MATLAB】去除趋势项(解决频谱图大部分为零的问题)
  • jmeter发送webserver请求和上传请求
  • 如何看centos 有没有安装x11
  • 超详细的前后端实战项目(Spring系列加上vue3)前后端篇(四)(一步步实现+源码)
  • 决策树|随机森林 GBDT XGBoost|集成学习
  • 【C语言实现TCP通信】
  • 黑马点评-短信登录
  • CentOS7 部署单机版 elasticsearch
  • Mujoco仿真【xml文件的学习 4】
  • vue数据持久化仓库
  • OrangePi AIpro评测 - 基础操作篇
  • 不含一阶导数项的线性二阶微分方程的通解
  • Redis篇 String
  • 【vue-2】v-on、v-show、v-if及按键修饰符
  • 华为交换机基础实验----VLAN基础
  • Vue3学习使用axios和qs进行POST请求和响应处理
  • 张大哥笔记:赚钱高手养成计划---如何将一份时间产生N份收入?
  • excel里如何将数据分组转置?
  • WHAT - 前端安全性测试和常见攻击手段
  • 重量and体积,不要在傻傻的花冤枉钱寄快递了!
  • docker ps显示的参数具体是什么意思
  • 【C++】多态:编程中的“一人千面”艺术
  • 【必备工具】gitee上传-保姆级教程
  • P1115 最长子段和
  • 02 FreeRTOS 任务
  • NSS题目练习4
  • 【算法】合并k个已排序的链表