public/kcc
1
0
Fork 0
mirror of https://github.com/ciromattia/kcc synced 2026-09-30 22:52:32 +00:00
Code Issues Releases Wiki Activity

Tweaked KindleGen/KindleUnpack multiprocessing

Browse Source
This commit is contained in:
Paweł Jastrzębski
2013-11-05 16:11:14 +01:00
parent c0f4bc021a
commit bdd10c7617
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kcc/KCC_gui.py
+10 -1
View File
@@ -257,14 +257,19 @@ class KindleUnpackThread(QtCore.QRunnable):
class WorkerThread(QtCore.QThread): class WorkerThread(QtCore.QThread):
#noinspection PyArgumentList
def __init__(self): def __init__(self):
QtCore.QThread.__init__(self) QtCore.QThread.__init__(self)
self.pool = QtCore.QThreadPool() self.pool = QtCore.QThreadPool()
self.pool.setMaxThreadCount(1)
self.conversionAlive = False self.conversionAlive = False
self.errors = False self.errors = False
self.kindlegenErrorCode = [0] self.kindlegenErrorCode = [0]
self.workerOutput = [] self.workerOutput = []
# 4 should be safe value. It will not melt 32bit enviroments and machines with pathologically low amount of RAM.
if QtCore.QThread.idealThreadCount() < 4:
self.threadNumber = QtCore.QThread.idealThreadCount()
else:
self.threadNumber = 4
def __del__(self): def __del__(self):
self.wait() self.wait()
@@ -375,6 +380,7 @@ class WorkerThread(QtCore.QThread):
self.emit(QtCore.SIGNAL("progressBarTick")) self.emit(QtCore.SIGNAL("progressBarTick"))
self.emit(QtCore.SIGNAL("addMessage"), 'Creating MOBI file...', 'info') self.emit(QtCore.SIGNAL("addMessage"), 'Creating MOBI file...', 'info')
self.workerOutput = [] self.workerOutput = []
self.pool.setMaxThreadCount(self.threadNumber)
for item in outputPath: for item in outputPath:
worker = KindleGenThread(item) worker = KindleGenThread(item)
worker.signals.result.connect(self.addResult) worker.signals.result.connect(self.addResult)
@@ -398,6 +404,9 @@ class WorkerThread(QtCore.QThread):
self.emit(QtCore.SIGNAL("addMessage"), 'Creating MOBI file... <b>Done!</b>', 'info', True) self.emit(QtCore.SIGNAL("addMessage"), 'Creating MOBI file... <b>Done!</b>', 'info', True)
self.emit(QtCore.SIGNAL("addMessage"), 'Cleaning MOBI file...', 'info') self.emit(QtCore.SIGNAL("addMessage"), 'Cleaning MOBI file...', 'info')
self.workerOutput = [] self.workerOutput = []
# Multithreading KindleUnpack in current form is a waste of resources.
# Unless we higly optimise KindleUnpack or drop 32bit support this will not change.
self.pool.setMaxThreadCount(1)
for item in outputPath: for item in outputPath:
worker = KindleUnpackThread([item, profile]) worker = KindleUnpackThread([item, profile])
worker.signals.result.connect(self.addResult) worker.signals.result.connect(self.addResult)