raytroop/ThreadPoolExecutor.md

## ThreadPoolExecutor.md

      
    Raw
  

              ThreadPoolExecutor.md
            
          
    from concurrent.futures import ThreadPoolExecutor
fastai
with ThreadPoolExecutor(num_cpus()) as e:
  ims = e.map(lambda fname: safely_process(fname), fnames)
dl2
def resize_mask(fn):
    Image.open(fn).resize((128,128)).save((fn.parent.parent)/'train_masks-128'/fn.name)

files = list((PATH/'train_masks_png').iterdir())
with ThreadPoolExecutor(8) as e: 
  e.map(resize_mask, files)