我正在通过在LeetCode上进行编码问题来练习golang。我正在尝试解决一个简单的数独难题(它只是验证了棋盘)。没有具有相同数字的行,没有具有相同数字的列,没有具有相同数字的3x3块。我正在尝试使用并发性来学习Go Routines / Channels / Etc ...

我无法让等待组完成

import (
    "sync"
    "fmt"
)
func isValidSlice(slice []byte, results chan<- bool, wg *sync.WaitGroup) {
    fmt.Println(slice)
    seen := make(map[byte]bool)
    for _,val := range(slice) {
        if seen[val] {
            if val != '.'{
                results <- false
                defer wg.Done()
                return
            }
        } else {
            seen[val] = true
        }
    }

    results <- true
    defer wg.Done()
}

func isValidSudoku(board [][]byte) bool {
    // Channel to receive solution
    c := make(chan bool)

    // Number of routines that will run (9 for rows, 9 for cols, 9 for 3x3 blocks)
    var wg sync.WaitGroup

    // Check every row
    for x:= 0; x < 9; x++{
        wg.Add(1)
        go isValidSlice(append([]byte{}, board[x]...), c, &wg)
    }
    for y:= 0; y < 9; y++{
        wg.Add(1)
        go isValidSlice(append([]byte{}, board[0:9][y]...), c, &wg)
    }
    // Check every 3x3 block
    for x:= 0; x <= 6; x += 3{
        for y := 0; y <= 6; y += 3{
            block_digits := append([]byte{}, board[x][y:y+3]...)
            block_digits = append(block_digits, board[x+1][y:y+3]...)
            block_digits = append(block_digits, board[x+2][y:y+3]...)
            wg.Add(1)
            go isValidSlice(block_digits, c, &wg)
        }
    }

    fmt.Println("got here")
    wg.Wait()
    fmt.Println("never got here")

    for result := range c{
        if !result{
            return false
        }
    }

    return true
}

我期望wg.Wait()锁能够释放并且代码可以向前移动。然后,我期望通道中的结果之一为false,如果为false,则返回false。否则,在遍历通道中的所有元素并且没有找到错误之后,我会期望为True。

最佳答案

您的goroutine无法调用wg.Done(),因为它们都在等待在通道中添加其值。但是由于您只消耗了wg.Wait()之后的通道中的值,因此除一个之外的所有goroutine都永远无法调用wg.Done()

实际上,您不需要WaitGroup,只需将其删除即可。

其他的建议:

  • 您应该将defer wg.Done()移到isValidSlice的第一行。在函数的最后一行调用defer没有多大意义。
  • 如果您要正确关闭通道,则只需要一个WaitGroup,可以在其他goroutine中执行此操作,请参见下面的示例。

  • func isValidSudoku(board [][]byte) bool {
    
        // ...
    
        fmt.Println("got here")
        go func(){
            wg.Wait()
            close(c)
        }()
        fmt.Println("never got here")
    
        for result := range c{
            if !result{
                go func(){
                    for _ := range c {
                    }
                }()
                return false
            }
        }
        return true
    }
    

    关于go - 使用Golang和并发验证9x9数独板,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/58533062/

    10-12 21:41