如何处理Go语言中的并发任务的任务调度和任务优先级问题？

package main

import "fmt"

func worker(id int, tasks chan int, result chan int) {
    for task := range tasks {
        fmt.Println("Worker", id, "start task", task)
        // 模拟任务执行
        result <- task * task
        fmt.Println("Worker", id, "finish task", task)
    }
}

func scheduler(tasks []int) []int {
    numWorkers := 3
    tasksChan := make(chan int)
    resultChan := make(chan int)
    doneChan := make(chan bool)

    // 启动若干个goroutine作为工作线程
    for i := 0; i < numWorkers; i++ {
        go worker(i, tasksChan, resultChan)
    }

    // 将任务发送给工作线程
    go func() {
        for _, task := range tasks {
            tasksChan <- task
        }
        close(tasksChan)
    }()

    // 收集完成的任务结果
    go func() {
        for range tasks {
            <-resultChan
        }
        doneChan <- true
    }()

    // 等待任务完成
    <-doneChan

    close(resultChan)

    // 返回任务结果
    var results []int
    for result := range resultChan {
        results = append(results, result)
    }

    return results
}

func main() {
    tasks := []int{1, 2, 3, 4, 5}
    results := scheduler(tasks)

    fmt.Println("Task results:", results)
}