this.waitingLookupRequests=Queues.newArrayBlockingQueue((conf.getMaxLookupRequest() - conf.getConcurrentLookupRequest())); | this.waitingLookupRequests=Queues.newConcurrentLinkedQueue(); | Queues.newArrayBlockingQueue((conf.getMaxLookupRequest() - conf.getConcurrentLookupRequest())) | Queues.newConcurrentLinkedQueue() | pulsar | 3f779a401ab72d39150d3df4958660b58ac0e59c | org.apache.pulsar.client.impl.ClientCnx | | _1 | waitingLookupRequests |
---|
_2 | waitingLookupRequests |
---|
| xyz | Queues.newArrayBlockingQueue((conf.getMaxLookupRequest() - conf.getConcurrentLookupRequest())) |
---|
| - com.google.common.collect.Queues
| xyz | Queues.newConcurrentLinkedQueue() |
---|
| AssignedTo | False |