Golang 함수에서 고루틴 생성 및 관리

Go 언어에서는 go 키워드와 함수 호출을 사용하여 고루틴을 만듭니다. 고루틴을 관리할 때 동기화를 위해 sync.WaitGroup을 사용하고, 고루틴을 취소하려면 컨텍스트 패키지를 사용하세요. 실제 전투에서는 네트워크 요청, 이미지 처리 및 기타 작업을 병렬로 처리하는 데 사용할 수 있습니다.

Golang 함수에서 고루틴 생성 및 관리

고루틴(코루틴)은 단일 스레드에서 동시에 여러 작업을 실행할 수 있는 Go 언어의 경량 병렬 실행 단위입니다.

고루틴 생성

고루틴 생성은 매우 간단합니다. go 키워드와 함수 호출을 사용할 수 있습니다: go 关键字后跟一个函数调用即可：

func hello() {
    fmt.Println("Hello from goroutine")
}

func main() {
    go hello() // 创建一个执行 hello() 函数的 goroutine
}

Goroutine 管理

同步

在处理共享资源时，需要对 goroutine 进行同步。使用 sync.WaitGroup 可以等待一组 goroutine 完成：

var wg sync.WaitGroup

func hello(name string) {
    wg.Add(1)
    defer wg.Done()

    fmt.Println("Hello", name)
}

func main() {
    wg.Add(3)
    go hello("John")
    go hello("Mary")
    go hello("Bob")
    wg.Wait() // 等待所有 goroutine 完成
}

取消

可以使用 context

import (
    "context"
    "fmt"
    "time"
)

func heavyComputation(ctx context.Context) {
    for {
        select {
        case <-ctx.Done():
            fmt.Println("Computation cancelled")
            return
        default:
            // 执行计算
        }
    }
}

func main() {
    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    defer cancel()

    go heavyComputation(ctx)
    time.Sleep(10 * time.Second) // 10 秒后取消计算
}

고루틴 관리

동기화

공유 처리 resources 때, 고루틴은 동기화되어야 합니다. 고루틴 그룹이 완료될 때까지 기다리려면 sync.WaitGroup을 사용하세요.

func main() {
    urls := []string{"https://example.com", "https://example.net", "https://example.org"}

    var wg sync.WaitGroup

    for _, url := range urls {
        wg.Add(1)
        go func(url string) {
            resp, err := http.Get(url)
            if err != nil {
                log.Fatal(err)
            }

            resp.Body.Close()
            wg.Done()
        }(url)
    }

    wg.Wait()
}

취소

고루틴을 취소하려면 context 패키지를 사용할 수 있습니다.

func main() {
    images := []string{"image1.jpg", "image2.jpg", "image3.jpg"}

    var wg sync.WaitGroup

    for _, image := range images {
        wg.Add(1)
        go func(image string) {
            img, err := image.Decode(image)
            if err != nil {
                log.Fatal(err)
            }

            // 处理图像

            wg.Done()
        }(image)
    }

    wg.Wait()
}

실용 사례

네트워크 요청 병렬 처리:

🎜rrreee🎜🎜이미지 처리 병렬 처리: 🎜🎜rrreee

위 내용은 Golang 함수에서 고루틴 생성 및 관리의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!