This is an automated email from the ASF dual-hosted git repository.
ggregory pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/commons-io.git
The following commit(s) were added to refs/heads/master by this push:
new 0cc94ec [IO-510] Add and adapt ReadAheadInputStream and
BufferedFileChannelInputStream from Apache Spark.
0cc94ec is described below
commit 0cc94ec855aaca26bb13a206874612f0381e4c9a
Author: Gary Gregory <[email protected]>
AuthorDate: Thu Oct 29 21:01:59 2020 -0400
[IO-510] Add and adapt ReadAheadInputStream and
BufferedFileChannelInputStream from Apache Spark.
Lowest level ctor does not need to be public for now.
---
src/main/java/org/apache/commons/io/input/ReadAheadInputStream.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/src/main/java/org/apache/commons/io/input/ReadAheadInputStream.java
b/src/main/java/org/apache/commons/io/input/ReadAheadInputStream.java
index be65b38..9f6c7f0 100644
--- a/src/main/java/org/apache/commons/io/input/ReadAheadInputStream.java
+++ b/src/main/java/org/apache/commons/io/input/ReadAheadInputStream.java
@@ -54,11 +54,11 @@ public class ReadAheadInputStream extends InputStream {
/**
* Creates a new daemon thread.
- *
+ *
* @param r the thread's runnable.
* @return a new daemon thread.
*/
- private static Thread newThread(Runnable r) {
+ private static Thread newThread(final Runnable r) {
final Thread thread = new Thread(r, "commons-io-read-ahead");
thread.setDaemon(true);
return thread;
@@ -140,7 +140,7 @@ public class ReadAheadInputStream extends InputStream {
* @param executorService An executor service for the read-ahead thread.
* @param shutdownExecutorService Whether or not to shutdown the given
ExecutorService on close.
*/
- public ReadAheadInputStream(final InputStream inputStream, final int
bufferSizeInBytes,
+ private ReadAheadInputStream(final InputStream inputStream, final int
bufferSizeInBytes,
final ExecutorService executorService, final boolean
shutdownExecutorService) {
if (bufferSizeInBytes <= 0) {
throw new IllegalArgumentException(
