Comment gérer les problèmes de file d'attente et de priorité des tâches simultanées en langage Go ?

func worker(tasks chan func()) {
    for task := range tasks {
        task()
    }
}

func main() {
    tasks := make(chan func())

    // 启动多个并发的worker
    for i := 0; i < 5; i++ {
        go worker(tasks)
    }

    // 向任务队列中添加任务
    for i := 0; i < 10; i++ {
        tasks <- func() {
            fmt.Println("Task", i)
        }
    }

    close(tasks) // 关闭任务队列

    // 等待所有worker完成任务
    wg := sync.WaitGroup{}
    wg.Add(5)
    for i := 0; i < 5; i++ {
        go func() {
            defer wg.Done()
            for range tasks {
            }
        }()
    }
    wg.Wait()
}

// 任务结构体
type Task struct {
    Priority int    // 任务优先级
    Content  string // 任务内容
}

// 优先级队列
type PriorityQueue []*Task

func (pq PriorityQueue) Len() int {
    return len(pq)
}

func (pq PriorityQueue) Less(i, j int) bool {
    return pq[i].Priority < pq[j].Priority
}

func (pq PriorityQueue) Swap(i, j int) {
    pq[i], pq[j] = pq[j], pq[i]
}

func (pq *PriorityQueue) Push(task interface{}) {
    *pq = append(*pq, task.(*Task))
}

func (pq *PriorityQueue) Pop() interface{} {
    old := *pq
    n := len(old)
    task := old[n-1]
    *pq = old[:n-1]
    return task
}

func main() {
    pq := make(PriorityQueue, 0)

    // 添加任务到优先级队列
    heap.Push(&pq, &Task{Priority: 3, Content: "Task 1"})
    heap.Push(&pq, &Task{Priority: 1, Content: "Task 2"})
    heap.Push(&pq, &Task{Priority: 2, Content: "Task 3"})

    // 从优先级队列中取出任务并执行
    for pq.Len() > 0 {
        task := heap.Pop(&pq).(*Task)
        fmt.Println("Executing", task.Content)
    }
}