12Parsec/bananaSPLIT
3
0
Fork 0
Code Issues Releases Wiki Activity

Il lancio di tanti thread concorrenti fa casino, il numero incrementale

Browse Source 
del file non viene resettato per ogni thread (inspiegabile)
This commit is contained in:
Emanuele
2019-12-13 12:34:02 +01:00
parent 3826c7d2d1
commit 275101eed3
2 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
bananaSPLIT/libbananasplit/libsplit.py
View File

@@ -51,6 +51,7 @@ class bananaSPLITTER(threading.Thread):
except UnicodeDecodeError as ee: except UnicodeDecodeError as ee:
self.log.critical("Il file [{}] contiene caratteri non compatibili con la codifica scelta! [{}]" self.log.critical("Il file [{}] contiene caratteri non compatibili con la codifica scelta! [{}]"
.format(self.fileParams['name'],ee)) .format(self.fileParams['name'],ee))
os.rmdir(self.outPath)
pass pass
def openFile(self): def openFile(self):
@@ -63,6 +64,7 @@ class bananaSPLITTER(threading.Thread):
except IOError as e: except IOError as e:
self.log.critical("Impossibile aprire il file: {}! [{}]".format(self.fileName,e)) self.log.critical("Impossibile aprire il file: {}! [{}]".format(self.fileName,e))
raise BaseException("OpenFile") raise BaseException("OpenFile")
os.rmdir(self.outPath)
pass pass
def remEmptyLines(self): def remEmptyLines(self):

2
bananaSPLIT/libtestmain.py
View File

@@ -26,6 +26,8 @@ if __name__ == "__main__":
splitter = bananaSPLITTER(fileParams=deepcopy(splconf), logger=logger) splitter = bananaSPLITTER(fileParams=deepcopy(splconf), logger=logger)
splist.append(splitter) splist.append(splitter)
splitter.start() splitter.start()
splitter.join()
logger.info("\n"+"="*50+"\n\tFINITO!!!\n"+"="*50) logger.info("\n"+"="*50+"\n\tFINITO!!!\n"+"="*50)