HackPool

北半球最优雅的协程库

Example

package main

import (
	"fmt"
	"github.com/greyh4t/hackpool"
)

func main() {

	numGoroutine := 2
	taskCount := 100

	hp := hackpool.New(numGoroutine, func(i interface{}) {
		fmt.Println(i.(int))
	})

	go func() {

		for i := 0; i < taskCount; i++ {
			hp.Push(i)
		}

		// push任务结束后必须关闭, 否则死锁
		hp.CloseQueue()
	}()

	// 跑起来! 伙计
	hp.Run()
}

Installation

go get github.com/greyh4t/hackpool

License

This project is copyleft of CSOIO and released under the GPL 3 license.