- pool = Pool(processes=8) # set the processes max number
- for root, dirs, files in os.walk(srcDir):
- for name in files:
- srcFile = os.path.join(root, name)
- dstFile = os.path.join(dstDir, name)
- print("%s => %s" % (srcFile,dstFile))
- # add_watermark(srcFile,dstFile,fontSize,myText,angle,fill,step)
- result = pool.apply_async(add_watermark,(srcFile,dstFile,fontSize,myText,angle,fill,step))
- pool.close()
- pool.join()