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

王林
풀어 주다: 2024-02-05 22:54:03
앞으로
858명이 탐색했습니다.

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 := <-pool 차단됩니다. 해당 채널의 채널을 계속 사용하려면 채널을 다시 설정해야 합니다.
으아악

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

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

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

원천:stackoverflow.com
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿
회사 소개 부인 성명 Sitemap
PHP 중국어 웹사이트:공공복지 온라인 PHP 교육,PHP 학습자의 빠른 성장을 도와주세요!