Java虚拟线程(Loom)的使用场景分析

虚拟线程显着提高了 I/O 密集型性能。
微服务API：SpringBoot使用Executors.newVirtualThreadPerTaskExecutor()处理每秒数万个请求，代码同步，线程池自动复用。
消息队列：Kafka为每条消息分配一个虚拟线程，I/O等待自动暂停，吞吐量提升5 0%以上。
传统Web服务器：Servlet容器使用虚拟线程保留同步代码，资源利用率提高6 0%。
对比：传统线程池栈空间1 MB+，虚拟线程几百字节，并发数百万无瓶颈。
注意：不要将虚拟线程用于 CPU 密集型任务，因为它会减慢 JVM 的速度。

线程池的应用范围

线程池适合处理任务：
一项短期任务
很多任务
网页请求处理
高性能响应能力要求
线程池不适合长时间运行的任务：
长时间运行的任务，例如 Telnet 连接
长会话，慢线程创建
避免性能问题：
请求数量惊人
避免内存溢出和 OutOfMemory 错误

基础：C#中可以优化性能的线程池

哦，刚认识C的时候，这个事情让我很头疼。
我们不谈谎言，但让我们谈谈我们当时遇到的陷阱。
> 我认为使用线程池可以省去您自己线程化的麻烦。
就这么做吧：
csharp ThreadPool.QueueUserWorkItem（状态=> { // 下载文件。
字符串文件路径=（字符串）状态； // ...跳过下载逻辑... });
起初还不错；文件小，我跑得很快。
后来Boss说必须支持同时下载上百个文件。
结果呢？系统直接冷却； CPU 已满，内存不足。
这时我才发现，我从一开始就没有考虑清楚线程池的大小。

你看，.NET默认的线程池大小是基于CPU核心数的，一般是核心数的两倍。
但想一想。
下载文件时，大多数都是等待网络，不做任何计算。
如果线程池太开放，大部分线程都会在那里等待，占用CPU资源，无法做其他工作。

然后我就改了。
线程池中的最小和最大线程数根据实际需求设置。
例如，我的下载任务大部分时间都在等待网络，所以我将最小线程数设置为4 最多设置 2 0 个。
这样，系统就不会因过多的空闲线程而陷入困境。

还有一个缺点。
工作岗位太分散了。
当时，我需要处理数千条数据记录。
作为一项任务，我将每条记录直接放入线程池中。
结果，调度在顶部的线程比任务本身还要大。
后来我学会了聪明，把几十条记录合并到一个工作中，一起工作。
这样，线程调度的开销就小很多，效率也更高。

是的，线程池并不是万能的。
例如，某些任务需要特殊优先级或需要单独完成。
这个时候，就需要考虑其他形式的联合融资。
然而，线程池对于大多数情况来说仍然相当不错。
重要的是要根据实际情况进行调整。

总之，线程池是个好东西；但要充分利用它；你需要考虑。
你不需要看官方文档中的例子，而是需要根据自己的实际需求进行调整。
这十年来我所经历的所有失败都给了我教训。
请不要再犯同样的错误。

多线程的一些概念

线程是操作系统的最小调度单位。
它们共享进程内存，但具有独立的堆栈和计数器。
创建和销毁进程比较简单，可以多核同步，但需要锁来避免数据争用。
进程使用IPC进行通信，线程直接改变共享变量。

线程池抢占静态线程，使用任务队列进行复用，节省创建和销毁开销。
队列使用链表环形缓冲区，需要公平调度以防止饥饿。
线程团队继续引入排队的任务。
使用自旋锁或信号量来管理队列进行同步。

信号量控制对共享资源的访问并实现同步和共享隔离。
C使用sem_init等，C++使用mutex+condition_variable来模拟。
用于队列满通知、生产者和消费者。

任务队列采用链表环形缓冲区，支持多线程安全插入和删除。
存储函数上下文和函数指针。
线程锁线程比较时，线程等待了很短的时间，线程挂起状态变量为空，作业排队后解除。

CPU密集型模式下的线程数约等于核心数，IO密集型模式下约等于2 倍核心数加2 一般公式：线程数=（IO等待时间+CPU运行时间）进程/CPU运行时间。

生产者将任务发布到队列，消费者线程池执行任务执行，隔离它们以优化输出。
异步执行任务进入后立即返回，由后台线程执行，以免阻塞主线程。
作为日志双缓冲区的异步清洗。

隔离需要花费大量时间来处理请求的任务（例如 Web 服务器）可以防止任务减慢其响应速度。
复用资源，线程池线程频繁执行数据库连接池等任务。
流控制限制线程池的大小并调度任务以防止系统过载。

数据争用通过互斥锁或原子操作保护关键组件。
死锁以固定顺序获取锁或使用 std::lock。
饥饿行动计划征税是使用优先级队列或循环调度来完成的。

代码示例（简单C++1 1 线程池版本） 消费者保护计划 类别 贸易池 官方： 线程池（大小线程）：停止（假）{ for (size_ti=0;i<线程++i){ Workers.emplace_back([this]{while true){ std:: function 函数； { std::special_lock 锁(queue_mutex); status.wait(lock,[this]{return||!functions.void(); }); if ( stop && 函数 .void ()) return ; 函数 = std :: move(functions.front()); 活动。
流行音乐 （）; } 功能 （）; } }); } } template voidenqueue(F&f) {{ std::exclusive_lock 锁(queue_mutex); tasks.emplace(std::forward(f));}status.notify_one();}~ThreadPool(){{std::exclusive_lock lock(queue_mutex); 停止=真； } 条件.notify_all(); for (std::Thread&Employee:Employees) 员工.join();私人： std:: 矢量 工人;std::queue>函数; std::mutexqueue_mutex;std::status_variable 状态;boolstop;};