(b *testing.B)
| 404 | } |
| 405 | |
| 406 | func BenchmarkChanSub3(b *testing.B) { |
| 407 | q := New("channel") |
| 408 | client := q.Client() |
| 409 | client.Sub("hello") |
| 410 | |
| 411 | go func() { |
| 412 | for i := 0; i < b.N; i++ { |
| 413 | sub := q.(*queue).chanSub("hello") |
| 414 | msg := NewMessage(1, "", 0, nil) |
| 415 | sub.high <- msg |
| 416 | } |
| 417 | }() |
| 418 | for i := 0; i < b.N; i++ { |
| 419 | msg := <-client.Recv() |
| 420 | msg.Reply(msg) |
| 421 | } |
| 422 | } |
| 423 | |
| 424 | func BenchmarkChanSub4(b *testing.B) { |
| 425 | q := New("channel") |