public CompletableTask next()

in concurrency-loadbalancer-core/src/main/java/com/uber/concurrency/loadbalancer/HeapConcurrencyLoadBalancer.java [58:64]

• 7 lines of code
• 3 McCabe index (conditional complexity)

    public CompletableTask<T> next() {
        TaskConcurrency<T> taskConcurrency = taskConcurrencyQueue.peek();
        if (taskConcurrency == null || Integer.compareUnsigned(Integer.MAX_VALUE, taskConcurrency.getConcurrency()) < 0) {
            return null; // no tasks or all tasks reached concurrency limits
        }
        return new ConcurrentTaskImpl(ticker.read(), taskConcurrency);
    };