目录 简介 公平锁和非公平锁 ReentrantLock 构造方法 获得锁 释放锁 锁的调试 【重点】Lock和synchronized的区别 简介 当多个线程需要访问某个公共资源的时候，我们知道需要通过加锁来保证资源的访问不会出问题。java提供了两种方式来加锁： 一种是关键字：synchronized，一种是concurrent包下的lock锁。 synchronized是java底层支持的，而concurrent包则是jdk实现。 公平锁和非公平锁 当有线程竞争锁时，当前线程会首先尝试获...

引出 读写锁的设计主要参考读写锁的设计模式：https://blog.csdn.net/qq_43040688/article/details/105857920 使用 public class ReadWriteLockTest { private static final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true); private static final Lock readLock = lock.readLock(); private static final Lock ...

目录 引出 初步使用 问题解答 第一个问题 第二个问题 第三个问题 wait和await的区别 等待队列 总结 利用Condition实现生产者和消费者 与 ReentrantLock的关系 总结 引出 在使用Lock之前，我们使用的最多的同步方式应该是synchronized关键字来实现同步方式了。配合Object的wait()、notify()系列方法可以实现等待/通知模式。 Condition接口也提供了类似Object的监视器方法，与Lock配合可以实现等待/通知模式，但是这两者在使用方...

引出 如果我们深入分析ReadWriteLock，会发现它有个潜在的问题：如果有线程正在读，写线程需要等待读线程释放锁后才能获取写锁，即读的过程中不允许写，这是一种悲观的读锁。 要进一步提升并发执行效率，Java 8引入了新的读写锁：StampedLock。 出现的问题：如果有999个需要读锁，1个需要写锁，此时，写的线程，很难得到执行。 StampedLock和ReadWriteLock相比，改进之处在于：读的过程中也允许获取写锁后写入！这样一来，我们读的数据就可能不一致，所以，需要一点额外的代码来判断读的过程中是否有写入，这种读锁是一种乐观锁。 乐观锁的意思就是乐观地估计读的过程...

引入 在Java高并发场景下，主要使用是三种锁synchronized、StampedLock、Lock 比较 synchronized StampedLock Lock 是JVM的的内置锁，每个JDK版本都会优化 是一个Java类，可以更好的扩展 是一个Java类，可以更好的扩展 都是悲观锁 提供了写的乐观锁 都是悲观锁，但是提供了自旋锁，或者不阻塞的获取锁 性能一般，因为有一个从用户态到内核态的过程 性能最好，可以代替读写...

简介 从JDK1.7开始，Java提供ForkJoin框架用于并行执行任务，它的思想就是：将一个大任务分割成若干小任务，最终汇总每个小任务的结果得到这个大任务的结果。 整个流程需要三个类完成： 1、ForkJoinPool 既然任务是被逐渐的细化的，那就需要把这些任务存在一个池子里面，这个池子就是ForkJoinPool。 它与其它的ExecutorService区别主要在于它使用“工作窃取“，那什么是工作窃取呢？ 一个大任务会被划分成无数个小任务，这些任务被分配到不同的队列，这些队列有些干活干的块，有些干得慢。于是干得快的，一看自己没任务需要执行了，就去隔壁的队列里面拿去任务执行...

目录 简介 简单的使用 重复使用的例子 动态减少 API 重要API 注册 到达 不再等待机制 监控子线程任务 强制关闭 调试API 获取阶段数 获取注册的数 获得到达和未到达的数目 总结 简介 java7中引入了一种新的可重复使用的同步屏障,称为移相器Phaser。Phaser拥有与CyclicBarrier和CountDownLatch类似的功劳. 但是这个类提供了更加灵活的应用。CountDownLatch和CyclicBarr...

目录 引出 线程池创建的参数 测试 测试代码 结果 结论： 线程池的阻塞队列的选择？ 拒绝策略 关闭 shutdown shutdownNow 守护线程 一个关闭的陷阱 API 关闭核心线程 更改线程池核心参数 创建初始线程 清空阻塞队列 引出 摘自阿里巴巴开发手册： 【强制】线程池不允许使用 Executors 去创建，而是通过 ThreadPoolExecutor 的方式，这样 的处理方式让写的同学更加明确线程池的运行规则...

这里写目录标题 简介 newCachedThreadPool newFixedThreadPool newSingleThreadExecutor newWorkStealingPool newScheduledThreadPool 简介 Java通过Executors提供五种线程池，分别为： newCachedThreadPool：创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。 newFixedThreadPool：创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。 ne...

目录 简介 API讲解 关闭 执行一个方法 执行一批方法 调试方式 判断线程池是否终结 判断是否执行了终结方法 简介 这是个接口，扩展了Executor接口，他有四个实现类： AbstractExecutorService ForkJoinPool ScheduledThreadPoolExecutor ThreadPoolExecutor API讲解 关闭 void shutdown() List<Runnable> shutdown...

简介 这个思想来源于Future设计模式：https://blog.csdn.net/qq_43040688/article/details/105868293 public interface Callable<V> { V call() throws Exception; } 可以看到，这是一个泛型接口，该接口声明了一个名称为call()的方法，同时这个方法可以有返回值V，也可以抛出异常。call()方法返回的类型就是传递进来的V类型。 那么怎么使用Callable呢？一般情况下是配合ExecutorService来使用的，在ExecutorServ...

Future的缺点 虽然Future可以异步的执行任务，但是还是有很多缺点： 没有办法回调，需要手动的调用 执行一组任务需要等待所有的任务执行完 CompletionService简介 CompletionService的实现目标是任务先完成可优先获取到，即结果按照完成先后顺序排序。 ExecutorCompletionService类，该类只有三个成员变量： public class ExecutorCompletionService<V> implements CompletionService<V> { private final...

目录 引入 简介 简单实用 创建CompleableFuture supplyAsync举例 runAsync举例 anyOf 举例 组合方法 组合两个任务，同时处理两个结果 组合两个任务，任务完成后做的操作 当两个任务任意一个执行完成后，执行一个操作 组合两个任务，处理后，返回一个结果 合并两个任务，第一个任务的输出是第二个任务的输入 中转方法 有返回值 当执行完成时执行的操作 级联操作 ...

Redis是什么 开源 基于键值的存储服务系统 多种数据结构 高性能、功能丰富 Redis的特性 速度快 持久化 多种数据结构 支持多种编程语言 主从复制 高可用、分布式 速度快 读写性能优异， Redis能读的速度是110000次/s，写的速度是81000次/s。 原因： 数据是存放在内存中（主要原因） 使用C语言实现 使用单线程的线程模型 持久化（断电数据不丢失） Redis将所有的数据保存在内存中，对数据的更新将异步的保存在磁盘中，支持AOF和RDB两种持久化方式。 多种数据结构 除了支持st...