Outline of a parallelized video processing code

multiprocessing_cv.py

def process_video(group_number):
  cap = cv2.VideoCapture("input_file.mp4")
  cap.set(cv2.CAP_PROP_POS_FRAMES, frame_jump * group_number)
  proc_frames = 0
  out = cv2.VideoWriter("output_{}.avi".format(group_number), ...)
  while proc_frames < frame_jump:
    ret, frame = cap.read()
    # ... DO SOME STUFF TO frame ... #
    proc_frames += 1
    out.write(frame)
  return None

# Process the video by splitting it into as many fragments as the number of virtual cores you have
import multiprocessing as mp
frame_jump =  cv2.VideoCapture("input_file.mp4").get(cv2.CAP_PROP_FRAME_COUNT) // mp.cpu_count()
mp.Pool(num_processes).map(process_video, range(num_processes))