菜单

网上皇家赌场网址golang实现基于channel的通用连接池详解

2019年5月29日 - 皇家赌场系统

*
链接的最大空闲时间,超时的链接将关闭放弃,可幸免空闲时链接自动失效难点

福寿康宁原理

你可能感兴趣的稿子:

实现

上述便是那篇文章的全体内容了,希望本文的内容对大家的读书或然办事具有自然的参谋学习价值,即使不不荒谬大家能够留言沟通,多谢大家对剧本之家的支撑。

* 使用channel管理池中的链接,高效

由于出现难题,在急需操作池中互斥数据的时候要求加锁。

将一连句柄存入channel中,由于缓存channel的特征,获取连接时只要池中有一而再,将一贯重回,如若池中从未连接,将卡住也许新建连接(没超越最大范围的事态下)。

结论

依据该连接池,能够管理全部io.Closer对象。比方memcached,redis等等,特别便利!

package pool
import (
  "errors"
  "io"
  "sync"
  "time"
)

var (
  ErrInvalidConfig = errors.New("invalid pool config")
  ErrPoolClosed  = errors.New("pool closed")
)

type factory func() (io.Closer, error)

type Pool interface {
  Acquire() (io.Closer, error) // 获取资源
  Release(io.Closer) error   // 释放资源
  Close(io.Closer) error    // 关闭资源
  Shutdown() error       // 关闭池
}

type GenericPool struct {
  sync.Mutex
  pool    chan io.Closer
  maxOpen   int // 池中最大资源数
  numOpen   int // 当前池中资源数
  minOpen   int // 池中最少资源数
  closed   bool // 池是否已关闭
  maxLifetime time.Duration
  factory   factory // 创建连接的方法
}

func NewGenericPool(minOpen, maxOpen int, maxLifetime time.Duration, factory factory) (*GenericPool, error) {
  if maxOpen <= 0 || minOpen > maxOpen {
    return nil, ErrInvalidConfig
  }
  p := &GenericPool{
    maxOpen:   maxOpen,
    minOpen:   minOpen,
    maxLifetime: maxLifetime,
    factory:   factory,
    pool:    make(chan io.Closer, maxOpen),
  }

  for i := 0; i < minOpen; i++ {
    closer, err := factory()
    if err != nil {
      continue
    }
    p.numOpen++
    p.pool <- closer
  }
  return p, nil
}

func (p *GenericPool) Acquire() (io.Closer, error) {
  if p.closed {
    return nil, ErrPoolClosed
  }
  for {
    closer, err := p.getOrCreate()
    if err != nil {
      return nil, err
    }
    // todo maxLifttime处理
    return closer, nil
  }
}

func (p *GenericPool) getOrCreate() (io.Closer, error) {
  select {
  case closer := <-p.pool:
    return closer, nil
  default:
  }
  p.Lock()
  if p.numOpen >= p.maxOpen {
    closer := <-p.pool
    p.Unlock()
    return closer, nil
  }
  // 新建连接
  closer, err := p.factory()
  if err != nil {
    p.Unlock()
    return nil, err
  }
  p.numOpen++
  p.Unlock()
  return closer, nil
}

// 释放单个资源到连接池
func (p *GenericPool) Release(closer io.Closer) error {
  if p.closed {
    return ErrPoolClosed
  }
  p.Lock()
  p.pool <- closer
  p.Unlock()
  return nil
}

// 关闭单个资源
func (p *GenericPool) Close(closer io.Closer) error {
  p.Lock()
  closer.Close()
  p.numOpen--
  p.Unlock()
  return nil
}

// 关闭连接池,释放所有资源
func (p *GenericPool) Shutdown() error {
  if p.closed {
    return ErrPoolClosed
  }
  p.Lock()
  close(p.pool)
  for closer := range p.pool {
    closer.Close()
    p.numOpen--
  }
  p.closed = true
  p.Unlock()
  return nil
}

前言

golang的channel除了goroutine通讯之外还会有诸多任何的机能,本文将达成一种基于channel的通用连接池。上面话非常少说了,来共同看看详细的介绍吧。

皇家娱乐登录,出于面向接口编制程序,全部创设连接的逻辑是不知道的,这里要求传入四个函数,该函数重回四个io.Closer对象。

* 连接池中连连类型为interface{},使得越来越通用

本来,你能够兑现基于interface{}的连接池,那样任何对象都能够被管理。

功能

何为通用?网上皇家赌场网址

连接池的兑现不正视具体的实例,而借助有些接口,本文的连接池选拔的是io.Closer接口,只即使贯彻了该接口的靶子都足以被池处理。

总结

相关文章

发表评论

电子邮件地址不会被公开。 必填项已用*标注

网站地图xml地图