an actor in go

actor.go

package main

import "fmt"

var (
	requestToActor    chan int
	responseFromActor chan int
)

const (
	adders     = 1000
	operations = 1000
)

func main() {
	requestToActor = make(chan int)
	responseFromActor = make(chan int)
	done := make(chan bool)

	// Launch tha actor
	go actor()

	// Creates threads that will increment the counter
	for i := 0; i < adders; i++ {
		go adder(operations, done) // Do increments
	}

	// Wait for all adders
	for i := 0; i < adders; i++ {
		<-done
	}

	// Get the value of the actor's counter
	requestToActor <- 0          // Increment by zero ;)
	value := <-responseFromActor // Just discard the result

	fmt.Printf("The final value of counter is %d\n", value)

}

func actor() {
	counter := 0 // This a variable that will be incremented "concurrently" (not) by an actor ;)
	for {
		incr := <-requestToActor
		counter += incr
		responseFromActor <- counter
	}
}

func adder(operations int, done chan bool) {
	for i := 0; i < operations; i++ {
		requestToActor <- 1 // Increment by 1
		<-responseFromActor // Just discard the result
	}
	done <- true // I finished
}