From 0b3ab15a67646e98bc3dbee32d8c2e923b2b3d3f Mon Sep 17 00:00:00 2001
From: Simon Rettberg
Date: Sat, 12 Sep 2015 18:13:53 +0200
Subject: Make queue len of hash checker configurable

---
 src/main/java/org/openslx/filetransfer/util/HashChecker.java | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

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<>();
 
@@ -23,8 +23,14 @@ public class HashChecker
 	private volatile boolean invalid = false;
 
 	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 );
-- 
cgit v1.2.3-55-g7522