From 1895aa127dde2eb28864184ef33e6627d97e06a4 Mon Sep 17 00:00:00 2001
From: Paweł Jastrzębski <pawelj@iosphe.re>
Date: Sun, 19 Mar 2017 07:48:39 +0100
Subject: Decrease memory usage

---
 kindlecomicconverter/comic2ebook.py | 8 +++++---
 kindlecomicconverter/comic2panel.py | 4 ++--
 2 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/kindlecomicconverter/comic2ebook.py b/kindlecomicconverter/comic2ebook.py
index f5c6320..f2d0fc6 100755
--- a/kindlecomicconverter/comic2ebook.py
+++ b/kindlecomicconverter/comic2ebook.py
@@ -455,7 +455,7 @@ def buildEPUB(path, chapterNames, tomeNumber):
 
 def imgDirectoryProcessing(path):
     global workerPool, workerOutput
-    workerPool = Pool()
+    workerPool = Pool(maxtasksperchild=100)
     workerOutput = []
     options.imgMetadata = {}
     options.imgOld = []
@@ -1185,9 +1185,11 @@ def makeMOBI(work, qtGUI=None):
         threadNumber = 1
     elif 2 < availableMemory <= 4:
         threadNumber = 2
-    else:
+    elif 4 < availableMemory <= 8:
         threadNumber = 4
-    makeMOBIWorkerPool = Pool(threadNumber)
+    else:
+        threadNumber = None
+    makeMOBIWorkerPool = Pool(threadNumber, maxtasksperchild=10)
     for i in work:
         makeMOBIWorkerPool.apply_async(func=makeMOBIWorker, args=(i, ), callback=makeMOBIWorkerTick)
     makeMOBIWorkerPool.close()
diff --git a/kindlecomicconverter/comic2panel.py b/kindlecomicconverter/comic2panel.py
index e173575..8618cda 100644
--- a/kindlecomicconverter/comic2panel.py
+++ b/kindlecomicconverter/comic2panel.py
@@ -238,13 +238,13 @@ def main(argv=None, qtGUI=None):
             work = []
             pagenumber = 1
             splitWorkerOutput = []
-            splitWorkerPool = Pool()
+            splitWorkerPool = Pool(maxtasksperchild=10)
             if options.merge:
                 print("Merging images...")
                 directoryNumer = 1
                 mergeWork = []
                 mergeWorkerOutput = []
-                mergeWorkerPool = Pool()
+                mergeWorkerPool = Pool(maxtasksperchild=10)
                 mergeWork.append([options.targetDir])
                 for root, dirs, files in os.walk(options.targetDir, False):
                     dirs, files = walkSort(dirs, files)
-- 
cgit 1.4.1