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) } }