查询线程池

此 API 用于显示集群中所有节点的线程池统计信息。

API #

GET /_cat/thread_pool
GET /_cat/thread_pool/{thread_pool_patterns}

API 的作用 #

返回集群中所有节点的线程池详细统计信息，包括：

• 活跃线程数：当前正在执行的线程数量
• 线程池大小：线程池的配置大小
• 队列状态：队列中的任务数和队列容量
• 拒绝统计：被拒绝的任务数量
• 完成统计：已完成的任务总数

此 API 是监控和调试集群性能的重要工具，可以帮助识别线程池瓶颈和资源竞争问题。

API 的参数 #

路由参数 #

查询字符串参数 #

返回的字段信息 #

默认显示的列：node_name, name, active, queue, rejected

线程池类型 #

常见线程池 #

请求示例 #

# 查询所有线程池
GET /_cat/thread_pool

# 显示列头
GET /_cat/thread_pool?v

# 查询特定线程池
GET /_cat/thread_pool/search

# 查询多个线程池（逗号分隔）
GET /_cat/thread_pool/search,bulk

# 使用通配符查询
GET /_cat/thread_pool/*

# 使用 JSON 格式
GET /_cat/thread_pool?format=json

# 只显示特定列
GET /_cat/thread_pool?h=node_name,name,active,queue,rejected

# 按活跃线程数排序
GET /_cat/thread_pool?s=active:desc

# 显示帮助信息
GET /_cat/thread_pool?help

响应示例 #

文本格式（默认） #

node_name     name        active queue rejected
master-node   search          5     2        0
master-node   write           3     0       10
data-node-1   search          8     5        0
data-node-1   bulk            2    50       15
data-node-2   search          4     1        0
data-node-2   write           2     0        5

JSON 格式 #

[
  {
    "node_name": "master-node",
    "name": "search",
    "active": "5",
    "queue": "2",
    "rejected": "0"
  },
  {
    "node_name": "data-node-1",
    "name": "bulk",
    "active": "2",
    "queue": "50",
    "rejected": "15"
  }
]

详细模式（带完整列头） #

node_name   name   active pool_size queue queue_size rejected largest completed
master-node search 5      4         2     100         0        5      15234
master-node write  3      2         0     200         10       3      8567

使用场景 #

1. 性能监控：监控线程池的使用情况
2. 瓶颈识别：识别线程池饱和问题
3. 拒绝分析：分析任务被拒绝的原因
4. 容量规划：评估线程池配置是否合理
5. 问题排查：诊断请求处理延迟问题

线程池问题诊断 #

高拒绝率 #

如果 rejected 列显示大量拒绝：

• 线程池过小，需要增加线程数
• 队列已满，考虑增加队列大小
• 负载过高，考虑增加节点或优化查询

队列堆积 #

如果 queue 列持续高位：

• 处理速度跟不上请求速度
• 可能存在慢查询或大量写入
• 检查 active 线程是否达到池大小上限

活跃线程持续高位 #

如果 active 持续接近 pool_size：

• 线程池可能成为瓶颈
• 考虑增加线程池大小或增加节点

线程池配置 #

线程池可以通过配置文件进行调整：

thread_pool:
  search:
    size: 20
    queue_size: 100
  write:
    size: 10
    queue_size: 200

注意事项 #

1. 此 API 只支持 GET 方法
2. 默认只显示部分列，使用 v=true 显示完整列头
3. local=true 时可能返回过时信息，但响应更快
4. 线程池配置更改需要重启节点才能生效
5. 不同版本的 Easysearch 可能有不同的线程池类型和名称

最佳实践 #

1. 定期监控：定期检查线程池状态，关注拒绝率
2. 设置告警：对高拒绝率和队列堆积设置告警
3. 合理配置：根据实际负载调整线程池大小
4. 分析模式：分析负载模式，找出高峰时段
5. 文档记录：记录线程池配置变更，便于问题追踪

相关文档 #

• 查询节点
• 获取节点统计信息
• 查询集群健康Cat格式