README
¶
gopool
A pool library for golang
Quick Example
import (
"github.com/lock-free/gopool"
"time"
)
// define resource
type Res = func(int, int) int
res := func(a int, b int) int {
return a + b
}
// create pool
getNewItem := func(onItemBoken gopool.OnItemBorken) (*gopool.Item, error) {
return &gopool.Item{res, func() {}}, nil
}
pool := GetPool(getNewItem, 8, 3000*time.Millisecond)
// Get resource
res, err := pool.Get()
if err != nil {
// handle
} else {
res.(Res)(2, 3) // 5
}
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CleanFunction ¶
type CleanFunction = func()
type GetNewItem ¶
type GetNewItem = func(OnItemBorken) (*Item, error)
get new item and can know the moment when it brokes
type Item ¶
type Item struct {
Resouce interface{} // keep Resouce
Clean CleanFunction // Clean Resouce TODO with DLB
}
type OnItemBorken ¶
type OnItemBorken = func()
type Pool ¶
type Pool struct {
// contains filtered or unexported fields
}
define pool data structure
func GetPool ¶
func GetPool(getNewItem GetNewItem, size int, duration time.Duration, retryDuration time.Duration) *Pool
get a pool, need to provide:
(1) getNewItem: how to get a new item (2) size (3) duration to get a new item
func (*Pool) GetItemNum ¶
Source Files
Click to show internal directories.
Click to hide internal directories.