(b *testing.B)
| 250 | } |
| 251 | |
| 252 | func BenchmarkActorRequest(b *testing.B) { |
| 253 | system := actor.NewSystem("bench") |
| 254 | defer system.Shutdown() |
| 255 | |
| 256 | echo := &EchoActor{name: "echo"} |
| 257 | pid := system.Spawn(echo, "echo") |
| 258 | |
| 259 | for i := 0; b.Loop(); i++ { |
| 260 | _, _ = pid.Request(&PingMsg{Count: i}, time.Second) |
| 261 | } |
| 262 | } |
| 263 | |
| 264 | func BenchmarkActorConcurrent(b *testing.B) { |
| 265 | system := actor.NewSystem("bench") |