※これは解答です。どうしても課題が解けない場合、ご利用ください。

課題１ - 基本問題

package main

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

const (
	PAA   = 1
	GUU   = 2
	CHOKI = 3
)

func main() {
	COUNT := 1000000
	rand.Seed(time.Now().UnixNano())

	result := [3]int{}
	for i := 0; i < COUNT; i++ {
		a := yukpiz()
		b := kent()

		switch {
		case a == b:
			result[0]++
		case a == PAA && b == GUU, a == GUU && b == CHOKI, a == CHOKI && b == PAA:
			result[1]++
		case a == PAA && b == CHOKI, a == GUU && b == PAA, a == CHOKI && b == GUU:
			result[2]++
		default:
			panic("(´・ω・｀)")
		}
	}

	fmt.Printf("引分: %d\n", result[0])
	fmt.Printf("勝利: %d\n", result[1])
	fmt.Printf("敗北: %d\n", result[2])
}

func yukpiz() int {
	s := []int{PAA, GUU, CHOKI}
	return s[rand.Intn(len(s))]
}

func kent() int {
	s := []int{PAA, GUU, CHOKI}
	return s[rand.Intn(len(s))]
}

課題１ - 発展問題

※変更箇所のみ記載しています。

func kent() int {
	s := []int{PAA, PAA, PAA, GUU, CHOKI}
	return s[rand.Intn(len(s))]
}

課題２ - 基本問題

package main

import (
	"fmt"
)

type MessageTo int

const (
	MESSAGE_TO_KENT    MessageTo = 0
	MESSAGE_TO_YUKPIZ  MessageTo = 1
	MESSAGE_END_ME     MessageTo = 3
	MESSAGE_END_ME_TOO MessageTo = 4
)

func main() {
	ch := make(chan MessageTo) // 相手にボールを渡す為のチャネル
	done := make(chan bool)    // 全ての会話完了を検知するチャネル

	go kent(ch, done)
	go yukpiz(ch, done)

	// 会話が終わるまでブロック
	<-done

	// 閉じているかを確認
	<-ch
	fmt.Println("会話完了")
}

func kent(ch chan MessageTo, done chan bool) {
	texts := []string{"あなたの名前を教えてください", "私はけんとです", "生ハム食べに行きましょう"}
	for v := range ch {
		switch v {
		case MESSAGE_END_ME_TOO:
			// 終了通知が来たらチャネルを閉じる
			close(ch)
			close(done)
		case MESSAGE_END_ME:
			if len(texts) == 0 {
				// セリフがなくなったら完了
				ch <- MESSAGE_END_ME_TOO
				break
			}
			fallthrough
		case MESSAGE_TO_KENT:
			if len(texts) > 0 {
				fmt.Println("kent:" + texts[0]) // 次のセリフを発言する
				texts = texts[1:]               // 発言済みのセリフを消す
				ch <- MESSAGE_TO_YUKPIZ         // 相手にボールを渡す
			} else {
				ch <- MESSAGE_END_ME
			}
		case MESSAGE_TO_YUKPIZ:
			ch <- MESSAGE_TO_YUKPIZ
		}
	}
}

func yukpiz(ch chan MessageTo, done chan bool) {
	texts := []string{"私はゆくぴずです", "よろしくおねがいします", "行きましょう"}
	ch <- MESSAGE_TO_KENT
	for v := range ch {
		switch v {
		case MESSAGE_END_ME_TOO:
			close(ch)
			close(done)
		case MESSAGE_END_ME:
			if len(texts) == 0 {
				ch <- MESSAGE_END_ME_TOO
				break
			}
			fallthrough
		case MESSAGE_TO_KENT:
			ch <- MESSAGE_TO_KENT
		case MESSAGE_TO_YUKPIZ:
			if len(texts) > 0 {
				fmt.Println("yukpiz:" + texts[0])
				texts = texts[1:]
				ch <- MESSAGE_TO_KENT
			} else {
				ch <- MESSAGE_END_ME
			}
		}
	}
}

課題２ - 発展問題

チャネルは1対1での送信と受信をサポートしていますが、
ブロードキャストのような1対多のような通信をサポートするには工夫が必要です。

package main

import (
	"fmt"
)

type Worker struct {
	Name          string
	BroadcastChan chan int
	DoneChan      chan int
	ReceiveChan   chan int
	Receive       func(*Worker)
}

func main() {
	bch := make(chan int)  //ブロードキャスト用のチャネル
	done := make(chan int) //終了判定用のチャネル

	var workers []*Worker
	workers = append(workers, &Worker{
		Name:          "yukpiz",
		BroadcastChan: bch,
		ReceiveChan:   make(chan int),
		Receive:       yukpiz,
	})
	workers = append(workers, &Worker{
		Name:          "kent",
		BroadcastChan: bch,
		ReceiveChan:   make(chan int),
		Receive:       kent,
	})
	workers = append(workers, &Worker{
		Name:          "ariaki",
		BroadcastChan: bch,
		ReceiveChan:   make(chan int),
		Receive:       ariaki,
	})

	go BroadcastObserve(workers, bch, done)
	for _, w := range workers {
		go w.Receive(w)
	}

	// 全てのチャネルが閉じられている事を確認
	<-done
	<-bch
	for _, w := range workers {
		<-w.ReceiveChan
	}
	fmt.Println("exit!")
}

func BroadcastObserve(workers []*Worker, bch chan int, done chan int) {
	defer close(done)
	for v := range bch {
		for _, w := range workers {
			w.ReceiveChan <- v
		}
	}

	fmt.Println("closed broad cast")
	for _, w := range workers {
		close(w.ReceiveChan)
	}
}

func yukpiz(me *Worker) {
	fmt.Printf("%s: 皆さんの名前を教えてください\n", me.Name)
	me.BroadcastChan <- 1
	for v := range me.ReceiveChan {
		switch v {
		case 3:
			fmt.Printf("%s: ありがとうございます\n", me.Name)
			fmt.Printf("%s: 好きなモノを教えてください\n", me.Name)
			v++
			me.BroadcastChan <- v
		case 5:
			fmt.Printf("%s: 日本酒が好きなんですね\n", me.Name)
			v++
			me.BroadcastChan <- v
		case 7:
			fmt.Printf("%s: 生ハムを食べにいきましょう\n", me.Name)
			v++
			me.BroadcastChan <- v

		}
	}
}

func kent(me *Worker) {
	for v := range me.ReceiveChan {
		switch v {
		case 1:
			fmt.Printf("%s: 私はけんとです\n", me.Name)
			v++
			me.BroadcastChan <- v
		case 6:
			fmt.Printf("%s: 私は生ハムが好きです\n", me.Name)
			v++
			me.BroadcastChan <- v
		case 8:
			fmt.Printf("%s: 行きましょう\n", me.Name)
			close(me.BroadcastChan)
		}
	}
}

func ariaki(me *Worker) {
	for v := range me.ReceiveChan {
		switch v {
		case 2:
			fmt.Printf("%s: 私はありあきです\n", me.Name)
			v++
			me.BroadcastChan <- v
		case 4:
			fmt.Printf("%s: 私は日本酒です\n", me.Name)
			v++
			me.BroadcastChan <- v
		}
	}
}