Example of multi-threading Solr updates

SolrUpdater.java

public class SolrUpdater implements Runnable {
  private final SolrInputDocument doc = new SolrInputDocument();
  private final UpdateRequest req = new UpdateRequest();
  private final SolrServer solr;
  private final BlockingQueue<String> strings;
  private final AtomicLong id;

  public SolrUpdater(SolrServer solr, BlockingQueue<String> strings,
      AtomicLong id) {
    this.solr = solr;
    this.strings = strings;
    this.id = id;
  }

  @Override
  public void run() {
    while(true) {
      String text = strings.take();
      doc.setField("id", "doc-" + id.getAndIncrement());
      doc.setField("text", text);
      req.add(doc);
      req.process(solr);
      req.clear();
      doc.clear();
    }
  }
}