言語の特徴

• 優れたパフォーマンス
• コンパイル/実行速度が早い
• 言語仕様がシンプル
• クロスコンパイルをサポート
• 並行処理のサポート
• マスコットがかわいい
• etc…

Goによる並行処理

• 1秒WaitしてHello, worldを出力
  
• Webにアクセスし、ステータスコードを出力
  
• 引数で受けたNameを出力
  

package main

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

func helloWorld() {
	time.Sleep(time.Second)
	fmt.Println("Hello, world!!")
}

func getHttp(url string) {
	res, err := http.Get(url)
	if err != nil {
		log.Fatal(err)
	}
	defer res.Body.Close()
	fmt.Println(url, res.Status)
}

func helloName(name string) {
	fmt.Println("Hello", name)
}

func main() {
	helloWorld()
	getHttp("https://jobs.excite.co.jp/")
	helloName("Makiyama")
	time.Sleep(time.Second * 2)
	fmt.Println("Done.")
}

$ go run goroutine.go
Hello, world!!
https://jobs.excite.co.jp/ 200 OK
Hello Makiyama
Done.

/*-- 略 --*/

func main() {
	go helloWorld()
	go getHttp("https://jobs.excite.co.jp/")
	go helloName("Makiyama")
	time.Sleep(time.Second * 2)
	fmt.Println("Done.")
}

$ go run goroutine.go
Hello Makiyama
https://jobs.excite.co.jp/ 200 OK
Hello, world!!
Done.

$ go run goroutine.go
Done.

package main

import (
	"fmt"
	"log"
	"math/rand"
	"sync"
	"time"
)

func main() {
	var wg sync.WaitGroup
	for i := 0; i < 5; i++ {
		wg.Add(1)             // goroutine起動のたびにインクリメント
		go func(i int) {
			defer wg.Done()   // 関数終了時にデクリメント
			n := rand.Intn(5)
			log.Println("sleep for", n, "seconds", "ID:", i)
			time.Sleep(time.Duration(n) * time.Second)
			log.Println("wake up,", "ID:", i)
		}(i)
	}
	wg.Wait()                // 処理をブロックし、カウンタが0になったら次に進む
	fmt.Println("Done.")
}

$ go run waitGroup.go
2016/11/29 13:35:51 sleep for 1 seconds ID: 4
2016/11/29 13:35:51 sleep for 2 seconds ID: 1
2016/11/29 13:35:51 sleep for 4 seconds ID: 0
2016/11/29 13:35:51 sleep for 2 seconds ID: 2
2016/11/29 13:35:51 sleep for 1 seconds ID: 3
2016/11/29 13:35:52 wake up, ID: 4
2016/11/29 13:35:52 wake up, ID: 3
2016/11/29 13:35:53 wake up, ID: 1
2016/11/29 13:35:53 wake up, ID: 2
2016/11/29 13:35:55 wake up, ID: 0
Done.

channel(チャネル)の基本

channelを用いたメッセージング

package main

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

func getHttp(url string) <-chan string {
	status := make(chan string)    	// channelの生成
	go func(url string) {
		res, err := http.Get(url)
		if err != nil {
			log.Fatal(err)
		}
		defer res.Body.Close()
		status <- res.Status	  // channelにデータを書き込み
	}(url)
	return status
}

func main() {
	status := getHttp("https://jobs.excite.co.jp/")
	fmt.Println(<-status)     	// channelにデータが書き込まれるまでブロック
	fmt.Println("Done.")
}

channelによる排他制御

package main

import (
	"fmt"
	"sync"
	"time"
)

type CountDown struct {
	Count     int
	HappyWord string
}

func happyNewYear(started int, word string) {
	var cd CountDown = CountDown{started, word}
	aKun := make(chan *CountDown)
	bSan := make(chan *CountDown)

	var wg sync.WaitGroup
	wg.Add(2)

	go func() {
		defer wg.Done()
		for {
			cd, ok := <-aKun // aKunから読み込み(書き込みを待つ)
			if !ok {
				break
			}
			time.Sleep(time.Second)
			fmt.Printf("　A君「%d！！！」\n", cd.Count)
			cd.Count-- // データの書き換え
			if cd.Count == 0 {
				break
			}

			bSan <- cd // bSanへ書き込み
		}
		close(bSan)
	}()

	go func() {
		defer wg.Done()
		for {
			cd, ok := <-bSan // bSanから読み込み(書き込みを待つ)
			if !ok {
				break
			}
			time.Sleep(time.Second)
			fmt.Printf("Bさん「%d！！！」\n", cd.Count)
			cd.Count-- // データの書き換え
			if cd.Count == 0 {
				break
			}

			aKun <- cd // aKunへ書き込み
		}
		close(aKun)
	}()

	aKun <- &cd // 最初の書き込み
	wg.Wait()   // 終了を待つ
	time.Sleep(time.Second)
	fmt.Printf("A君・Bさん「「%s！！！」」\n", cd.HappyWord)
}

func main() {
	happyNewYear(3, "Happy New year!!!")
	fmt.Println("Done.")
}

まとめ

エンジニア募集

エキサイトでは一緒に働いてくださる方を新卒採用と中途採用で募集しています。
詳しくは、こちらの採用情報ページをご覧ください。

エンジニアの働きやすい環境が整っており、風通しの良い会社です。
1年目でも「Go入れたい」とか勝手に言える素敵な会社です！
ぜひ一緒により良いサービスを作り上げていきましょう！ʕ◔ϖ◔ʔ！