Method Put

internal/compressions/writer_pool.go:71–82

(writer Writer)

}

func (this *WriterPool) Put(writer Writer) {
	if writer.IncreaseHit() > maxWriterHits {
		// do nothing to discard it
		return
	}

	select {
	case this.c <- writer:
	default:
		isBusy = true
	}
}