在Go语言中如何解决并发任务的优先级调度问题？

func main() {
    go task1()
    go task2()
    time.Sleep(time.Second) //等待任务执行完成
}

func task1() {
    //执行任务1的代码
}

func task2() {
    //执行任务2的代码
}

import "container/heap"

//定义一个任务结构体
type Task struct {
    id       int
    priority int
    //其他任务相关的字段
}

//定义一个任务队列类型
type TaskQueue []*Task

//实现heap.Interface接口的Len方法
func (tq TaskQueue) Len() int {
    return len(tq)
}

//实现heap.Interface接口的Less方法
func (tq TaskQueue) Less(i, j int) bool {
    return tq[i].priority > tq[j].priority
}

//实现heap.Interface接口的Swap方法
func (tq TaskQueue) Swap(i, j int) {
    tq[i], tq[j] = tq[j], tq[i]
    tq[i].id = i
    tq[j].id = j
}

//实现heap.Interface接口的Push方法
func (tq *TaskQueue) Push(x interface{}) {
    task := x.(*Task)
    *tq = append(*tq, task)
}

//实现heap.Interface接口的Pop方法
func (tq *TaskQueue) Pop() interface{} {
    old := *tq
    n := len(old)
    task := old[n-1]
    *tq = old[0 : n-1]
    return task
}

func main() {
    taskQueue := make(TaskQueue, 0)
    heap.Init(&taskQueue)

    //添加任务到优先级队列中
    heap.Push(&taskQueue, &Task{id: 1, priority: 3})
    heap.Push(&taskQueue, &Task{id: 2, priority: 2})
    heap.Push(&taskQueue, &Task{id: 3, priority: 1})

    //从优先级队列中获取任务并执行
    for taskQueue.Len() > 0 {
        task := heap.Pop(&taskQueue).(*Task)
        go executeTask(task)
    }
    time.Sleep(time.Second) //等待任务执行完成
}

func executeTask(task *Task) {
    //执行任务的代码
}