code: def test_simple_multi_threading_example():
      tmpdir = tempfile.mkdtemp()
  
      n = 100
      tmpfiles = []
      for i in range(n):
          tmpfiles.append(
              tempfile.NamedTemporaryFile(
                  dir=tmpdir, suffix=".JPEG", delete=False
              )
          )
          im = Image.new("RGB", original_dimensions)
          im.save(tmpfiles[i].name, "JPEG")
  
      p = Augmentor.Pipeline(tmpdir)
      assert len(p.augmentor_images) == n
  
      p.resize(
          probability=1,
          width=larger_dimensions[0],
          height=larger_dimensions[1],
      )
      p.sample(n, multi_threaded=True)
  
      generated_images = glob.glob(
          os.path.join(tmpdir, "output", "*.JPEG")
      )
      number_of_gen_images = len(generated_images)
  
      assert number_of_gen_images == n
  
      for im_path in generated_images:
          im_g = Image.open(im_path)
          assert im_g.size == larger_dimensions
  
      # Clean up
      for t in tmpfiles:
          t.close()
  
file_path: Augmentor/tests/test_multi_threading.py
imports: import os
  import sys
  import Augmentor
  import tempfile
  import io
  import shutil
  from PIL import Image
  from Augmentor import Operations
  import glob
label_desc: Use image node_id 1 for calling a global function with example usage: test_simple_multi_threading_example() without return types