Kubernetes 调度器队列 - 设计与实现
内容提要
Kubernetes调度器包含三个队列：Active队列存放待调度Pod并按优先级堆排序；UnSchedulable队列存放调度失败的Pod；Backoff队列存放等待重试的Pod，采用指数退避机制，默认1至10秒。后台goroutine定期将Pod移回Active队列。核心实现为PriorityQueue，位于scheduling_queue.go，提供Add、Pop、Update、Delete等操作。
延伸解读
三个队列的分工与协作
调度器通过Active、UnSchedulable和Backoff三个队列管理Pod的调度状态。Active队列按优先级堆排序，存放待调度Pod；UnSchedulable队列记录调度失败的Pod；Backoff队列则用堆按重试等待时间排序，避免频繁重试。后台goroutine定期将满足条件的Pod移回Active队列，实现状态流转。这种设计既保证了优先级调度，又通过退避机制减轻了调度器负载。
指数退避机制的实际影响
Backoff队列采用指数退避算法，默认初始退避1秒，最大10秒。重试次数越多，等待时间越长，例如重试3次后等待8秒。这能有效防止调度失败的Pod频繁重试导致系统过载。但退避时间基数需要合理配置，过小可能无法缓解负载，过大则可能延迟Pod的调度。实际使用中需根据集群规模和调度压力调整。
PriorityQueue的CRUD操作逻辑
PriorityQueue的Add操作将Pod加入Active队列，并从其他队列删除；Pop从Active队列取出堆顶Pod，队列为空时阻塞等待；Delete依次尝试从三个队列删除；Update则根据Pod所在队列采取不同策略：在Active或Backoff队列中直接更新或移动，在UnSchedulable队列中若Pod有更新则移入Active队列。这些操作确保了Pod状态的一致性。
后台goroutine与事件驱动调度
PriorityQueue的Run方法启动两个后台goroutine：每1秒将Backoff队列中完成退避的Pod移入Active队列，每30秒将UnSchedulable队列中停留过久的Pod移入Active队列。此外，当节点添加、更新或Pod删除等事件触发时，调度器会调用MoveAllToActiveOrBackoffQueue，将UnSchedulable队列中的Pod根据退避状态移至Active或Backoff队列，实现事件驱动的重新调度。
Q&A
Kubernetes调度器队列包含哪几个队列？各自的作用是什么？
Kubernetes调度器队列包含三个队列：Active队列存放等待被调度的Pod，按优先级堆排序；UnSchedulable队列存放调度失败的Pod；Backoff队列存放等待重试的Pod，采用指数退避机制。
调度失败的Pod重试机制是怎样的？
调度失败的Pod会进入Backoff队列，采用指数退避机制，默认最小等待1秒，最大10秒。重试次数越多，等待时间越长，例如重试3次后等待时间为2^3=8秒。后台goroutine定期将完成重试的Pod移回Active队列。
调度器队列中Pod的状态是如何转换的？
新创建的Pod加入Active队列；调度失败后进入UnSchedulable队列；等待重试的Pod进入Backoff队列。当事件触发或后台goroutine定期刷新时，Pod会从UnSchedulable或Backoff队列移回Active队列重新调度。成功调度的Pod从队列中删除。
调度器队列的核心实现类是什么？它提供了哪些主要操作？
核心实现类是PriorityQueue，位于scheduling_queue.go。它提供Add、Pop、Update、Delete等操作，分别用于添加Pod到Active队列、从Active队列弹出Pod、更新Pod以及从队列中删除Pod。
调度器队列的后台goroutine是如何工作的？
有两个后台goroutine：一个每1秒运行一次，将Backoff队列中已完成重试的Pod移动到Active队列；另一个每30秒运行一次，将UnSchedulable队列中停留时间过长的Pod移动到Active队列。这些操作由PriorityQueue.Run方法启动。
调度器队列中Pod的优先级和重试等待时间是如何排序的？
Active队列按优先级从高到低排序，堆顶Pod优先级最高；Backoff队列按重试等待时间从低到高排序，堆顶Pod等待时间最少。这样确保高优先级Pod优先调度，且重试等待时间短的Pod优先重试。
