Analisis teknologi teras bahasa Go

Pengaturcaraan serentak dalam Go dilaksanakan menggunakan goroutine (benang ringan) dan saluran (paip komunikasi). Goroutine dicipta melalui kata kunci pergi, yang sangat ringan dan boleh mencipta sejumlah besar goroutin tanpa menjejaskan prestasi. Saluran digunakan untuk komunikasi antara goroutine dan merupakan paip bertaip. Contoh ini menunjukkan aplikasi perangkak serentak, menggunakan goroutine untuk merangkak URL secara selari untuk meningkatkan kecekapan.

Analisis Teknologi Teras Go: Pengaturcaraan Serentak

Model konkurensi dalam Go adalah berdasarkan konsep goroutine (benang ringan) dan saluran (paip komunikasi). Dengan memanfaatkan sepenuhnya ciri ini, pembangun boleh membina aplikasi berprestasi tinggi yang sangat serentak.

Goroutine

Goroutine ialah urutan ringan dalam Go, dibuat dengan kata kunci go. Ia dijalankan pada penjadual coroutine, dan tidak seperti benang tradisional, goroutine sangat ringan dan beribu-ribu boleh dibuat tanpa kesan prestasi yang ketara. Kod berikut menunjukkan cara mencipta dan menggunakan goroutines:

package main

import (
    "fmt"
    "runtime"
)

func main() {
    fmt.Printf("Number of goroutines: %d\n", runtime.NumGoroutine()) // 当前正在运行的 goroutine 数量

    // 创建一个 goroutine
    go func() {
        fmt.Println("Hello from a goroutine!")
    }()

    fmt.Printf("Number of goroutines: %d\n", runtime.NumGoroutine()) // 当前正在运行的 goroutine 数量
}

Saluran

Saluran ialah paip yang digunakan untuk komunikasi antara gorouti. Mereka ditaip, yang bermaksud mereka hanya boleh menghantar nilai jenis tertentu. Kod berikut menunjukkan cara membuat dan menggunakan saluran:

package main

import (
    "fmt"
)

func main() {
    // 创建一个 int 类型的 channel
    c := make(chan int)

    // 向 channel 发送值
    go func() {
        c <- 42
    }()

    // 从 channel 接收值
    v := <-c
    fmt.Println(v) // 输出：42
}

Kes praktikal: Perangkak serentak

Berikut ialah contoh mudah menggunakan goroutine dan saluran untuk membina perangkak serentak:

package main

import (
    "fmt"
    "net/http"
    "sync"
)

var wg sync.WaitGroup

func main() {
    // 要爬取的 URL 列表
    urls := []string{
        "https://example.com",
        "https://example2.com",
        "https://example3.com",
    }

    // 创建 channel 来接收每个 URL 的响应
    results := make(chan string)

    // 为每个 URL 创建一个 goroutine
    for _, url := range urls {
        wg.Add(1)
        go func(url string) {
            resp, err := http.Get(url)
            if err != nil {
                fmt.Printf("Error fetching %s: %v\n", url, err)
            } else if resp.StatusCode == 200 {
                results <- url
            }
            wg.Done()
        }(url)
    }

    // 从 channel 中获取响应
    go func() {
        for url := range results {
            fmt.Println(url)
        }
    }()

    // 等待所有 goroutine 完成
    wg.Wait()
}

Dengan menggunakan, goroutine dan saluran perangkak ini boleh merangkak serentak Ambil berbilang URL, sekali gus meningkatkan kecekapan.

Atas ialah kandungan terperinci Analisis teknologi teras bahasa Go. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!