A Gossip Impl

gossip.go

package main

import (
	"log"
	"math/rand"
	"time"
)

type GossipMessage struct {
	FromNodeIdx int
	Number int
}

func main() {
	var nodeAsses [12]chan GossipMessage
	for i := range nodeAsses {
		nodeAsses[i] = make(chan GossipMessage)
	}

	for idx := 0 ; idx < 12; idx++ {
		go func(nodeIdx int) {
			currNum := rand.Intn(1000000)
			log.Printf("#%d init = %d", nodeIdx, currNum)
			for {
				select {
				case msg := <- nodeAsses[nodeIdx]:
					currNum = (currNum + msg.Number) / 2
					log.Printf("#%d recv from #%d: %d, now = %d", nodeIdx, msg.FromNodeIdx, msg.Number, currNum)
				default:
					t := rand.Intn(12)
					if t == nodeIdx {
						time.Sleep(time.Duration(rand.Intn(500)) * time.Millisecond)
					} else {
						nodeAsses[t] <- GossipMessage{
							FromNodeIdx: nodeIdx,
							Number: currNum,
						}
					}
				}

				time.Sleep(time.Duration(rand.Intn(10)) * time.Millisecond)
			}
		}(idx)
	}

	time.Sleep(10000 * time.Millisecond)
}