Gopool

A lightweight goroutine pool for Golang.

Reference Implementation

go get github.com/mengdu/gopool

Usage

package main

import (
	"fmt"
	"time"

	"github.com/mengdu/gopool"
)

func main() {
	pool := gopool.New(3)
	// pool.WithNonblocking = true
	defer pool.Release()
	for i := 0; i < 10; i++ {
		index := i
		// fmt.Printf("task-%d\n", index)
		if err := pool.Submit(func() {
			fmt.Println("do", index)
			time.Sleep(time.Second * 2) // 模拟耗时任务
		}); err != nil {
			fmt.Println("error", err)
		}
	}
	pool.Wait()
	fmt.Println("all done")
}