并发编程核心技术解析-CSDN博客

本文链接：https://blog.csdn.net/CodeJavaPro/article/details/149713715

📕我是廖志伟，一名Java开发工程师、《Java项目实战——深入理解大型互联网企业通用技术》（基础篇）、（进阶篇）、（架构篇）、《解密程序员的思维密码——沟通、演讲、思考的实践》作者、清华大学出版社签约作家、Java领域优质创作者、CSDN博客专家、阿里云专家博主、51CTO专家博主、产品软文专业写手、技术文章评审老师、技术类问卷调查设计师、幕后大佬社区创始人、开源项目贡献者。

📘拥有多年一线研发和团队管理经验，研究过主流框架的底层源码(Spring、SpringBoot、SpringMVC、SpringCloud、Mybatis、Dubbo、Zookeeper)，消息中间件底层架构原理(RabbitMQ、RocketMQ、Kafka)、Redis缓存、MySQL关系型数据库、 ElasticSearch全文搜索、MongoDB非关系型数据库、Apache ShardingSphere分库分表读写分离、设计模式、领域驱动DDD、Kubernetes容器编排等。

📙不定期分享高并发、高可用、高性能、微服务、分布式、海量数据、性能调优、云原生、项目管理、产品思维、技术选型、架构设计、求职面试、副业思维、个人成长等内容。

Java程序员廖志伟

💡在这个美好的时刻，笔者不再啰嗦废话，现在毫不拖延地进入文章所要讨论的主题。接下来，我将为大家呈现正文内容。

CSDN

一、并发编程知识体系

并发编程是计算机科学中的一个重要领域，它涉及如何让多个任务同时执行，以提高程序的性能和响应速度。以下是对并发编程知识体系的详细描述，并添加了技术实现细节。

线程基础

线程是并发编程的基本单位，它是程序中执行任务的最小单元。以下是线程的一些基础知识：

线程生命周期：线程的生命周期包括创建（Thread.start()）、就绪（线程等待CPU调度）、运行（CPU执行线程代码）、阻塞（线程等待某些条件满足）、等待（线程主动等待其他线程或条件）、超时（线程等待时间超过设定值）、终止（线程执行完毕或被终止）等状态。在Java中，线程的生命周期管理依赖于线程调度器，调度器负责根据线程优先级和线程状态进行线程的切换。
线程优先级：线程优先级决定了线程在调度器中的优先级，高优先级的线程有更高的执行机会。在Java中，线程优先级分为1（最低）到10（最高），默认优先级为5。线程优先级并不保证线程一定能够获得更多的执行时间，而是影响线程调度器的决策。
守护线程：守护线程是服务其他线程的线程，当没有非守护线程运行时，守护线程也会终止。在Java中，可以通过调用Thread.setDaemon(true)将线程设置为守护线程。
线程池：线程池是一组线程的集合，它可以重用这些线程来执行多个任务，提高性能。线程池通常由核心线程数、最大线程数、存活时间、工作队列等参数配置。在Java中，可以使用Executors工厂类创建线程池，例如Executors.newFixedThreadPool(int nThreads)创建固定大小的线程池。

核心参数配置、拒绝策略、工作队列类型

核心参数配置：线程池的核心参数配置包括核心线程数、最大线程数、存活时间、工作队列等。核心线程数决定了线程池的最小线程数，最大线程数决定了线程池的最大线程数。存活时间决定了线程空闲多长时间后会被回收。工作队列用于存储等待执行的任务，常见的有数组阻塞队列、链表阻塞队列等。
拒绝策略：当线程池达到最大容量时，拒绝策略决定如何处理新提交的任务。常见的拒绝策略有AbortPolicy（抛出异常）、CallerRunsPolicy（调用者运行）、DiscardPolicy（丢弃任务）、DiscardOldestPolicy（丢弃最旧的任务）。
工作队列类型：工作队列用于存储等待执行的任务，常见的有数组阻塞队列、链表阻塞队列等。数组阻塞队列基于数组实现，适用于任务数量较少的场景；链表阻塞队列基于链表实现，适用于任务数量较多的场景。

同步机制

同步机制确保多个线程在访问共享资源时不会相互干扰，以下是几种常见的同步机制：

悲观锁/乐观锁：悲观锁假设冲突不可避免，因此会锁定资源直到事务完成；乐观锁则假设冲突很少发生，通过版本号或时间戳来检测冲突。在Java中，可以使用synchronized关键字实现悲观锁，使用乐观锁可以使用原子类或CAS操作。
读写锁：读写锁允许多个线程同时读取资源，但只允许一个线程写入资源。在Java中，可以使用ReentrantReadWriteLock实现读写锁。
条件变量：条件变量允许线程在某个条件不满足时等待，直到条件满足时被唤醒。在Java中，可以使用Object.wait()和Object.notify()方法实现条件变量。

并发集合

并发集合是专门为并发环境设计的集合类，以下是几种常见的并发集合：

ConcurrentHashMap：ConcurrentHashMap采用分段锁技术，将数据分为多个段，每个段有自己的锁，从而提高并发访问性能。
CopyOnWrite容器：CopyOnWrite容器在写操作时复制整个容器，读操作时访问原容器，适用于读多写少的场景。在Java中，可以使用CopyOnWriteArrayList实现CopyOnWrite容器。
BlockingQueue：BlockingQueue支持线程间的生产者-消费者模型，当队列满时，生产者线程会等待；当队列空时，消费者线程会等待。在Java中，可以使用ArrayBlockingQueue、LinkedBlockingQueue等实现BlockingQueue。

并发工具类

Phaser：Phaser用于协调多个线程的执行，支持动态添加参与者。在Java中，可以使用Phaser的构造函数创建Phaser实例，并使用Phaser.arriveAndAwaitAdvance()方法协调线程执行。
Exchanger：Exchanger允许两个线程交换数据。在Java中，可以使用Exchanger的构造函数创建Exchanger实例，并使用Exchanger.exchange(Object x)方法交换数据。
FutureTask：FutureTask表示异步计算的结果。在Java中，可以使用FutureTask的构造函数创建FutureTask实例，并使用FutureTask.get()方法获取异步计算的结果。

非阻塞算法

非阻塞算法利用了原子操作和内存屏障等机制，以下是一些非阻塞算法：

CAS原理：Compare-And-Swap，通过原子操作保证操作的原子性。在Java中，可以使用Atomic类提供原子操作，如AtomicInteger、AtomicLong等。
Atomic类：提供原子操作的类，如AtomicInteger、AtomicLong等。这些类提供了各种原子操作方法，例如compareAndSet、getAndIncrement等。
无锁队列：基于CAS原理实现的无锁队列。无锁队列在多线程环境下可以高效地进行插入和删除操作，而不需要使用锁机制。

并发框架

Netty线程模型：Netty使用主从多线程模型，一个Boss线程负责接收客户端连接，多个Worker线程负责处理业务逻辑。这种模型可以提高网络应用程序的并发性能。
Akka Actor模型：Akka使用Actor模型，每个Actor都是一个独立的消息处理器。Actor模型可以简化并发编程，提高系统的可扩展性和容错性。
Disruptor环形缓冲区：Disruptor使用环形缓冲区，通过发布/订阅模式实现高效的并发数据交换。环形缓冲区可以减少锁的使用，提高并发性能。

二、MyBatis知识体系

MyBatis是一个优秀的持久层框架，它支持定制化SQL、存储过程以及高级映射。以下是MyBatis知识体系的详细描述，并添加了技术实现细节。

SQL映射

注解映射：使用注解定义SQL映射，简化配置。在MyBatis中，可以使用@Select、@Insert、@Update、@Delete等注解定义SQL映射。
结果集映射：定义实体类与数据库表之间的映射关系。在MyBatis中，可以使用@Results、@Result等注解定义结果集映射。
关联查询：处理多表关联查询，如一对多、多对多等。在MyBatis中，可以使用@One、@Many等注解定义关联查询。

动态SQL

OGNL表达式：使用OGNL表达式构建动态SQL语句。OGNL表达式是一种表达式语言，可以用于动态构建SQL语句。
分支语句：根据条件动态选择不同的SQL片段。在MyBatis中，可以使用、等标签实现分支语句。
批量操作：支持批量插入、更新、删除等操作。在MyBatis中，可以使用标签实现批量操作。

缓存机制

一级缓存：本地缓存，用于缓存SQL语句的结果集。在MyBatis中，一级缓存默认开启，可以通过设置标签禁用一级缓存。
二级缓存：应用级缓存，用于缓存实体对象。在MyBatis中，可以使用标签配置二级缓存。
自定义缓存：自定义缓存实现，满足特定需求。在MyBatis中，可以实现Cache接口自定义缓存。
代理模式：使用代理模式实现缓存的透明化。在MyBatis中，使用Cglib代理技术实现缓存的透明化。

MapperProxy插件拦截动态代理执行流程

MapperProxy：MyBatis的动态代理实现，用于代理Mapper接口。在MyBatis中，使用Cglib代理技术实现MapperProxy。
插件拦截：通过拦截器机制扩展MyBatis功能。在MyBatis中，可以使用Interceptor接口实现拦截器。
动态代理执行流程：Mapper接口调用过程，包括代理、拦截器、SQL构建、执行等环节。

SqlSession生命周期

SqlSession：MyBatis的核心接口，用于执行数据库操作。在MyBatis中，SqlSession负责管理数据库连接、事务等。
生命周期：SqlSession的创建、使用、提交、回滚、关闭等阶段。在MyBatis中，SqlSession通常在SqlSessionFactory中创建，并使用try-with-resources语句自动关闭。

执行器类型

执行器：MyBatis中负责执行SQL语句的组件，包括简单执行器、批处理执行器、分页执行器等。在MyBatis中，可以使用ExecutorType枚举指定执行器类型。

延迟加载扩展机制

延迟加载：在需要时才加载关联数据，提高性能。在MyBatis中，可以使用@Lazy注解实现延迟加载。
扩展机制：自定义加载策略，满足特定需求。在MyBatis中，可以实现LazyLoader接口自定义延迟加载策略。

类型处理器、拦截器链、方言支持

类型处理器：将数据库类型转换为Java类型。在MyBatis中，可以使用TypeHandler接口实现类型处理器。
拦截器链：拦截器按照顺序执行，实现扩展功能。在MyBatis中，可以使用Interceptor接口实现拦截器。
方言支持：支持不同的数据库方言，如MySQL、Oracle等。在MyBatis中，可以使用标签定义方言，并在MyBatis配置文件中指定方言。

CSDN

博主分享

📥博主的人生感悟和目标

Java程序员廖志伟

📙经过多年在CSDN创作上千篇文章的经验积累，我已经拥有了不错的写作技巧。同时，我还与清华大学出版社签下了四本书籍的合约，并将陆续出版。

《Java项目实战—深入理解大型互联网企业通用技术》基础篇的购书链接：https://item.jd.com/14152451.html
《Java项目实战—深入理解大型互联网企业通用技术》基础篇繁体字的购书链接：http://product.dangdang.com/11821397208.html
《Java项目实战—深入理解大型互联网企业通用技术》进阶篇的购书链接：https://item.jd.com/14616418.html
《Java项目实战—深入理解大型互联网企业通用技术》架构篇待上架
《解密程序员的思维密码--沟通、演讲、思考的实践》购书链接：https://item.jd.com/15096040.html

面试备战资料

八股文备战

场景	描述	链接
时间充裕（25万字）	Java知识点大全（高频面试题）	Java知识点大全
时间紧急（15万字）	Java高级开发高频面试题	Java高级开发高频面试题

理论知识专题（图文并茂，字数过万）

技术栈	链接
RocketMQ	RocketMQ详解
Kafka	Kafka详解
RabbitMQ	RabbitMQ详解
MongoDB	MongoDB详解
ElasticSearch	ElasticSearch详解
Zookeeper	Zookeeper详解
Redis	Redis详解
MySQL	MySQL详解
JVM	JVM详解

集群部署（图文并茂，字数过万）

技术栈	部署架构	链接
MySQL	使用Docker-Compose部署MySQL一主二从半同步复制高可用MHA集群	Docker-Compose部署教程
Redis	三主三从集群（三种方式部署/18个节点的Redis Cluster模式）	三种部署方式教程
RocketMQ	DLedger高可用集群（9节点）	部署指南
Nacos+Nginx	集群+负载均衡（9节点）	Docker部署方案
Kubernetes	容器编排安装	最全安装教程