为何我的goroutine没有运行？解释一下

Goroutine是一种轻量级线程，用于并发执行任务。它们是Go语言中并行编程的重要组成部分。然而，有时goroutine可能无法正常运行，导致并发程序出现问题。本文将探讨导致goroutine无法运行的常见原因，并提供解决这些问题的有效方法。了解这些原因并采取适当的措施可以确保goroutine的正确运行，从而提高程序的性能和可靠性。

func main() {
    var wg sync.waitgroup
    ch := make(chan int,5)
    start:= time.now()
    cnt:=0
    wg.add(10000)
    for i:=0; i<10000; i++ {
        ch <- 1
        go func() {
            defer wg.done()
            dosomething()
            cnt++
            <-ch
        }()
    }
    wg.wait()
    fmt.println(cnt)
    end:= time.now()
    fmt.println("end of program.",end.sub(start))
}

这里我想并发执行程序，并且我希望最多有5个goroutines。 问题是当我打印出“cnt”时，它不会是 10000。这意味着我有一些 goroutine 没有执行。我该如何解决这个问题？

现在我使用互斥体来解决这个问题，但是这个程序的运行时并不会因为goroutine而更好，我不明白为什么。

func main() {
    var wg sync.WaitGroup
    var mutex sync.Mutex
    ch := make(chan int,5)
    start:= time.Now()
    cnt:=0
    for i:=0; i<10000; i++ {
        wg.Add(1)
        ch <- 1
        go func() {
            defer wg.Done()
            defer mutex.Unlock()
            mutex.Lock()
            doSomething()
            cnt++
            <-ch
        }()
    }
    wg.Wait()
    fmt.Println(cnt)
    end:= time.Now()
    fmt.Println("End of program.",end.Sub(start))
}

解决方案

尝试在下面的程序中计算工人的数量，看看哪个数字可以给你最好的结果。尽管如此，您的基准测试方式并不真正可靠，通常应该避免。

但是这个程序应该运行得更好；肯定有更好的实现。所以在这里你只是生成 workers 数量的 goroutine，但在你的情况下，它是 10000 goroutine，这对于小情况来说实际上是没有必要的；这太过分了。

注意：对我来说，这个程序的效果比您的实现好 >50%。

package main

import (
    "fmt"
    "sync"
    "time"
)

type work struct {
    wg   *sync.WaitGroup
    jobs <-chan struct{}

    mu  *sync.Mutex
    val *int
}

// worker is responsible for executing the work assigned
func worker(w work) {
    for range w.jobs {
        w.mu.Lock()
        *w.val++
        w.mu.Unlock()
    }
    w.wg.Done()
}

func main() {
    start := time.Now()
    jobs := make(chan struct{}, 2) // Number of jobs (buffer)
    workers := 2                   // Number of workers
    cnt := 0                       // Shared variable among workers

    work := work{
        wg:   &sync.WaitGroup{},
        jobs: jobs,
        mu:   &sync.Mutex{},
        val:  &cnt,
    }

    // Worker Pool
    work.wg.Add(workers)
    for i := 0; i < workers; i++ {
        go worker(work)
    }

    // Allocate jobs (Signal worker(s))
    for i := 0; i < 10000; i++ {
        jobs <- struct{}{}
    }
    // Ask the workers to stop
    close(jobs)
    work.wg.Wait()

    fmt.Println(cnt)
    fmt.Println("End of program: ", time.Since(start))
}

今天关于《为何我的goroutine没有运行？解释一下》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！