goroutine 使い方まとめ

#goroutineとはなにか？
軽量スレッドである、並行処理で複数のスレッドが立てられる
「go」というシンプルなメソッドを使ってスレッドを立てる
「channel」は複数のgoroutineにメッセージを送るもの
また「select」は複数のchannelを管理するものである

mainの関数が終了しないようにgoroutineを制御する仕組みは「channel」か「sync」を使用する
以下の例はchannelを使用して複数のリクエストを並行処理で書いてある例である。

go

package main

import (
	"fmt"
	"log"
	"net/http"
	"time"
)

func getStatus(urls []string) <-chan string {
	statusChan := make(chan string)
	for _, url := range urls {
		go func(url string) {
			res, err := http.Get(url)
			if err != nil {
				log.Fatal(err)
			}
			defer res.Body.Close()
			statusChan <- res.Status
		}(url)
	}
	return statusChan
}

func main() {
	timeout := time.After(time.Second)
	urls := []string{
		"http://example.com",
		"http://example.net",
		"http://example.org",
	}
	statusChan := getStatus(urls)

	for {
		select {
		case status := <-statusChan:
			fmt.Println(status)
		case <-timeout:
			break
		}
	}
}

syncを使って書くと以下のようになる

go

package main

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

func getStatus(urls []string) {
	wait := new(sync.WaitGroup)
	for _, url := range urls {
		wait.Add(1)
		go func(url string) {
			res, err := http.Get(url)
			if err != nil {
				log.Fatal(err)
			}
			defer res.Body.Close()
			log.Println(url, res.Status)
			wait.Done()
		}(url)
	}
	wait.Wait()
}

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

Do not communicate by sharing memory;instead, share memory by communicating.

の原則につきgoroutineの管理はchannelを使用してメッセージを送ってやりとりするのが望ましい。

参考URL
http://gihyo.jp/dev/feature/01/go_4beginners/0005
https://github.com/astaxie/build-web-application-with-golang/blob/master/ja/02.7.md
http://jxck.hatenablog.com/entry/20130414/1365960707