Example of partitioning message over internal channels in golang

queue.go

package main

import (
	"fmt"
	"hash/fnv"
	"strconv"
	"sync"
	"time"
)

func main() {
	wg := sync.WaitGroup{}
	numberOfWorkers := uint64(4)
	channels := make([]chan string, numberOfWorkers)

	for i := uint64(0); i < numberOfWorkers; i++ {
		channels[int(i)] = make(chan string)
	}

	for i, c := range channels {
		go process_queue(wg, i, c)
	}

	uids := []string{"niels", "jurriaan", "arno", "daan", "martijn", "cheffrey", "koen", "martijn", "cheffrey", "koen"}

	h := fnv.New64a()
	for _, uid := range uids {
		h.Write([]byte(uid))

		channels[h.Sum64()%numberOfWorkers] <- uid

		h.Reset()
	}

	time.Sleep(time.Second * 1)
	for _, c := range channels {
		close(c)
	}

	wg.Wait()
}

func process_queue(wg sync.WaitGroup, n int, c chan string) {
	name := strconv.Itoa(n)
	for msg := range c {
		fmt.Printf("Queue %s received: %s \n", name, msg)
	}
	wg.Done()
}

Volgens mij spel je het als 'cheffrey'