Golang 関数を使用して非同期操作を処理するにはどうすればよいですか?-Golang-php.cn

関数を使用して非同期操作を処理する手順は、次の 3 つのステップに分かれています。コードブロックを同時に実行するコルーチンを作成します。チャネルを使用して、コルーチン間で結果やエラーなどのデータを送信します。コルーチンを使用して非同期タスクを実行し、チャネルから結果を受け取ります。

Golang 関数を使用して非同期操作を処理するにはどうすればよいですか?

Golang では、関数を使用して非同期操作を処理するのが一般的なパターンです。関数はコルーチンとして実行できるため、メインスレッドをブロックすることなくコードのブロックを同時に実行できます。

コルーチン

コルーチンは、新しいオペレーティングシステムスレッドを作成せずにコードを同時に実行できる軽量のスレッドです。コルーチンは、goキーワードと、その後に実行される関数によって作成されます。

go func() { // 异步代码在此处执行 }

ログイン後にコピー

Channel

チャネルは、で使用される通信メカニズムです。コルーチンとメインスレッド間、または異なるコルーチン間でデータを送信します。

非同期操作の場合、チャネルを使用してコルーチン実行の結果またはエラーを受信できます。

result := make(chan int) go func() { // 异步代码在此处执行 result <- resultValue }

ログイン後にコピー

実際のケース: Web ページの同時クロール

一連の URL を同時にクロールする実際のケースを考えてみましょう。

package main import ( "fmt" "io/ioutil" "net/http" ) func main() { urls := []string{"url1", "url2", "url3"} results := make(chan string) // 为每个 URL 创建一个协程 for _, url := range urls { go func(url string) { // 爬取网页并发送结果到信道 resp, err := http.Get(url) if err != nil { results <- fmt.Sprintf("Error getting %s: %v", url, err) return } defer resp.Body.Close() body, err := ioutil.ReadAll(resp.Body) if err != nil { results <- fmt.Sprintf("Error reading body of %s: %v", url, err) return } results <- fmt.Sprintf("Got body of %s: %s", url, string(body)) }(url) } // 从信道接收结果并打印 for i := 0; i < len(urls); i++ { fmt.Println(<-results) } }

ログイン後にコピー