Searched defs:runners (Results 1 - 2 of 2) sorted by relevance

/lucene-3.6.0/solr/solrj/src/java/org/apache/solr/client/solrj/impl/
H A DStreamingUpdateSolrServer.java66 final Queue<Runner> runners; field in class:StreamingUpdateSolrServer
90 runners = new LinkedList<Runner>();
188 // in which case, the next queue.put() would block and there would be no runners to handle it.
191 synchronized (runners) {
192 if (runners.size() == 1 && queue.remainingCapacity() == 0) {
196 runners.remove( this );
239 synchronized( runners ) {
240 if( runners.isEmpty()
241 || (queue.remainingCapacity() < queue.size() // queue is half full and we can add more runners
242 && runners
[all...]
H A DConcurrentUpdateSolrServer.java70 final Queue<Runner> runners; field in class:ConcurrentUpdateSolrServer
103 runners = new LinkedList<Runner>();
207 // runners to handle it.
211 synchronized (runners) {
212 if (runners.size() == 1 && queue.remainingCapacity() == 0) {
216 runners.remove(this);
258 synchronized (runners) {
259 if (runners.isEmpty() || (queue.remainingCapacity() < queue.size() // queue
268 // runners
269 && runners
[all...]

Completed in 12 milliseconds