stevazi/addon
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

test processi in ricerca globale

Browse Source
This commit is contained in:
mac12m99
2019-11-20 11:36:26 +01:00
committed by marco
parent 9333a976a1
commit 3f32c572cd
1 changed files with 21 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
specials/search.py
+21 -8
View File
@@ -18,7 +18,8 @@ from platformcode import config, logger
from platformcode import platformtools from platformcode import platformtools
from core.support import typo from core.support import typo
import cPickle, shutil import cPickle, shutil
global_lock = threading.Lock() from multiprocessing import Process
multi = 'process'
addon = xbmcaddon.Addon('metadata.themoviedb.org') addon = xbmcaddon.Addon('metadata.themoviedb.org')
def_lang = addon.getSetting('language') def_lang = addon.getSetting('language')
@@ -573,10 +574,15 @@ def do_search(item, categories=None):
logger.info("Búsqueda cancelada") logger.info("Búsqueda cancelada")
return itemlist return itemlist
if multithread: if multithread:
t = Thread(target=channel_search, args=[search_results, channel_parameters, tecleado], if multi == 'threads':
name=channel_parameters["title"]) t = Thread(target=channel_search, args=[search_results, channel_parameters, tecleado],
t.setDaemon(True) name=channel_parameters["title"])
t.start() t.setDaemon(True)
t.start()
else:
t = Process(target=channel_search, args=[search_results, channel_parameters, tecleado],
name=channel_parameters["title"])
t.start()
threads.append(t) threads.append(t)
# Modo single Thread # Modo single Thread
else: else:
@@ -606,19 +612,26 @@ def search_progress(threads):
import math import math
progreso = platformtools.dialog_progress_bg(config.get_localized_string(20000), "") progreso = platformtools.dialog_progress_bg(config.get_localized_string(20000), "")
pendent = [a for a in threads if a.isAlive()] if multi == 'threads':
pendent = [a for a in threads if a.isAlive()]
else:
pendent = [a for a in threads if a.is_alive()]
if len(pendent) > 0: t = float(100) / len(pendent) if len(pendent) > 0: t = float(100) / len(pendent)
while len(pendent) > 0: while len(pendent) > 0:
index = (len(threads) - len(pendent)) + 1 index = (len(threads) - len(pendent)) + 1
percentage = int(math.ceil(index * t)) percentage = int(math.ceil(index * t))
list_pendent_names = [a.getName() for a in pendent] list_pendent_names = ['test' for a in pendent]
mensaje = config.get_localized_string(70282) % (", ".join(list_pendent_names)) mensaje = config.get_localized_string(70282) % (", ".join(list_pendent_names))
progreso.update(percentage, progreso.update(percentage,
config.get_localized_string(60521) % (len(threads) - len(pendent) + 1, len(threads)), config.get_localized_string(60521) % (len(threads) - len(pendent) + 1, len(threads)),
mensaje) mensaje)
time.sleep(0.5) time.sleep(0.5)
pendent = [a for a in threads if a.isAlive()] if multi == 'threads':
pendent = [a for a in threads if a.isAlive()]
else:
pendent = [a for a in threads if a.is_alive()]
progreso.close() progreso.close()
with open(os.path.join(res_dir, 'done'), 'w') as f: with open(os.path.join(res_dir, 'done'), 'w') as f:
f.write('1') f.write('1')