private static class MediawikiImporter.indexProducer
extends java.lang.Object
implements java.util.concurrent.Callable<java.lang.Integer>
Modifier and Type | Field and Description |
---|---|
(package private) int |
count |
private java.util.concurrent.BlockingQueue<MediawikiImporter.wikisourcerecord> |
entries |
(package private) java.io.PrintWriter |
out |
protected static MediawikiImporter.wikisourcerecord |
poison |
Constructor and Description |
---|
MediawikiImporter.indexProducer(int bufferCount,
java.io.File indexFile) |
Modifier and Type | Method and Description |
---|---|
java.lang.Integer |
call() |
void |
consume(MediawikiImporter.wikisourcerecord b) |
private final java.util.concurrent.BlockingQueue<MediawikiImporter.wikisourcerecord> entries
java.io.PrintWriter out
protected static MediawikiImporter.wikisourcerecord poison
int count
public MediawikiImporter.indexProducer(int bufferCount, java.io.File indexFile) throws java.io.IOException
java.io.IOException
public void consume(MediawikiImporter.wikisourcerecord b)
public java.lang.Integer call()
call
in interface java.util.concurrent.Callable<java.lang.Integer>