async

package main

import (
	"fmt"

	"github.com/egonelbre/async"
)

func main() {
	input := []int{0, 1, 2, 3, 4, 5, 6, 7, 8, 9}
	output := make([]int, len(input))
	async.BlockIter(len(input), 2, func(start, limit int) {
		for i, v := range input[start:limit] {
			output[start+i] = v * v
		}
	})

	for i, v := range output {
		fmt.Println(i, input[i], v)
	}
}

Output:

package main

import (
	"fmt"

	"github.com/egonelbre/async"
)

func main() {
	input := []int{0, 1, 2, 3, 4, 5, 6, 7, 8, 9}
	output := make([]int, len(input))
	async.Iter(len(input), 2, func(i int) {
		output[i] = input[i] * input[i]
	})

	for i, v := range output {
		fmt.Println(i, input[i], v)
	}
}

Output:

package main

import (
	"fmt"
	"sync/atomic"

	"github.com/egonelbre/async"
)

func main() {
	total := int64(0)

	async.Run(8, func(id int) {
		atomic.AddInt64(&total, int64(id))
	})

	fmt.Println(total)
}

Output:
28

package main

import (
	"fmt"

	"github.com/egonelbre/async"
)

func main() {
	work := make(chan int, 3)
	done := make(chan int, 3)

	async.Spawn(3, func(id int) {
		for v := range work {
			done <- v * v
		}
	}, func() {
		close(done)
	})

	for i := 0; i < 5; i += 1 {
		work <- i
	}
	close(work)

	for r := range done {
		fmt.Println(r)
	}
}

Output: