No need for volatile
This commit is contained in:
parent
d27a27c980
commit
71ad0125d6
@ -34,7 +34,7 @@ public class ChunkedFile implements ChunkedByteInput {
|
|||||||
private final long startOffset;
|
private final long startOffset;
|
||||||
private final long endOffset;
|
private final long endOffset;
|
||||||
private final int chunkSize;
|
private final int chunkSize;
|
||||||
private volatile long offset;
|
private long offset;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new instance that fetches data from the specified file.
|
* Creates a new instance that fetches data from the specified file.
|
||||||
|
@ -29,7 +29,7 @@ public interface ChunkedInput<B> {
|
|||||||
boolean isEndOfInput() throws Exception;
|
boolean isEndOfInput() throws Exception;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Releases the resources associated with the stream.
|
* Releases the resources associated with the input.
|
||||||
*/
|
*/
|
||||||
void close() throws Exception;
|
void close() throws Exception;
|
||||||
|
|
||||||
|
@ -36,7 +36,7 @@ public class ChunkedNioFile implements ChunkedByteInput {
|
|||||||
private long startOffset;
|
private long startOffset;
|
||||||
private final long endOffset;
|
private final long endOffset;
|
||||||
private final int chunkSize;
|
private final int chunkSize;
|
||||||
private volatile long offset;
|
private long offset;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new instance that fetches data from the specified file.
|
* Creates a new instance that fetches data from the specified file.
|
||||||
|
@ -30,7 +30,7 @@ public class ChunkedNioStream implements ChunkedByteInput {
|
|||||||
private final ReadableByteChannel in;
|
private final ReadableByteChannel in;
|
||||||
|
|
||||||
private final int chunkSize;
|
private final int chunkSize;
|
||||||
private volatile long offset;
|
private long offset;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Associated ByteBuffer
|
* Associated ByteBuffer
|
||||||
|
@ -36,7 +36,7 @@ public class ChunkedStream implements ChunkedByteInput {
|
|||||||
|
|
||||||
private final PushbackInputStream in;
|
private final PushbackInputStream in;
|
||||||
private final int chunkSize;
|
private final int chunkSize;
|
||||||
private volatile long offset;
|
private long offset;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new instance that fetches data from the specified stream.
|
* Creates a new instance that fetches data from the specified stream.
|
||||||
|
Loading…
Reference in New Issue
Block a user