public static final class RowHandleMap.initDataConsumer extends java.lang.Object implements java.util.concurrent.Callable<RowHandleMap>
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.BlockingQueue<RowHandleMap.entry> |
cache |
private RowHandleMap |
map |
private java.util.concurrent.Future<RowHandleMap> |
result |
Constructor and Description |
---|
RowHandleMap.initDataConsumer(RowHandleMap map) |
Modifier and Type | Method and Description |
---|---|
RowHandleMap |
call() |
void |
close() |
void |
consume(byte[] key,
long l)
hand over another entry that shall be inserted into the HandleMap with an addl method
|
void |
finish()
to signal the initialization thread that no more entries will be submitted with consumer()
this method must be called.
|
RowHandleMap |
result()
this must be called after a finish() was called.
|
protected void |
setResult(java.util.concurrent.Future<RowHandleMap> result) |
private final java.util.concurrent.BlockingQueue<RowHandleMap.entry> cache
private final RowHandleMap map
private java.util.concurrent.Future<RowHandleMap> result
public RowHandleMap.initDataConsumer(RowHandleMap map)
protected final void setResult(java.util.concurrent.Future<RowHandleMap> result)
public final void consume(byte[] key, long l)
key
- l
- public final void finish()
public final RowHandleMap result() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
java.lang.InterruptedException
java.util.concurrent.ExecutionException
public final RowHandleMap call() throws java.io.IOException
call
in interface java.util.concurrent.Callable<RowHandleMap>
java.io.IOException
public void close()