Method Put

internal/utils/bfs/gzip_reader_pool.go:52–58

(reader *gzip.Reader)

}

func (this *GzipReaderPool) Put(reader *gzip.Reader) {
	select {
	case this.getC() <- reader:
	default:
		// 不需要close，因为已经在使用的时候调用了
	}
}

func (this *GzipReaderPool) getC() chan *gzip.Reader {
	var procId = percpu.GetProcId()