private static class Digest.md5FilechunkConsumer
extends java.lang.Object
implements java.util.concurrent.Callable<java.security.MessageDigest>
Modifier and Type | Field and Description |
---|---|
private java.security.MessageDigest |
digest |
private java.util.concurrent.BlockingQueue<Digest.filechunk> |
empty |
private java.util.concurrent.BlockingQueue<Digest.filechunk> |
filed |
protected static Digest.filechunk |
poison |
Constructor and Description |
---|
Digest.md5FilechunkConsumer(int bufferSize,
int bufferCount) |
Modifier and Type | Method and Description |
---|---|
java.security.MessageDigest |
call() |
void |
consume(Digest.filechunk c) |
Digest.filechunk |
nextFree() |
private final java.util.concurrent.BlockingQueue<Digest.filechunk> empty
private final java.util.concurrent.BlockingQueue<Digest.filechunk> filed
protected static Digest.filechunk poison
private java.security.MessageDigest digest
public Digest.md5FilechunkConsumer(int bufferSize, int bufferCount)
public void consume(Digest.filechunk c)
public Digest.filechunk nextFree() throws java.io.IOException
java.io.IOException
public java.security.MessageDigest call()
call
in interface java.util.concurrent.Callable<java.security.MessageDigest>