private static class MediawikiImporter.wikiConsumer
extends java.lang.Object
implements java.util.concurrent.Callable<java.lang.Integer>
Modifier and Type | Field and Description |
---|---|
private int |
count |
private java.util.concurrent.BlockingQueue<MediawikiImporter.wikiraw> |
entries |
protected static MediawikiImporter.wikiraw |
poison |
private MediawikiImporter.indexProducer |
producer |
Constructor and Description |
---|
MediawikiImporter.wikiConsumer(int bufferCount,
MediawikiImporter.indexProducer producer) |
Modifier and Type | Method and Description |
---|---|
java.lang.Integer |
call() |
void |
consume(MediawikiImporter.wikiraw b) |
private final java.util.concurrent.BlockingQueue<MediawikiImporter.wikiraw> entries
protected static MediawikiImporter.wikiraw poison
private final MediawikiImporter.indexProducer producer
private int count
public MediawikiImporter.wikiConsumer(int bufferCount, MediawikiImporter.indexProducer producer)
public void consume(MediawikiImporter.wikiraw b)
public java.lang.Integer call()
call
in interface java.util.concurrent.Callable<java.lang.Integer>