wip
This commit is contained in:
6
mt.py
6
mt.py
@@ -22,11 +22,11 @@ class mt():
|
|||||||
self.__threads = []
|
self.__threads = []
|
||||||
if useprocesses:
|
if useprocesses:
|
||||||
mp.set_start_method('fork', True)
|
mp.set_start_method('fork', True)
|
||||||
manager = mp.Manager()
|
self.__manager = mp.Manager()
|
||||||
self.__results = manager.list()
|
self.__results = self.__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])
|
self.__keepalive = self.__manager.list([0])
|
||||||
else:
|
else:
|
||||||
self.__results = []
|
self.__results = []
|
||||||
self.__progress = 0
|
self.__progress = 0
|
||||||
|
|||||||
Reference in New Issue
Block a user