pool

Documentation

Overview

* @Author: drowningwhale 351231768@qq.com * @Date: 2023-10-09 16:45:31 * @LastEditors: drowningwhale 351231768@qq.com * @LastEditTime: 2023-10-09 17:41:15 * @FilePath: \go-course\Pool\NewPool.go * @Description: 这是默认设置,请设置`customMade`, 打开koroFileHeader查看配置 进行设置: https://github.com/OBKoro1/koro1FileHeader/wiki/%E9%85%8D%E7%BD%AE

Index

• func NewNewPool(initCnt, maxCnt, maxIdleCnt int, maxIdleTime time.Duration, ...) (*newPool, error)
• type Pool
  • func NewPool(initCnt, maxIdleCnt, maxCnt int, maxIdleTime time.Duration, ...) (*Pool, error)
  • func (p *Pool) Close()
  • func (p *Pool) Get(ctx context.Context) (net.Conn, error)
  • func (p *Pool) Put(ctx context.Context, conn net.Conn) error

Functions

func NewNewPool

func NewNewPool(initCnt, maxCnt, maxIdleCnt int, maxIdleTime time.Duration, factory func() (net.Conn, error)) (*newPool, error)

Types

type Pool

type Pool struct {
	// contains filtered or unexported fields
}

func NewPool

func NewPool(initCnt, maxIdleCnt, maxCnt int, maxIdleTime time.Duration, factory func() (net.Conn, error)) (*Pool, error)

func (*Pool) Close

func (p *Pool) Close()

func (*Pool) Get

func (p *Pool) Get(ctx context.Context) (net.Conn, error)

实现取连接

func (*Pool) Put

func (p *Pool) Put(ctx context.Context, conn net.Conn) error