。

无界队列#xff1a;适合任务量大且任务执行时间短的场景#xff0c;避免因队列满而拒绝任务。

IO密集型任务

核心线程数与CPU核数相同避免线程过多导致的上下文切换提高CPU利用率。

无界队列适合任务量大且任务执行时间短的场景避免因队列满而拒绝任务。

IO密集型任务

适用于执行大量IO操作的任务如文件读写、网络通信、数据库访问等。

这类任务在等待IO时线程处于阻塞状态因此可以通过增加线程数来提高并发度。

线程池配置

核心线程数根据CPU核数和IO等待时间来调整通常设置为CPU核数的2倍或更多。

最大线程数可以设置为更高取决于系统资源和任务特性。

任务队列使用有界队列如LinkedBlockingQueue防止过多线程导致资源耗尽。

java

import

Runtime.getRuntime().availableProcessors();int

corePoolSize

ThreadPoolExecutor(corePoolSize,maxPoolSize,keepAliveTime,

TimeUnit.SECONDS,new

LinkedBlockingQueueRunnable(1000),

有界队列new

ThreadPoolExecutor.CallerRunsPolicy()

饱和策略);for

IO密集型任务例如数据库查询performDatabaseQuery();});}executor.shutdown();}private

static

模拟IO操作System.out.println(Performing

query

Thread.currentThread().getName());try

{Thread.sleep(100);

{Thread.currentThread().interrupt();}}

场景描述

适用于需要长时间处理的任务如视频处理、数据分析、复杂计算等。

这类任务占用线程时间较长可能导致线程池中的线程被长期占用。

线程池配置

核心线程数适中不宜过多以防止系统资源被长时间占用。

最大线程数可以适当增加但需要考虑系统资源限制。

任务队列使用有界队列并合理设置队列大小防止大量长时间任务导致线程池资源耗尽。

import

ThreadPoolExecutor(corePoolSize,maxPoolSize,keepAliveTime,

TimeUnit.SECONDS,new

ArrayBlockingQueueRunnable(100),

有界队列new

ThreadPoolExecutor.AbortPolicy()

饱和策略拒绝任务);for

长时间任务例如视频处理processVideo();});}executor.shutdown();}private

static

模拟长时间处理System.out.println(Processing

video

Thread.currentThread().getName());try

{Thread.sleep(5000);

{Thread.currentThread().interrupt();}}

网络IO密集RPC调用通常涉及较多的网络IO因此线程会存在等待IO的情况。

批量任务拆分批量操作通常会将大量任务分发到多个节点或服务进行处理确保每个节点的负载均衡尤为关键。

并发限制为了避免对单个节点或服务的过度压力线程池的大小和任务队列的处理策略必须合理控制。

服务启动后端服务启动时通常会通过操作系统创建一个或多个进程来运行服务。

任务分发某些服务可能为了处理不同的任务创建多个子进程来分担负载。

例如处理批量数据、并行计算等。

异步处理当需要异步处理任务或处理一些耗时较长的任务时可以通过创建新的进程来避免阻塞主进程。

多进程架构一些后端框架如Django、Flask等或部署工具如Gunicorn、uWSGI等会自动创建多个进程来处理多用户并发请求。

线程池是一种管理多个线程执行的机制通过复用一组线程来避免频繁创建和销毁线程节省系统资源。

大部分编程语言和框架都会有内置的线程池机制。

在Java中常用的线程池框架是java.util.concurrent包下的ExecutorService。

创建和控制线程池通常涉及以下几个方面

ExecutorService

Executors.newFixedThreadPool(10);

FixedThreadPool固定大小的线程池适合处理稳定数量的任务。

CachedThreadPool根据需求动态创建线程池适合任务负载波动较大的场景。

ScheduledThreadPool用于调度任务的线程池支持周期性或延迟执行任务。

SingleThreadExecutor只有一个线程的线程池适合顺序执行任务。

{//

关闭线程池当不再需要使用线程池时应该调用shutdown()方法关闭它。

调用shutdown()后线程池不再接受新任务但会继续执行已提交的任务。

可以使用awaitTermination()方法等待所有任务执行完成。

核心线程数Core

当线程池中的线程数量超过核心线程数时多余的空闲线程存活的时间。

任务队列Task

Queue

根据系统负载和任务类型的不同选择合适的线程池大小和配置非常重要

小任务并发如果任务非常小且耗时短建议使用较大的线程池和较小的任务队列。

长时间任务如果任务执行时间较长建议保持较小的线程池避免线程上下文切换带来的开销。

队列的选择常用的任务队列有LinkedBlockingQueue无界队列和SynchronousQueue直接提交队列。

进程通常在服务启动、异步任务或多进程架构中产生。

线程池通过Executor框架创建常见参数有核心线程数、最大线程数、存活时间和任务队列。

根据任务类型和系统负载选择合适的线程池配置避免资源浪费或阻塞。

工厂方法模式抽象工厂模式

LoggerFactory.getLogger(RedisUtils.class);private

MapString,

timeUnit.toString());dataMap.put(key,

value);}public

原型模式主要解决的问题就是创建⼤量᯿复的类⽽我们模拟的场景就需要给不同的⽤户都创建相同的

试卷但这些试卷的题⽬不便于每次都从库中获取甚⾄有时候需要从远程的RPC中获取。

这样都是⾮

在原型模式中所需要的⾮常᯿要的⼿段就是克隆在需要⽤到克隆的类中都需要实现

implements

⽬前此种⽅式的单例确实满⾜了懒加载但是如果有多个访问者同时去获取对象实例你可以想象成

⼀堆⼈在抢厕所就会造成多个同样的实例并存从⽽没有达到单例的要求。

懒汉模式(线程安全)

此种模式虽然是安全的但由于把锁加到⽅法上后所有的访问都因需要锁占⽤导致资源的浪费。

饿汉模式(线程安全)

但此种⽅式并不是懒加载也就是说⽆论你程序中是否⽤到这样的类都会在程序启动之初进⾏创

那么这种⽅式导致的问题就像你下载个游戏软件可能你游戏地图还没有打开呢但是程序已经将

这些地图全部实例化。

到你⼿机上最明显体验就⼀开游戏内存满了⼿机卡了需要换了。

public

使⽤类的静态内部类实现的单例模式既保证了线程安全有保证了懒加载同时不会因为加锁的⽅

这主要是因为JVM虚拟机可以保证多线程并发访问的正确性也就是⼀个类的构造⽅法在多线程环境下可以被正确的加载。

双重锁校验(线程安全)

可以封装引⽤⼀个V实例⽀持并发访问如上的单例⽅式就是使⽤了这样的⼀个

使⽤CAS的好处就是不需要使⽤传统的加锁⽅式保证线程安全⽽是依赖于CAS的忙等算法依赖

于底层硬件的实现来保证线程安全。

相对于其他锁的实现没有线程的切换和阻塞也就没有了额外

当然CAS也有⼀个缺点就是忙等如果⼀直没有获取到将会处于死循环中。

结构型模式包括适配器、桥接、组合、装饰器、外观、享元、代理这7类。

适配器模式的主要作⽤就是把原本不兼容的接⼝通过适配修改做到统⼀。

⽽这时候就会需要做⼀些营销系统⼤部分常⻅的都是裂变、拉客例如你邀请⼀个⽤户开户、或者

邀请⼀个⽤户下单那么平台就会给你返利多邀多得。

同时随着拉新的量越来越多开始设置每⽉下单

查询⽤户内部下单数量接⼝

LoggerFactory.getLogger(POPOrderService.class);public

long

userId){logger.info(⾃营商家查询⽤户的订单是否为⾸单{},

userId);return

LoggerFactory.getLogger(POPOrderService.class);public

boolean

{logger.info(POP商家查询⽤户的订单是否为⾸单{},

uId);return

LoggerFactory.getLogger(PayController.class);public

boolean

{logger.info(模拟微信渠道⽀付划账开始。

uId{}

tradeId{}

{logger.info(模拟⽀付宝渠道⽀付划账开始。

uId{}

tradeId{}amount{},

{logger.info(指纹⽀付⻛控校验指纹信息);}}return

true;}}

适用于处理大量独立且执行时间较短的任务例如Web请求处理、快速计算等。

这类任务通常是CPU密集型的执行时间短且数量庞大。

线程池配置

核心线程数与CPU核心数相同避免过度创建线程导致上下文切换开销。

最大线程数一般设置为与核心线程数相同或略高。

任务队列使用无界队列如LinkedBlockingQueue避免因为任务量大而频繁创建和销毁线程。

import

Runtime.getRuntime().availableProcessors();ExecutorService

executor

短时间任务例如处理一个请求processRequest();});}executor.shutdown();}private

static

模拟处理请求System.out.println(Processing

request

Thread.currentThread().getName());}

Tomcat

namePrefixcatalina-exec-maxThreads150

minSpareThreads4/

protocolHTTP/1.1connectionTimeout20000redirectPort8443executortomcatThreadPool

加群联系作者vxxiaoda0423