Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package com.ning.compress.lzf.parallel;
 
 

Author(s):
C├ędrik LIME
class CompressTask implements Callable<LZFChunk> {
	private static final ThreadLocal<ChunkEncoderENCODER = new ThreadLocal<ChunkEncoder>() {
		protected ChunkEncoder initialValue() {
			return ChunkEncoderFactory.optimalInstance();
		}
	};
	protected byte[] data;
	protected int offsetlength;
	public CompressTask(byte[] inputint offsetint lengthBlockManager blockManager) {
		super();
		this. = input;
		this. = offset;
		this. = length;
		this. = blockManager;
	}
	public CompressTask(byte[] inputBlockManager blockManager) {
		this(input, 0, input.lengthblockManager);
	}

	public LZFChunk call() {
		if ( != null) {
			// input data is fully processed, we can now discard it
			return lzfChunk;
else {
			// cleanup time!
			return null;
		}
	}
New to GrepCode? Check out our FAQ X