TaskConcurrency get()

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


        TaskConcurrency<T> get(T t) {
            for (TaskConcurrency<T> tc : queue) {
                if (tc.getTask() == t) {
                    return tc;
                }
            }
            return null;
        }