1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
package main
import (
"fmt"
"github.com/Arceliar/phony"
)
// Structs can embed the Inbox type to fulfill the Actor interface.
type printer struct {
phony.Inbox
}
// Functions can be defined to send messages to an Actor from another Actor.
func (p *printer) Println(from phony.Actor, msg ...interface{}) {
p.Act(from, func() { fmt.Println(msg...) })
}
// It's useful to embed an Actor in a struct whose fields the Actor is responsible for.
type counter struct {
phony.Inbox
count int
printer *printer
}
// Act with a nil sender is useful for asking an Actor to do something from non-Actor code.
func (c *counter) Increment() {
c.Act(nil, func() { c.count++ })
}
// Block waits until after a message has been processed before returning.
// This can be used to interrogate an Actor from an outside goroutine.
// Note that Actors shouldn't use this on eachother, since it blocks, it's just meant for convenience when interfacing with outside code.
func (c *counter) Get() int {
var n int
phony.Block(c, func() { n = c.count })
return n
}
// Print sends a message to the counter, telling to to call c.printer.Println
// Calling Println sends a message to the printer, telling it to print
// So message sends become function calls.
func (c *counter) Print() {
c.Act(nil, func() {
c.printer.Println(c, "The count is:", c.count)
})
}
func main() {
c := &counter{printer: new(printer)} // Create an actor
for idx := 0; idx < 10; idx++ {
c.Increment() // Ask the Actor to do some work
c.Print() // And ask it to send a message to another Actor, which handles them asynchronously
}
n := c.Get() // Inspect the Actor's internal state
fmt.Println("Value from Get:", n) // This likely prints before the Print() lines above have finished -- Actors work asynchronously.
phony.Block(c.printer, func() {}) // Wait for an Actor to handle a message, in this case just to finish printing
fmt.Println("Exiting")
}
|
