做淘宝客网站的流程,网站从建设到运行要多少钱,wordpress文件调用函数,公司企业网站怎么建设什么是AQS? AQS#xff08;AbstractQueuedSynchronizer#xff09;是Java中用于实现锁和同步器的基础框架。它是一个抽象类#xff0c;提供了一种灵活且强大的方式来实现各种同步器#xff0c;如ReentrantLock、Semaphore、CountDownLatch等
AQS实现原理#xff1f;
1、…什么是AQS? AQSAbstractQueuedSynchronizer是Java中用于实现锁和同步器的基础框架。它是一个抽象类提供了一种灵活且强大的方式来实现各种同步器如ReentrantLock、Semaphore、CountDownLatch等
AQS实现原理
1、资源共享AQS 中定义了一个整型的 state 变量来表示同步状态该状态可以被多个线程共享根据该状态的不同值来表示不同的状态比如锁被占用或者可用。
等于0表示当前同步状态为空闲状态即没有线程占用资源。大于0通常表示当前同步状态被一个线程所占用且在信号量的应用中也可以表示可用资源数量。小于0一般表示当前同步状态已被某个线程占用数值表示等待获取资源的线程数量
2、模板方法AQS 提供了 acquire() 和 release() 两个模板方法具体的同步器只需实现这两个方法的逻辑即可。其中 acquire() 方法用于获取资源如果获取不到则会将当前线程加入等待队列release() 方法用于释放资源并唤醒等待队列中的其他线程。
3、等待队列AQS 使用一个双向链表来维护等待线程的队列队列中的线程按照先进先出的顺序来获取资源。当一个线程无法获取资源时会被加入到等待队列中并进入等待状态。
4、CAS 操作AQS 使用 CASCompare And Swap操作来对状态进行原子性地修改保证多线程并发操作时的数据一致性。
5、子类实现具体的同步器如 ReentrantLock、Semaphore 等需要继承 AQS并根据自身需求实现 acquire() 和 release() 方法来实现自定义的同步逻辑。
AQS的辅助类
Condition Condition条件是Java中用于线程之间通信的一种机制常用于对线程的等待和唤醒操作。Condition通常与Lock一起使用是Lock接口的一部分用于替代传统的Object的wait()和notify()/notifyAll()方法。在使用Condition时首先需要获得一个Lock对象然后通过Lock对象的newCondition()方法创建一个Condition对象。线程可以通过Condition的await()方法进入等待状态当其他线程调用Condition的signal()或者signalAll()方法时被等待的线程会被唤醒。使用Condition可以更加精细地控制线程的等待和唤醒而不像使用Object的wait()和notify()/notifyAll()方法那样具有局限性。
CountDownLatch减少计数 CountDownLatch 是 Java 中的一个同步工具类用于实现多个线程之间的同步通过减少计数的方式实现线程之间的等待和通知。
CountDownLatch 内部维护一个计数器通过 countDown() 方法递减计数通过 await() 方法阻塞调用线程直到计数器为 0。在初始化 CountDownLatch 时需要指定计数器的初始值每次调用 countDown() 方法都会使计数器减 1。当计数器减至 0 时所有在 await() 方法上阻塞的线程都会被唤醒可以继续执行后续操作。 举例风火雷电四大法王都能封印魔兽但是随着一个个法王的离开每次调用countDown()方法直至没有一个法王存在魔兽就会苏醒。
CyclicBarrier循环栅栏 CyclicBarrier循环栅栏是Java中的一个同步辅助工具用于在多个线程之间实现同步。它允许一组线程全部达到一个同步点后再继续执行。当所有线程达到同步点时CyclicBarrier会释放它们并重置以便可以被重复使用。 CyclicBarrier是通过指定一个计数值来初始化当调用await()方法时线程会等待直到所有参与者都调用了该方法此时所有线程会被释放并继续执行。CyclicBarrier的一个常见应用场景是将问题分解成多个子任务并行处理在每个子任务完成后使用CyclicBarrier来等待所有子任务完成后才继续执行其他操作。 举例召集七颗龙珠即可召唤神龙每当获取一颗龙珠会调用await()方法进行等待一直集齐七颗才能召唤神龙。
Semaphore信号灯 Semaphore信号量是一个用于控制对共享资源的访问的同步工具。它通常用于限制同时访问某个共享资源的线程数量或者进行线程之间的同步。在Java中Semaphore提供了一种计数信号量可以用来控制同时访问某个资源的线程数量也可以用来实现生产者-消费者模式。 Semaphore内部维护着一个计数器初始化时指定初始的许可数量线程可以通过acquire()方法获取许可如果计数器大于0则获取成功计数器减1通过release()方法释放许可计数器加1当计数器为0时acquire()方法会阻塞线程直到有其他线程释放许可。 举例六辆汽车三个停车位通过acquire()方法占用停车位通过release()方法离开停车位但是只能同时停三辆车。 ps以下是我整理的java面试资料密码是obht感兴趣的可以看看。最后创作不易觉得写得不错的可以点点关注
链接https://www.yuque.com/u39298356/uu4hxh?# 《Java面试宝典》
