HashMap 前述 HashMap是基于 散列表来实现的 为什么要引入散列表这个结构？ 传统的数组：索引快，但有大小限制，且动态增删耗性能 传统的链表：动态扩容，增删容易，但是索引慢 散列表的出现，便是 整合了数组与链表的优势！ 而散列表又是和 Hash密切相关着的. Hash 也称哈希，散列，基本原理就是将任意长度内的输入，通过哈希算法，转换为 固定长度内的输出. 特点： 不能从 hash值反向推导出原始数据 原始数据的微小变化会得到完全不同的 hash值，相同的数据会得到相同的值 哈希算法的执行效率要高效，长…
CyclicBarrier 循环屏障 适用场景：多个线程之间相互等待 源码 构造 public CyclicBarrier(int parties) { this(parties, null); } /** * parites: barrier需要参与的线程数量, 每次屏障需要参与的线程数 * barrierAction: 当前 "代"最后一个到位的线程, 需要执行的事件 (可以为 null) */ public CyclicBarrier(int parties, Runnable barri…
最近在看 CyclicBarrier的源码，这里先贴出个 CyclicBarrier的 demo，之后会来更新 CyclicBarrier的源码 源码真的很重要，从源码层面理解了其工作原理，不仅能加深你对并发领域组件的设计的理解，而且在实际使用时能够减少一些 "坑" /** * 模拟王者荣耀 */ public class MyCyclicBarrierDemo { public static void main(String[] args) { String[] names = new Str…
无意间看到此面试题，就临时写了几种写法，信号量的暂时还没去使用，待补充日后 /** * 使用共享变量及其 volatile */ public class Demo { volatile static int state = 0; public static void main(String[] args) { new Thread(() -> { while (true) { if (state % 3 == 0) { System.out.println(1); state ++; } } }).star…
MiniReentrantLock package aqs; import sun.misc.Unsafe; import java.lang.reflect.Field; import java.util.concurrent.locks.AbstractQueuedSynchronizer; import java.util.concurrent.locks.LockSupport; public class MiniReentrantLock implements Lock{ /** * 锁的是资源 --&g…
happens-before JMM设计的核心目标：① 为程序员提供足够强的内存可见性保证 ② 对编译器和处理器的要求尽可能宽松一些 阐述操作之间的内存可见性 现在电脑都是多 CPU，并且都有缓存，这就导致了多线程直接的可见性问题 为了解决多线程的可见性问题，就衍生出来的 happens-before原则，让线程之间去遵守这些原则；其同时编译器和处理器会去优化我们编写的代码，这也是给了它们进行优化的约束. 在 JMM中，如果一个操作执行的结果需要对另一个操作可见，那么这两个操作之间必须要存在 happens-bef…
Condition 可以认为是一个等待队列 一个对象自带互斥锁，每一个对象维护着一个等待阻塞队列，这也是其问题所在 JDK5 时引入了 Condition 它将等待队列也做成了一个对象！ 比如说在生产者消费者问题中，为了保证数据安全问题 我们必要的时候将生产者和消费者都放进了同一个队列中 但现在，可以分开放！ 生产者放进了生产者队列，消费者放进消费者队列 使用 Condition实现生产者和消费者可以精确控制唤醒生产者还是消费者线程 而通过锁对象的 signal唤醒是等待队列中随机身份 -> 生产者、消费者 …
LongAdder /** * 对比下高并发下 LongAdder和AtomicLong的性能 */ public class LongAdderDemo { public static void main(String[] args) throws InterruptedException { LongAdderVSAtomicLong(1, 10000000); LongAdderVSAtomicLong(10, 10000000); LongAdderVSAtomicLong(20, 10000000); L…
AtomicInteger 基于CAS来实现线程安全的 public class AtomicInteger extends Number implements java.io.Serializable { private static final long serialVersionUID = 6214790243416807050L; // setup to use Unsafe.compareAndSwapInt for updates private static final Unsafe unsafe =…
信息存储 <dependency> <groupId>org.openjdk.jol</groupId> <artifactId>jol-core</artifactId> <version>0.9</version> </dependency> 查看synchronized记录的信息存在Mark Word中 public class JusTest { public static void main(String[] …
join 无限等待 等待线程的完成 Waiting for the finalization of a thread In some situations, we will have to wait for the finalization of a thread. For example, we may have a program that will begin initializing the resources it needs before proceeding with the rest of the …
Random
Video
Chinese (Simplified)
English
German
