From 6122c6332df1088e4420515e8e92c51dec85c897 Mon Sep 17 00:00:00 2001
From: Reinhard Pointner <rednoah@users.noreply.github.com>
Date: Tue, 4 Nov 2014 13:45:27 +0000
Subject: [PATCH] * variable threadPoolSize for parallel checksum computations

---
 source/net/filebot/Settings.java                      | 11 +++++++++--
 .../filebot/ui/sfv/ChecksumComputationService.java    |  7 +++++--
 2 files changed, 14 insertions(+), 4 deletions(-)

diff --git a/source/net/filebot/Settings.java b/source/net/filebot/Settings.java
index 82b4b886..2270ea1b 100644
--- a/source/net/filebot/Settings.java
+++ b/source/net/filebot/Settings.java
@@ -7,6 +7,8 @@ import java.io.File;
 import java.util.Locale;
 import java.util.MissingResourceException;
 import java.util.ResourceBundle;
+import java.util.logging.Level;
+import java.util.logging.Logger;
 import java.util.prefs.BackingStoreException;
 import java.util.prefs.Preferences;
 
@@ -90,10 +92,15 @@ public final class Settings {
 
 	public static int getPreferredThreadPoolSize() {
 		try {
-			return Integer.parseInt(System.getProperty("threadPool"));
+			String threadPool = System.getProperty("threadPool");
+			if (threadPool != null) {
+				return Integer.parseInt(threadPool);
+			}
 		} catch (Exception e) {
-			return Runtime.getRuntime().availableProcessors();
+			Logger.getLogger(Settings.class.getName()).log(Level.WARNING, e.toString());
 		}
+
+		return Runtime.getRuntime().availableProcessors();
 	}
 
 	public static String getApplicationDeployment() {
diff --git a/source/net/filebot/ui/sfv/ChecksumComputationService.java b/source/net/filebot/ui/sfv/ChecksumComputationService.java
index a59808c2..6e450e9d 100644
--- a/source/net/filebot/ui/sfv/ChecksumComputationService.java
+++ b/source/net/filebot/ui/sfv/ChecksumComputationService.java
@@ -13,6 +13,7 @@ import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 
+import net.filebot.Settings;
 import net.filebot.util.DefaultThreadFactory;
 
 class ChecksumComputationService {
@@ -24,6 +25,8 @@ class ChecksumComputationService {
 	private final AtomicInteger completedTaskCount = new AtomicInteger(0);
 	private final AtomicInteger totalTaskCount = new AtomicInteger(0);
 
+	private final int threadPoolSize = Settings.getPreferredThreadPoolSize();
+
 	public ExecutorService newExecutor() {
 		return new ChecksumComputationExecutor();
 	}
@@ -83,7 +86,7 @@ class ChecksumComputationService {
 	private class ChecksumComputationExecutor extends ThreadPoolExecutor {
 
 		public ChecksumComputationExecutor() {
-			super(1, 2 * Runtime.getRuntime().availableProcessors(), 0L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new DefaultThreadFactory("ChecksumComputationPool", Thread.MIN_PRIORITY));
+			super(1, threadPoolSize, 0L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(), new DefaultThreadFactory("ChecksumComputationPool", Thread.MIN_PRIORITY));
 
 			synchronized (executors) {
 				if (executors.add(this) && executors.size() == 1) {
@@ -100,7 +103,7 @@ class ChecksumComputationService {
 			// for a few files, use one thread
 			// for lots of files, use multiple threads
 			// e.g 50 files ~ 1 thread, 200 files ~ 2 threads, 1000 files ~ 3 threads, 40000 files ~ 5 threads
-			return max(1, (int) ((Runtime.getRuntime().availableProcessors() / 2) + log10(getQueue().size()) - 1));
+			return max(1, (int) ((threadPoolSize / 2) + log10(getQueue().size()) - 1));
 		}
 
 		@Override