MCPcopy Create free account
hub / github.com/ReactiveX/RxGo / WithCPUPool

Function WithCPUPool

options.go:147–151  ·  view source on GitHub ↗

WithCPUPool allows to specify an execution pool based on the number of logical CPUs.

()

Source from the content-addressed store, hash-verified

145
146// WithCPUPool allows to specify an execution pool based on the number of logical CPUs.
147func WithCPUPool() Option {
148 return newFuncOption(func(options *funcOption) {
149 options.pool = runtime.NumCPU()
150 })
151}
152
153// WithBackPressureStrategy sets the back pressure strategy: drop or block.
154func WithBackPressureStrategy(strategy BackpressureStrategy) Option {

Calls 1

newFuncOptionFunction · 0.85

Used in the wild real call sites across dependent graphs

searching dependent graphs…