Cirque

A circular queue that processes jobs in parallel but returns results in FIFO.

inputs := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}

inputChannel, outputChannel := NewCirque(3, func(i interface{}) interface{} {
    time.Sleep(time.Duration(rand.Int63n(100)) * time.Millisecond)
    return i.(int) * 2
})

go func() {
    for _, i := range inputs {
        inputChannel <- i
    }
    close(inputChannel)
}()

var output []int
for i := range outputChannel {
    output = append(output, i.(int))
}
fmt.Println(output)

// Output: [2 4 6 8 10 12 14 16 18 20]