基本使用

  1. package main
  2. import (
  3. "github.com/gogf/gf/v2/container/gpool"
  4. "fmt"
  5. "time"
  6. )
  7. func main () {
  8. // 创建一个对象池,过期时间为1秒
  9. p := gpool.New(time.Second, nil)
  10. // 从池中取一个对象,返回nil及错误信息
  11. fmt.Println(p.Get())
  12. // 丢一个对象到池中
  13. p.Put(1)
  14. // 重新从池中取一个对象,返回1
  15. fmt.Println(p.Get())
  16. // 等待2秒后重试,发现对象已过期,返回nil及错误信息
  17. time.Sleep(2*time.Second)
  18. fmt.Println(p.Get())
  19. }

创建及销毁方法

我们可以给定动态创建及销毁方法。

  1. package main
  2. import (
  3. "fmt"
  4. "github.com/gogf/gf/v2/container/gpool"
  5. "github.com/gogf/gf/v2/net/gtcp"
  6. "github.com/gogf/gf/v2/os/glog"
  7. "time"
  8. )
  9. func main() {
  10. // 创建对象复用池,对象过期时间为3秒,并给定创建及销毁方法
  11. p := gpool.New(3*time.Second, func() (interface{}, error) {
  12. return gtcp.NewConn("www.baidu.com:80")
  13. }, func(i interface{}) {
  14. glog.Println("expired")
  15. i.(*gtcp.Conn).Close()
  16. })
  17. conn, err := p.Get()
  18. if err != nil {
  19. panic(err)
  20. }
  21. result, err := conn.(*gtcp.Conn).SendRecv([]byte("HEAD / HTTP/1.1\n\n"), -1)
  22. if err != nil {
  23. panic(err)
  24. }
  25. fmt.Println(string(result))
  26. // 丢回池中以便重复使用
  27. p.Put(conn)
  28. // 等待一定时间观察过期方法调用
  29. time.Sleep(4*time.Second)
  30. }

执行后,终端输出结果:

  1. HTTP/1.1 302 Found
  2. Connection: Keep-Alive
  3. Content-Length: 17931
  4. Content-Type: text/html
  5. Date: Wed, 29 May 2019 11:23:20 GMT
  6. Etag: "54d9749e-460b"
  7. Server: bfe/1.0.8.18
  8. 2019-05-29 19:23:24.732 expired