Golang channel任务优先级处理示例

type Task struct {
    Name     string
    Priority int // 数值越小，优先级越高
}

highPriorityCh := make(chan Task, 10)
midPriorityCh  := make(chan Task, 10)
lowPriorityCh  := make(chan Task, 10)

func startScheduler() {
    for {
        select {
        case task := <-highPriorityCh:
            handleTask(task)
        default:
            select {
            case task := <-highPriorityCh:
                handleTask(task)
            case task := <-midPriorityCh:
                handleTask(task)
            default:
                select {
                case task := <-highPriorityCh:
                    handleTask(task)
                case task := <-midPriorityCh:
                    handleTask(task)
                case task := <-lowPriorityCh:
                    handleTask(task)
                }
            }
        }
    }
}

func handleTask(task Task) {
    fmt.Printf("处理任务: %s, 优先级: %d\n", task.Name, task.Priority)
}
func main() {
go startScheduler()
// 发送测试任务
highPriorityCh <- Task{Name: "紧急修复", Priority: 1}
lowPriorityCh  <- Task{Name: "日志清理", Priority: 3}
midPriorityCh  <- Task{Name: "数据备份", Priority: 2}
highPriorityCh <- Task{Name: "安全告警", Priority: 1}

// 等待调度处理（实际中可用 waitGroup）
time.Sleep(2 * time.Second)
}