parallel_video_processing.py

import cv2
import time
import concurrent.futures


def display_frames(name):
    cap = cv2.VideoCapture(name)
    while True:
        ret, frames = cap.read()
        
        # process frames here
        
        if not ret:
            break
        cv2.imshow(str(cap), frames)
        cv2.waitKey(1)

    cap.release()

    return name


def main():
    t1 = time.time()
    names = [
      'test1.avi',
      'test2.avi',
      'test3.avi',
      'test4.avi']

    with concurrent.futures.ProcessPoolExecutor(max_workers=4) as executor:
        executor.map(display_frames, names)

    cv2.destroyAllWindows()
    print("Elapse timee: {} seconds".format(time.time()-t1))


if __name__ == '__main__':
    main()