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

舟山公司网站建设网络营销企业有哪些公司

舟山公司网站建设,网络营销企业有哪些公司,h5页面制作工具易企秀,做直播 网站的上市公司1. CAS 1.1 CAS 原理 CAS(Compare-And-Swap)即比较并交换,是一种无锁算法,用于实现多线程环境下的原子操作。它是一种乐观锁的实现方式,其核心思想是:假设数据在没有被其他线程修改的情况下进行操作&…

1. CAS

1.1 CAS 原理

CAS(Compare-And-Swap)即比较并交换,是一种无锁算法,用于实现多线程环境下的原子操作。它是一种乐观锁的实现方式,其核心思想是:假设数据在没有被其他线程修改的情况下进行操作,如果发现数据被修改了,则重新尝试操作,直到成功为止。

CAS 操作包含三个操作数:内存位置(V)、预期原值(A)和新值(B)。当且仅当内存位置 V 的值等于预期原值 A 时,才将该位置的值更新为新值 B;否则,不做任何操作。整个操作是原子性的,由硬件层面来保证。

在 Java 中,java.util.concurrent.atomic 包下的原子类就是基于 CAS 实现的,例如 AtomicIntegerAtomicLong 等。

1.2 使用示例

使用 AtomicInteger 进行自增操作

import java.util.concurrent.atomic.AtomicInteger;public class CASAtomicIntegerExample {public static void main(String[] args) {// 创建一个 AtomicInteger 对象,初始值为 0AtomicInteger atomicInteger = new AtomicInteger(0);// 创建两个线程,每个线程对 atomicInteger 进行 1000 次自增操作Thread t1 = new Thread(() -> {for (int i = 0; i < 1000; i++) {atomicInteger.incrementAndGet();}});Thread t2 = new Thread(() -> {for (int i = 0; i < 1000; i++) {atomicInteger.incrementAndGet();}});// 启动线程t1.start();t2.start();try {// 等待两个线程执行完毕t1.join();t2.join();} catch (InterruptedException e) {e.printStackTrace();}// 输出最终结果System.out.println("Final value: " + atomicInteger.get());}
}

解释

  • AtomicInteger 是 Java 提供的一个原子整数类,它内部使用 CAS 机制来保证对整数的操作是原子的。

  • incrementAndGet() 方法会原子地将 AtomicInteger 的值加 1,并返回加 1 后的值。

  • 在多线程环境下,多个线程可以同时调用 incrementAndGet() 方法,而不会出现数据不一致的问题。

1.3 CAS 的局限性

  • ABA 问题:CAS 操作只关注值是否相等,而不关心值的变化过程。如果一个值从 A 变为 B,再从 B 变回 A,CAS 操作会认为值没有发生变化,从而继续进行更新操作。可以使用 AtomicStampedReference 或 AtomicMarkableReference 来解决 ABA 问题。

  • 循环时间长开销大:如果 CAS 操作长时间不成功,会导致线程不断地进行自旋,从而消耗大量的 CPU 资源。

  • 只能保证一个共享变量的原子操作:CAS 只能保证对一个共享变量的原子操作,如果需要对多个共享变量进行原子操作,需要使用锁或其他同步机制。

2. AQS

AQS(AbstractQueuedSynchronizer)是 Java 并发包(java.util.concurrent)中用于构建锁和同步器的基础框架。许多 Java 并发工具类,如 ReentrantLockCountDownLatchSemaphore 等都是基于 AQS 实现的。

1.1 核心组成部分

  • 同步状态(state):一个 int 类型的变量,用于表示同步状态。不同的同步器可以根据这个状态来实现不同的同步逻辑。例如,在 ReentrantLock 中,state 为 0 表示锁未被持有,大于 0 表示锁已经被持有,并且数值表示重入的次数。

  • 队列(CLH 队列的变种):一个双向链表,用于管理那些获取同步状态失败的线程。当一个线程尝试获取同步状态失败时,会被封装成一个节点加入到队列的尾部,进入等待状态。当持有同步状态的线程释放状态后,会从队列的头部唤醒一个等待线程。

  • CAS(Compare-And-Swap)操作:用于保证对 state 变量的原子性修改。CAS 操作是一种无锁算法,通过比较内存中的值和预期值是否相等,如果相等则将内存中的值更新为新值。

1.2 工作流程

  • 获取同步状态:线程尝试通过 tryAcquire 方法获取同步状态,如果获取成功,则继续执行;如果获取失败,则将该线程封装成节点加入到等待队列中,并进入阻塞状态。

  • 释放同步状态:线程通过 tryRelease 方法释放同步状态,释放成功后,会从队列的头部唤醒一个等待线程。

  • 队列管理:当有新的线程获取同步状态失败时,会将其封装成节点加入到队列的尾部;当持有同步状态的线程释放状态后,会从队列的头部唤醒一个等待线程。

1.3 自定义同步器示例 

通过一个自定义同步器来演示 AQS 的使用,实现一个简单的独占锁。

import java.util.concurrent.locks.AbstractQueuedSynchronizer;// 自定义同步器
class MySync extends AbstractQueuedSynchronizer {// 尝试获取锁@Overrideprotected boolean tryAcquire(int arg) {// 使用 CAS 操作尝试将状态从 0 变为 1if (compareAndSetState(0, 1)) {// 设置当前线程为独占线程setExclusiveOwnerThread(Thread.currentThread());return true;}return false;}// 尝试释放锁@Overrideprotected boolean tryRelease(int arg) {// 检查当前线程是否为独占线程if (getExclusiveOwnerThread() != Thread.currentThread()) {throw new IllegalMonitorStateException();}// 将状态设置为 0setState(0);// 清除独占线程setExclusiveOwnerThread(null);return true;}// 判断是否处于锁定状态@Overrideprotected boolean isHeldExclusively() {return getState() == 1;}
}// 自定义独占锁
class MyLock {private final MySync sync = new MySync();// 加锁public void lock() {sync.acquire(1);}// 解锁public void unlock() {sync.release(1);}// 判断是否锁定public boolean isLocked() {return sync.isHeldExclusively();}
}// 测试类
public class AQSExample {public static void main(String[] args) {MyLock lock = new MyLock();// 线程 1 尝试获取锁Thread thread1 = new Thread(() -> {lock.lock();try {System.out.println("Thread 1 acquired the lock.");Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();System.out.println("Thread 1 released the lock.");}});// 线程 2 尝试获取锁Thread thread2 = new Thread(() -> {lock.lock();try {System.out.println("Thread 2 acquired the lock.");} finally {lock.unlock();System.out.println("Thread 2 released the lock.");}});thread1.start();thread2.start();try {thread1.join();thread2.join();} catch (InterruptedException e) {e.printStackTrace();}}
}

解释

  • MySync 类:继承自 AbstractQueuedSynchronizer,并重写了 tryAcquiretryRelease 和 isHeldExclusively 方法。

    • tryAcquire:尝试获取锁,使用 CAS 操作将状态从 0 变为 1,如果成功则将当前线程设置为独占线程。

    • tryRelease:尝试释放锁,检查当前线程是否为独占线程,如果是则将状态设置为 0,并清除独占线程。

    • isHeldExclusively:判断当前是否处于锁定状态。

  • MyLock 类:封装了 MySync 对象,提供了 lockunlock 和 isLocked 方法。

    • lock:调用 sync.acquire(1) 方法获取锁。

    • unlock:调用 sync.release(1) 方法释放锁。

    • isLocked:调用 sync.isHeldExclusively() 方法判断是否锁定。

  • AQSExample 类:创建了两个线程,分别尝试获取和释放锁,演示了自定义锁的使用。

注意事项

  • 在使用 AQS 时,需要根据具体需求重写 tryAcquiretryRelease 等方法,确保同步状态的正确管理。

  • AQS 提供了公平锁和非公平锁的实现,需要根据具体场景选择合适的锁策略。

http://www.dtcms.com/wzjs/296797.html

相关文章:

  • 怎么做淘宝客网站和APP品牌推广方式都有哪些
  • wordpress创建三级分类抚顺优化seo
  • sharepoint网站制作下载一个百度时事新闻
  • 阜阳网站建设阜阳广告公司取名字参考大全
  • 建手机网站要多少钱广东省疫情最新
  • 包装设计网站官网搜索关键词网站
  • 网站建设功免费b站推广网站短视频
  • 社区网站的建设镇江关键字优化公司
  • szfob外贸论坛首页搜索引擎优化管理实验报告
  • flash美食网站论文分类信息网站平台有哪些
  • 做网站基本语言摘抄一小段新闻
  • 做网站公奇闻司郑州汉狮网络营销未来有哪些发展趋势
  • 网站开发运营新人要注意什么网络推广seo教程
  • 网站开发3687474企鹅个人推广app的妙招
  • 做结构设计有没有自学的网站bing搜索引擎
  • 一起来做网站什么是软文文案
  • 织梦网站建设流程全网营销整合营销
  • 中低端网站建设客户网免费推广网
  • 怎么制作微信购物网站网站排名优化价格
  • 飘雪影视在线观看免费观看西瓜上海网站快速排名优化
  • 怎样做百度网站推广网站搜索关键词优化
  • 群艺馆网站建设方案关键词热度分析工具
  • 海外打开网站慢推广引流网站
  • 企业管理系统数据库设计秦皇岛seo排名
  • 河南企起网站建设首页关键词怎么排名靠前
  • 网站有二级域名做竞价代运营套餐价格表
  • 上海网站建设浦东搜索引擎网站入口
  • 洋气的文化传媒公司名字绍兴seo网站优化
  • 温州做网站制作哪家好百度投放广告流程
  • 网络推广员的日常工作seo工具有哪些