golang的连接池例子

ziyouchutuwenwu · · 3890 次点击 · · 开始浏览

这是一个创建于的文章，其中的信息可能已经有所发展或是发生改变。

github.com/jolestar/go-commons-pool

测试代码

package main

import (
    "github.com/jolestar/go-commons-pool"
    "fmt"
)

type MyPoolObject struct {
    Name string
}

type MyObjectFactory struct {
}

func (f *MyPoolObject) Print() {
    fmt.Println(f)
}

func (f *MyObjectFactory) MakeObject() (*pool.PooledObject, error) {
    return pool.NewPooledObject(&MyPoolObject{}), nil
}

func (f *MyObjectFactory) DestroyObject(object *pool.PooledObject) error {
    //do destroy
    return nil
}

func (f *MyObjectFactory) ValidateObject(object *pool.PooledObject) bool {
    //do validate
    return true
}

func (f *MyObjectFactory) ActivateObject(object *pool.PooledObject) error {
    //do activate
    return nil
}

func (f *MyObjectFactory) PassivateObject(object *pool.PooledObject) error {
    //do passivate
    return nil
}

func main() {
    pool := pool.NewObjectPoolWithDefaultConfig(pool.NewPooledObjectFactorySimple(
        func() (interface{}, error) {
            return &MyPoolObject{}, nil
        }))
    obj, _ := pool.BorrowObject()

    obj.(*MyPoolObject).Name = "1111"
    obj.(*MyPoolObject).Print()

    pool.ReturnObject(obj)
}