gistfile1.go

type ThingPool struct {
  pool chan *Thing
  generator func() *Thing
  destructor func(*Thing)
}

func NewThingPool(poolSize int, generator func() *Thing, destructor func(*Thing)) *ThingPool {
  p := &ThingPool{
          pool : make(chan *Thing, poolsize),
          generator : generator,
          destructor : destructor,
        }
  for i := 0; i < poolSize; i++ {
    p.pool <- generator()
  }
  return p
}


func (p *ThingPool) Acquire(maxWait time.Duration) *Thing {
  select {
  case t := <-p.pool:
    return t
  default:
    timeout := time.After(maxWait)
    select {
    case t := <-p.pool:
      return t
    case <-timeout:
      return p.generator()
    }
  }
}

func (p *ThingPool) Release(t *Thing) {
  select {
  case p.pool <- t:
  default:
    p.destructor(t)
  }
}