Function WithDecoderConcurrency

zstd/decoder_options.go:68–83

WithDecoderConcurrency sets the number of created decoders. When decoding block with DecodeAll, this will limit the number of possible concurrently running decodes. When decoding streams, this will limit the number of inflight blocks. When decoding streams and setting maximum to 1, no async decoding

(n int)

// By default this will be set to 4 or GOMAXPROCS, whatever is lower.
// Cannot be changed with ResetWithOptions.
func WithDecoderConcurrency(n int) DOption {
	return func(o *decoderOptions) error {
		if n < 0 {
			return errors.New("concurrency must be at least 0")
		}
		newVal := n
		if n == 0 {
			newVal = runtime.GOMAXPROCS(0)
		}
		if o.resetOpt && newVal != o.concurrent {
			return errors.New("WithDecoderConcurrency cannot be changed on Reset")
		}
		o.concurrent = newVal
		return nil
	}
}

// WithDecoderMaxMemory allows to set a maximum decoded size for in-memory
// non-streaming operations or maximum window size for streaming operations.