加载带有和不带有 go-routines 的地图

3回答

泛舟湖上清波郎朗

您的信号量sem不起作用，因为您对其进行了深度缓冲。一般来说，这是为此类任务设置地图的错误方法，因为读取文件会很慢。如果你有一个更复杂的任务——例如，读一行，想很多，设置一些东西——你会想要这个作为你的伪代码结构：type workType struct {    index int    line  string}var wg sync.WaitGroupwg.Add(nWorkers)// I made this buffered originally but there's no real point, so// fixing that in an editwork := make(chan workType)for i := 0; i < nWorkers; i++ {    go readAndDoWork(work, &wg)}for i := 1; fscanner.Scan(); i++ {    work <- workType{index: i, line: fscanner.Text()}}close(work)wg.Wait()... now your dictionary is ready ...工人这样做：func readAndDoWork(ch chan workType, wg *sync.WorkGroup) {    for item := range ch {        ... do computation ...        insertIntoDict(item.index, result)    }    wg.Done()}抓住互斥锁（以insertIntoDict保护映射从索引到结果）并写入字典。（如果你愿意，你可以内联它。）这里的想法是设置一定数量的工作人员——可能基于可用 CPU 的数量——每个工作人员抓取下一个工作项并处理它。主 goroutine 只是打包工作，然后关闭工作通道——这将导致所有工作人员看到输入结束——然后等待他们发出信号表明他们已经完成了计算。（如果您愿意，您可以再创建一个 goroutine 来读取工作人员计算的结果并将它们放入映射中。这样您就不需要映射本身的互斥体。）

0 0

噜噜哒

正如我在评论中提到的，您无法控制 goroutine 的执行顺序，因此不应从它们内部更改索引。这是一个示例，其中与地图的交互在单个 goroutine 中，而您在其他 goroutine 中进行处理：package mainimport (    "bufio"    "fmt"    "log"    "os"    "sync")var (    fileName = "some.dat"    MAX      = 9000)func checkerr(err error) {    if err != nil {        fmt.Println(err)        log.Fatal(err)    }}type result struct {    index int    data string}func main() {    ourDict := make(map[int]string)    f, err := os.Open(fileName)    checkerr(err)    defer f.Close()    fscanner := bufio.NewScanner(f)    var wg sync.WaitGroup    sem := make(chan struct{}, MAX) // Use empty structs for semaphores as they have no allocation    defer close(sem)    out := make(chan result)    defer close(out)    indexPos := 1    for fscanner.Scan() {        text := fscanner.Text()        wg.Add(1)        sem <- struct{}{}        go func(index int, data string) {            // Defer the release of your resources, otherwise if any error occur in your goroutine            // you'll have a deadlock            defer func() {                wg.Done()                <-sem            }()            // Process your data            out <- result{index, data}        }(indexPos, text) // Pass in the data that will change on the iteration, go optimizer will move it around better        indexPos++    }    // The goroutine is the only one to write to the dict, so no race condition    go func() {        for {            if entry, ok := <-out; ok {                ourDict[entry.index] = entry.data            } else {                return // Exit goroutine when channel closes            }        }    }()    wg.Wait()    for i, v := range ourDict {        fmt.Printf("%d: %s\n", i, v)    }}

0 0

元芳怎么了

好的，我已经弄清楚了。通过复制给goroutine一个值来挂起，似乎有效。改变：for fscanner.Scan() {    text := fscanner.Text()    wg.Add(1)    sem <- 1    go func() {        mu.Lock()        defer mu.Unlock()        ourDict[indexPos] = text        indexPos++        <- sem        wg.Done()    }()}到for fscanner.Scan() {        text := fscanner.Text()        wg.Add(1)        sem <- 1        go func(mypos int) {                mu.Lock()                defer mu.Unlock()                ourDict[mypos] = text                <-sem                wg.Done()        }(indexPos)        indexPos++}完整代码： https: //play.golang.org/p/dkHaisPHyHz使用工人池，package mainimport (    "bufio"    "fmt"    "log"    "os"    "sync")const (    MAX      = 10    fileName = "some.dat")type gunk struct {    line string    id   int}func main() {    ourDict := make(map[int]string)    wg := sync.WaitGroup{}    mu := sync.RWMutex{}    cha := make(chan gunk)    for i := 0; i < MAX; i++ {        wg.Add(1)        go func(id int) {            defer wg.Done()            for {                textin, ok := <-cha                if !ok {                    return                }                mu.Lock()                ourDict[textin.id] = textin.line                mu.Unlock()            }        }(i)    }    f, err := os.Open(fileName)    checkerr(err)    defer f.Close()    fscanner := bufio.NewScanner(f)    indexPos := 1    for fscanner.Scan() {        text := fscanner.Text()        thisgunk := gunk{line: text, id: indexPos}        cha <- thisgunk        indexPos++    }    close(cha)    wg.Wait()    for i, v := range ourDict {        fmt.Printf("%d: %s\n", i, v)    }}func checkerr(err error) {    if err != nil {        fmt.Println(err)        log.Fatal(err)    }}

0 0