example_test.go

package gopool_test

import (
	"context"
	"fmt"

	"github.com/codegrapple/gopool"
)

func ExamplePool_basic() {
	ctx := context.Background()

	// Pool with bounded parallelism.
	pool := gopool.New(2, 8)
	defer pool.Shutdown(ctx)

	// Two independent handles, each bound to a single goroutine.
	h1 := pool.NewHandle()
	h2 := pool.NewHandle()

	var (
		seq1, seq2 int
		out1, out2 []int
	)

	// Schedule work concurrently, but observe sequential execution per handle.
	for i := 0; i < 3; i++ {
		h1.Schedule(ctx, func() {
			out1 = append(out1, seq1)
			seq1++
		})

		h2.Schedule(ctx, func() {
			out2 = append(out2, seq2)
			seq2++
		})
	}

	// Ensure all scheduled work has completed.
	pool.Shutdown(ctx)

	fmt.Println(out1)
	fmt.Println(out2)

	// Output:
	// [0 1 2]
	// [0 1 2]
}