📕我是廖志伟,一名Java开发工程师、《Java项目实战——深入理解大型互联网企业通用技术》(基础篇)、(进阶篇)、(架构篇)清华大学出版社签约作家、Java领域优质创作者、CSDN博客专家、阿里云专家博主、51CTO专家博主、产品软文专业写手、技术文章评审老师、技术类问卷调查设计师、幕后大佬社区创始人、开源项目贡献者。
📘拥有多年一线研发和团队管理经验,研究过主流框架的底层源码(Spring、SpringBoot、SpringMVC、SpringCloud、Mybatis、Dubbo、Zookeeper),消息中间件底层架构原理(RabbitMQ、RocketMQ、Kafka)、Redis缓存、MySQL关系型数据库、 ElasticSearch全文搜索、MongoDB非关系型数据库、Apache ShardingSphere分库分表读写分离、设计模式、领域驱动DDD、Kubernetes容器编排等。不定期分享高并发、高可用、高性能、微服务、分布式、海量数据、性能调优、云原生、项目管理、产品思维、技术选型、架构设计、求职面试、副业思维、个人成长等内容。

🌾阅读前,快速浏览目录和章节概览可帮助了解文章结构、内容和作者的重点。了解自己希望从中获得什么样的知识或经验是非常重要的。建议在阅读时做笔记、思考问题、自我提问,以加深理解和吸收知识。阅读结束后,反思和总结所学内容,并尝试应用到现实中,有助于深化理解和应用知识。与朋友或同事分享所读内容,讨论细节并获得反馈,也有助于加深对知识的理解和吸收。💡在这个美好的时刻,笔者不再啰嗦废话,现在毫不拖延地进入文章所要讨论的主题。接下来,我将为大家呈现正文内容。

一、并发编程知识体系
线程基础
线程的生命周期是一个复杂的过程,涉及多个状态。在Java中,线程的状态可以通过Thread类和Runtime类来获取。线程创建后,它首先进入新建状态(New),然后是可运行状态(Runnable),此时线程可能会被调度器选中执行。当线程执行完毕、发生异常或被阻塞时,它将进入阻塞状态(Blocked)或终止状态(Terminated)。线程优先级则通过Thread的getPriority()和setPriority()方法来获取和设置,优先级较高的线程有更高的执行机会。
守护线程在Java中通过设置线程为守护状态来实现,通常使用isDaemon()和setDaemon(true)方法。守护线程的结束不会影响主程序的运行,因此它们通常用于执行后台任务,如垃圾回收。
线程池是并发编程中的重要工具,它通过限制并管理线程数量来提高系统性能。线程池中的线程可以重用,减少了线程创建和销毁的开销。核心线程数和最大线程数是线程池配置中的关键参数,它们分别决定了线程池在空闲和忙碌时的线程数量。存活时间可以通过设置keepAliveTime来定义,而工作队列则是线程池等待执行任务的容器。
当线程池中的任务数超过最大线程数时,拒绝策略就变得至关重要。CallerRunsPolicy策略要求调用线程执行该任务,而AbortPolicy策略则抛出异常。DiscardPolicy和DiscardOldestPolicy策略则简单地忽略新任务或丢弃最旧的任务。
同步机制是并发编程中的核心,它确保了多线程访问共享资源时的数据一致性。悲观锁通常通过synchronized关键字或Lock接口来实现,它假设在访问共享资源时可能会发生冲突,因此在访问前先加锁。乐观锁则采用版本号或时间戳来检测数据变更,如果检测到冲突,则重试或回滚操作。读写锁(如ReentrantReadWriteLock)允许多个线程同时读取,但写入时需要独占锁。
条件变量(如Object.wait()和Object.notify())允许线程在满足特定条件时等待,条件成立时被唤醒。这些机制在处理生产者-消费者问题等并发场景中非常有用。
Java并发集合类如ConcurrentHashMap和CopyOnWriteArrayList提供了线程安全的集合实现,它们通过不同的算法和机制来确保线程安全。例如,ConcurrentHashMap使用分段锁来提高并发性能,而CopyOnWriteArrayList则在写操作时复制整个容器,适用于读多写少的场景。
并发工具类如Phaser和Exchanger提供了高级的线程间协作机制。Phaser允许线程分阶段执行,而Exchanger允许两个线程交换数据。
非阻塞算法如CAS(Compare-And-Swap)通过原子操作来避免锁的使用,从而提高并发性能。Atomic类提供了各种原子操作,如AtomicInteger和AtomicLong。
并发框架如Netty和Akka提供了更高层次的并发编程抽象,它们适用于构建高性能和可扩展的网络应用程序和分布式系统。Netty是一个基于NIO的框架,它简化了网络编程。Akka则使用Actor模型,它将每个线程视为一个Actor,每个Actor独立处理消息。
并发框架
Netty使用事件驱动模型,它允许非阻塞I/O操作,从而提高系统吞吐量。Netty的核心组件包括Channel、EventLoopGroup、ChannelPipeline等。Channel表示网络连接,EventLoopGroup负责处理I/O事件,ChannelPipeline则用于处理入站和出站事件。
Akka使用Actor模型,每个Actor都是一个独立的消息处理器。Actor通过发送消息来通信,并且可以并行处理多个消息。Akka的核心组件包括Actor系统、Actor、ActorRef、ActorSelection等。
Disruptor是一个高性能的环形缓冲区,它通过减少锁的使用来提高并发性能。Disruptor使用环形数组作为缓冲区,每个生产者或消费者都有自己的序列号,它们通过比较序列号来避免冲突。
二、MyBatis知识体系
SQL映射
MyBatis的SQL映射可以通过XML或注解来实现。XML映射使用 、