HW2, Go to barrier

Barrier by using channel

package main

import (
	"fmt"
)

type callback func()

func pulseAll(amount int, pulse chan bool, success callback) {
	for i := 0; i < amount; i++ {
		pulse <- true
	}
	success()
}

func wait(wait chan bool) {
	<-wait
}

func aSyncFunction(amount int, barrierChan chan int, doneChan chan bool, waitChan chan bool) {
	n := <-barrierChan
	fmt.Println(n)
	if n == amount {
		pulseAll(amount-1, waitChan, func() {
			doneChan <- true
		})
	} else {
		barrierChan <- n + 1
		wait(waitChan)
	}
}

func barrierFunction(amountOfBarrier int) {
	barrierChannel := make(chan int)
	doneChannel := make(chan bool)
	waitChannel := make(chan bool)

	for i := 0; i < amountOfBarrier; i++ {
		go aSyncFunction(amountOfBarrier, barrierChannel, doneChannel, waitChannel)
	}

	barrierChannel <- 1
	<-doneChannel
}

func main() {
	barrierFunction(10)
}