Function BenchmarkSendMessage

queue/queue_test.go:299–331

(b *testing.B)

}

func BenchmarkSendMessage(b *testing.B) {
	q := New("channel")
	//mempool
	b.ReportAllocs()
	go func() {
		client := q.Client()
		client.Sub("mempool")
		defer client.Close()
		for msg := range client.Recv() {
			go func(msg *Message) {
				if msg.Ty == types.EventTx {
					msg.Reply(client.NewMessage("mempool", types.EventReply, types.Reply{IsOk: true, Msg: []byte("word")}))
				}
			}(msg)
		}
	}()
	go q.Start()
	client := q.Client()
	//high 优先级
	msg := client.NewMessage("mempool", types.EventTx, "hello")
	for i := 0; i < b.N; i++ {
		err := client.Send(msg, true)
		if err != nil {
			b.Error(err)
			return
		}
		_, err = client.Wait(msg)
		if err != nil {
			b.Error(err)
			return
		}
	}
}

func BenchmarkStructChan(b *testing.B) {
	ch := make(chan struct{})