chan chan 구성으로 인해 교착 상태 발생

질문 내용

작업 채널에 작업을 배포하는 작은 코드를 작성하여 Go의 chan chan 构造，如下所示，我希望 3 个工作子例程处理 10 个作业。每个工作子例程都有自己的通道，在其中接收要处理的“作业”。主 Go 例程通过从通道池中获取通道（因此是 chan chan 구문을 이해하려고 합니다.

하지만 이 코드는 교착상태 상황으로 이어질 것입니다! 이 코드의 몇 가지 변형을 시도했지만 동일한 오류가 발생했습니다.

작업자 서브루틴이 해당 채널에서 작업을 읽기를 영원히 기다리고 있기 때문인가요? 아니면 다른 이유 때문인가요(채널이 조기에 닫히는 경우 등)? 전체 구조를 이해하는 데 분명히 뭔가가 빠져 있습니다.

이 문제와 해결 방법을 이해하도록 도와줄 사람이 있나요?

놀이터의 코드를 요청한 대로 아래에 복사했습니다.

package main

import (
    "fmt"
    "sync"
)

type Job struct {
    ID int
}

func worker(id int, jobs <-chan Job, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Printf("Worker %d starting\n", id)
    for job := range jobs {
        fmt.Printf("Worker %d processing job %d\n", id, job.ID)
    }
    fmt.Printf("Worker %d done\n", id)
}

func main() {
    numWorkers := 3
    maxJobs := 10
    var wg sync.WaitGroup
    // Create the pool of worker channels
    pool := make(chan chan Job, numWorkers)

    for i := 0; i < numWorkers; i++ {
        workerChan := make(chan Job) // Create a new channel for each worker
        pool <- workerChan           // Add the worker channel to the pool
        go worker(i, workerChan, &wg)
    }
    defer close(pool)
    // Create jobs and distribute them to workers
    for i := 0; i < maxJobs; i++ {
        job := Job{ID: i}
        wg.Add(1)
        workerChan := <-pool
        workerChan <- job
    }

    // Wait for all workers to complete
    wg.Wait()
    fmt.Println("All jobs are processed")
}

정답

우선 여기선 채널이 필요없습니다. 여러 작업자에게 작업을 배포하려면 단일 공유 채널에서 모든 작업자를 읽으면 됩니다. 채널에 작업을 보낼 때 사용 가능한 작업자가 있으면 그 중 한 명이 해당 작업을 받습니다. 그렇지 않으면 사용 가능한 작업자가 있을 때까지 채널 보내기 작업이 차단됩니다.

각 작업자에 대해 별도의 채널을 사용하려는 경우에도 채널 중 일부가 필요하지 않고 일부만 필요합니다. 각 작업자는 전용 채널에서 듣고 작업 할당을 직접 관리하게 됩니다.

으아악

코드에 두 가지 문제가 있습니다:

1. 작업을 채널로 보낼 때가 아니라 고루틴을 생성할 때 대기 그룹에 추가해야 합니다
2. 채널에서 채널을 읽으면 해당 채널이 풀에서 제거됩니다. 따라서 채널 3개를 읽은 후에는 다른 채널이 없기 때문에 workerChannel := 차단됩니다. 해당 채널의 채널을 계속 사용하려면 채널을 다시 설정해야 합니다.

으아악

이 방법으로 채널의 채널을 순환 대기열로 사용할 수 있습니다

1. pool 不会有任何效果。您必须关闭 pool에서 채널을 닫습니다.

위 내용은 chan chan 구성으로 인해 교착 상태 발생의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!