WithCPUPool allows to specify an execution pool based on the number of logical CPUs.
()
| 145 | |
| 146 | // WithCPUPool allows to specify an execution pool based on the number of logical CPUs. |
| 147 | func 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. |
| 154 | func WithBackPressureStrategy(strategy BackpressureStrategy) Option { |
searching dependent graphs…