Go의 동시 프로그래밍은 고루틴(경량 스레드)과 채널(통신 파이프)을 사용하여 구현됩니다. 고루틴은 go 키워드를 통해 생성되는데, 이는 매우 가볍고 성능에 영향을 주지 않고 많은 수의 고루틴을 생성할 수 있습니다. 채널은 고루틴 간의 통신에 사용되며 형식화된 파이프입니다. 이 예에서는 효율성을 높이기 위해 goroutine을 사용하여 URL을 병렬로 크롤링하는 동시 크롤러의 적용을 보여줍니다.
Go 핵심 기술 분석: 동시 프로그래밍
Go의 동시성 모델은 고루틴(경량 스레드)과 채널(통신 파이프) 개념을 기반으로 합니다. 이러한 기능을 최대한 활용함으로써 개발자는 동시성이 높은 고성능 애플리케이션을 구축할 수 있습니다.
Goroutine
Goroutine은 go
라는 키워드로 생성된 Go의 경량 스레드입니다. 코루틴 스케줄러에서 실행되며 기존 스레드와 달리 고루틴은 매우 가벼우며 성능에 큰 영향을 주지 않고 수천 개를 생성할 수 있습니다. 다음 코드는 고루틴을 생성하고 사용하는 방법을 보여줍니다.
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 数量 }
Channel
Channel은 고루틴 간의 통신에 사용되는 파이프입니다. 이는 유형이 지정되어 있으므로 특정 유형의 값만 전달할 수 있습니다. 다음 코드는 채널을 생성하고 사용하는 방법을 보여줍니다.
package main import ( "fmt" ) func main() { // 创建一个 int 类型的 channel c := make(chan int) // 向 channel 发送值 go func() { c <- 42 }() // 从 channel 接收值 v := <-c fmt.Println(v) // 输出:42 }
실제 사례: 동시 크롤러
다음은 고루틴과 채널을 사용하여 동시 크롤러를 구축하는 간단한 예입니다.
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() }
고루틴과 채널을 사용하여 이 크롤러는 동시에 여러 URL을 가져와 크롤링할 수 있으므로 효율성이 향상됩니다.
위 내용은 Go 언어 핵심 기술 분석의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!