func()

in component/xload/threadpool.go [111:156]

• 41 lines of code
• 13 McCabe index (conditional complexity)

func (threadPool *ThreadPool) Do(priority bool) {
	defer threadPool.waitGroup.Done()

	if priority {
		// This thread will work only on high priority channel
		for {
			select {
			case <-threadPool.ctx.Done(): // listen to cancellation signal
				return

			default:
				select {
				case <-threadPool.ctx.Done(): // listen to cancellation signal
					return
				case item := <-threadPool.priorityItems:
					threadPool.process(item)
				}
			}
		}
	} else {
		// This thread will work only on both high and low priority channel
		for {
			select {
			case <-threadPool.ctx.Done(): // listen to cancellation signal
				return

			default:
				select {
				case <-threadPool.ctx.Done(): // listen to cancellation signal
					return
				case item := <-threadPool.priorityItems:
					threadPool.process(item)
				default:
					select {
					case <-threadPool.ctx.Done(): // listen to cancellation signal
						return
					case item := <-threadPool.priorityItems:
						threadPool.process(item)
					case item := <-threadPool.workItems:
						threadPool.process(item)
					}
				}
			}
		}
	}
}