diff options
Diffstat (limited to 'src/main/java/org/openslx/filetransfer/util/HashChecker.java')
-rw-r--r-- | src/main/java/org/openslx/filetransfer/util/HashChecker.java | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/main/java/org/openslx/filetransfer/util/HashChecker.java b/src/main/java/org/openslx/filetransfer/util/HashChecker.java index 3c173fb..13c06db 100644 --- a/src/main/java/org/openslx/filetransfer/util/HashChecker.java +++ b/src/main/java/org/openslx/filetransfer/util/HashChecker.java @@ -14,7 +14,7 @@ public class HashChecker { private static final Logger LOGGER = Logger.getLogger( HashChecker.class ); - private final BlockingQueue<HashTask> queue = new LinkedBlockingQueue<>( 10 ); + private final BlockingQueue<HashTask> queue; private final List<Thread> threads = new ArrayList<>(); @@ -24,7 +24,13 @@ public class HashChecker public HashChecker( String algorithm ) throws NoSuchAlgorithmException { + this( algorithm, 10 ); + } + + public HashChecker( String algorithm, int queueLen ) throws NoSuchAlgorithmException + { this.algorithm = algorithm; + this.queue = new LinkedBlockingQueue<>( queueLen ); CheckThread thread = new CheckThread( false ); thread.start(); threads.add( thread ); |