}
func (lb *defaultLoadBalancer) getTaskQueueLoadBalancer(tq *tqid.TaskQueue) *tqLoadBalancer {
loadbalancer.go
lb.lock.RLock()
tqlb, ok := lb.taskQueueLBs[*tq]
lb.lock.RUnlock()
if ok {
return tqlb
}
tqlb, ok = lb.taskQueueLBs[*tq]
if !ok {
tqlb = newTaskQueueLoadBalancer(tq)
lb.taskQueueLBs[*tq] = tqlb
}
lb.lock.Unlock()
return tqlb
}