#process a filtered list of files by calling reapeatedly a
#console app(no console opens) in two parallel threads with a timeout
#Antoni Gual May 2015
import os
import threading
import subprocess
def my_thread():
global files,path,timeout,options
myname= threading.currentThread().getName()
while files:
#create command to run
nextfile=files.pop()
#print name of thread and command being run
print('Thread {0} starts processing {1}'.format(myname,nextfile))
f=path + nextfile + options
try:
#timeout interrupts frozen command, shell=True does'nt open a console
subprocess.check_call(args= f , shell=True, timeout=timeout)
except subprocess.TimeoutExpired:
print('Thread {0} Processing {0} took too long' .format(myname,nextfile))
except subprocess.CalledProcessError as e:
print ('Thread {0} Processing {1} returned error {2}:{3}'.format(myname,nextfile,e.returncode,e.output))
except Exception as e:
print ('Thread {0} Processing {1} returned error {2}'.format(myname,nextfile,type(e).__name__))
print ('thread {0} stopped'.format(myname))
timeout=150
#the patth to the console app
exe_path = '\"C:/Program files/Calibre2/ebook-convert.exe" '
file_path = './' # so it can be called from a console opened in the folder whrer files are
options = '\" .epub > nul'
#filter the files in file_path
extensions = ['mobi','lit','prc','azw','rtf','odf' ] ;
files = [fn for fn in os.listdir(file_path) if any([fn.endswith(ext) for ext in extensions])];
path=exe_path +' \"'+file_path
#runs the same thread twice, each with a name
t1= threading.Thread(target=my_thread, name='uno' )
t1.start()
t2= threading.Thread(target=my_thread,name='dos' )
t2.start()
Diff to Previous Revision
--- revision 2 2015-05-19 15:42:55
+++ revision 3 2015-05-19 19:31:59
@@ -1,5 +1,5 @@
-#process a filtered list of files by calling reapeatedly a
-#command (no console opens) in two parallel threads with a timeout
+#process a filtered list of files by calling reapeatedly a
+#console app(no console opens) in two parallel threads with a timeout
#Antoni Gual May 2015
import os
@@ -7,24 +7,35 @@
import subprocess
def my_thread():
- global files,path,timeout,options
- while files:
- #create command to run
- f=path + files.pop() + options
- #print name of thread and command being run
- print(threading.currentThread().getName(),'>',f)
- #timeout interruptrs frozen commnad, shell=True does'nt open a console
- subprocess.check_call(args= f , shell=True, timeout=timeout)
-
-timeout=300 #kill command after 5 minutes (300 secs)
-#threads will build a command line of 'exe_path file_path filename options'
-exe_path = '\"C:/archivos de programa/Calibre2/ebook-convert.exe" '
-file_path = "C:/Users/AGUAL/Downloads/share/Robert A Heinlein Bibliography/"
-options = '\" .epub'
+ global files,path,timeout,options
+ myname= threading.currentThread().getName()
+ while files:
+ #create command to run
+ nextfile=files.pop()
+ #print name of thread and command being run
+ print('Thread {0} starts processing {1}'.format(myname,nextfile))
+ f=path + nextfile + options
+ try:
+ #timeout interrupts frozen command, shell=True does'nt open a console
+ subprocess.check_call(args= f , shell=True, timeout=timeout)
+ except subprocess.TimeoutExpired:
+ print('Thread {0} Processing {0} took too long' .format(myname,nextfile))
+ except subprocess.CalledProcessError as e:
+ print ('Thread {0} Processing {1} returned error {2}:{3}'.format(myname,nextfile,e.returncode,e.output))
+ except Exception as e:
+ print ('Thread {0} Processing {1} returned error {2}'.format(myname,nextfile,type(e).__name__))
+ print ('thread {0} stopped'.format(myname))
+
+
+timeout=150
+#the patth to the console app
+exe_path = '\"C:/Program files/Calibre2/ebook-convert.exe" '
+file_path = './' # so it can be called from a console opened in the folder whrer files are
+options = '\" .epub > nul'
#filter the files in file_path
-extenstions = ['mobi','lit','prc','azw' ] ;
-files = [fn for fn in os.listdir(file_path) if any([fn.endswith(ext) for ext in extenstions])];
+extensions = ['mobi','lit','prc','azw','rtf','odf' ] ;
+files = [fn for fn in os.listdir(file_path) if any([fn.endswith(ext) for ext in extensions])];
path=exe_path +' \"'+file_path
#runs the same thread twice, each with a name
