wea_ondara/master
1
1
Fork 0
Code Issues Pull Requests Releases Wiki Activity

wip

Browse Source
This commit is contained in:
wea_ondara
2020-01-25 13:51:16 +01:00
parent fdc1743d5d
commit 60d966a497
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
mt.py
View File

@@ -26,10 +26,12 @@ class mt():
self.__results = manager.list() self.__results = manager.list()
self.__progress = mp.Value("i", 0) self.__progress = mp.Value("i", 0)
self.__lock = mp.Lock() self.__lock = mp.Lock()
self.__keepalive = manager.list([0])
else: else:
self.__results = [] self.__results = []
self.__progress = 0 self.__progress = 0
self.__lock = th.Lock() self.__lock = th.Lock()
self.__keepalive = [0]
self.__progressinterval = progressinterval self.__progressinterval = progressinterval
for i in range(self.__threadcount): for i in range(self.__threadcount):
self.__results.append([]) self.__results.append([])
@@ -70,6 +72,7 @@ class mt():
self.__inc_progress(len(part)) self.__inc_progress(len(part))
if self.__comment is not None: if self.__comment is not None:
print("\r" + self.__comment + ": " + str(self.__get_progress()) + "/" + str(len(self.__data)) + " ...", end='', flush=True) print("\r" + self.__comment + ": " + str(self.__get_progress()) + "/" + str(len(self.__data)) + " ...", end='', flush=True)
self.__keepalive[0] = 0
with self.__lock: with self.__lock:
self.__results[i] = results self.__results[i] = results
@@ -114,6 +117,7 @@ class mt():
self.__inc_progress(len(part)) self.__inc_progress(len(part))
if self.__comment is not None: if self.__comment is not None:
print("\r" + self.__comment + ": " + str(self.__get_progress()) + "/" + str(len(self.__data)) + " ...", end='', flush=True) print("\r" + self.__comment + ": " + str(self.__get_progress()) + "/" + str(len(self.__data)) + " ...", end='', flush=True)
self.__keepalive[0] = 0
with self.__lock: with self.__lock:
self.__results[i] = results self.__results[i] = results
@@ -160,6 +164,7 @@ class mt():
self.__inc_progress(len(part)) self.__inc_progress(len(part))
if self.__comment is not None: if self.__comment is not None:
print("\r" + self.__comment + ": " + str(self.__get_progress()) + "/" + str(len(self.__data)) + " ...", end='', flush=True) print("\r" + self.__comment + ": " + str(self.__get_progress()) + "/" + str(len(self.__data)) + " ...", end='', flush=True)
self.__keepalive[0] = 0
with self.__lock: with self.__lock:
self.__results[i] = val self.__results[i] = val