small-pineapple

``` type Wrap struct { connection atomic.Value } func (this *Wrap) Connect(addr string) error { conn, err := amqp.Dial(addr) if err != nil { return err } this.connection.Store(conn) go func()...

I have not read it carefully. However in golang, for one connection(session or something else like that) can have its dedicated goroutine(that's golang one of most important feature). One connection's...

> will operate the same Kcp structure together If one kcp struct shared with multiple UdpSession, shouldn't Kcp struct has its own mutex to be thread safe? However, the mutex...

So the only purpose UdpSession use mutex is make UdpSession can be concurrent. That is somewhat werid, because that should be user's responsibility, for example, make its own session type...

So ModulePrototype.Probability is relative probability or weight. However, the entropy value is dominated by the size of p (ModuleSet.Count), those entropies should have been normalized before compare.