check if max_threads has been reached
()
| 276 | |
| 277 | // check if max_threads has been reached |
| 278 | func (worker *worker) isAtThreadLimit() bool { |
| 279 | if worker.maxThreads <= 0 { |
| 280 | return false |
| 281 | } |
| 282 | |
| 283 | worker.threadMutex.RLock() |
| 284 | atMaxThreads := len(worker.threads) >= worker.maxThreads |
| 285 | worker.threadMutex.RUnlock() |
| 286 | |
| 287 | return atMaxThreads |
| 288 | } |
| 289 | |
| 290 | func (worker *worker) handleRequest(ch contextHolder) error { |
| 291 | metrics.StartWorkerRequest(worker.name) |
no outgoing calls
no test coverage detected