Использование многопроцессорной обработки с opencv для параллельного запуска функции с вводом кадров с разных камер. - PullRequest
0 голосов
/ 08 сентября 2018

Я пытаюсь запустить функцию, которая берет кадры из различных каналов камеры и сохраняет их на диск.

У меня есть три камеры, подключенные к USB-портам моего ноутбука, и я пытаюсь запустить все камеры одновременно и пытаюсь выполнить некоторые действия с этими захваченными изображениями / кадрами. Для простоты я просто сохраняю их на диск. Вот код ниже:

from __future__ import absolute_import
from __future__ import division
from __future__ import print_function

from multiprocessing import Process

import cv2
#from scipy.stats import math
import datetime
count = 0
def saving_frame(frame):
    count = 0
    date_string = datetime.datetime.now().strftime("%Y-%m-%d-%H:%M")
    count = count +1 
    cv2.imwrite('Frame_'+str(count)+date_string+'.png',frame)
    return

def runInParallel(*fns):
      proc = []
      for fn in fns:
        p = Process(target=fn)
        p.start()
        proc.append(p)
      for p in proc:
        p.join()


video_capture_1 = cv2.VideoCapture(0)

video_capture_2 = cv2.VideoCapture(1)

video_capture_3 = cv2.VideoCapture(2)

print ('Start Rec')

while True:
    ret_1, frame_1 = video_capture_1.read()
    ret_2, frame_2 = video_capture_2.read()
    ret_3, frame_3 = video_capture_3.read()

    runInParallel(saving_frame(frame_1),saving_frame(frame_2),saving_frame(frame_3))

    cv2.imshow('frame1', frame_1)
    cv2.imshow('frame2', frame_2)
    cv2.imshow('frame3', frame_3)
    if cv2.waitKey(1) & 0xFF == ord('q'):
        break
video_capture_1.release()
video_capture_2.release()
video_capture_3.release()

cv2.destroyAllWindows()

Однако приведенный выше код не сохраняет ни одного кадра. Не могли бы вы помочь мне с этим?

...