やりたいこととしては「メイン処理を行いながら、動画の読み込みをサイズ上限を超えないように行う」という処理を行いたいです。
試したことは以下の通りです。
- Python標準の「futures.ThreadPoolExecutor」を使ってみたところFPSが極端に落ちてしまう
(動画読み込み処理が完了するとFPSが元に戻るので、スレッドだとメイン処理と読み込み処理が交互に動いてると見て間違いなさそうです) - Python標準の「futures.ProcessPoolExecutor」を使うとグローバル変数がメイン処理と読み込み処理で共有できない
この場合、一番効率的な並行処理はどういったものがあるのか、ご助力願いたいです。
以下、サンプルソースを記載します。
## スレッドのテスト
import cv2
import os
import sys
import numpy as np
from concurrent import futures
import pygame
from pygame.locals import *
import traceback
MOVIE_PATH = os.path.join(os.path.dirname(__file__), "../img/movie")
test_mp4 = cv2.VideoCapture(MOVIE_PATH+"/test.mp4")
mp4_fps = test_mp4.get(cv2.CAP_PROP_FPS)
frame_list = []
is_game_end = False
def mp4_reset():
global test_mp4, frame_list
test_mp4.set(cv2.CAP_PROP_POS_FRAMES, 0)
frame_list = []
def mp4_read():
global test_mp4, frame_list, is_game_end
while(1):
if is_game_end:
break
if sys.getsizeof(frame_list) > 1000:
continue
ret, frame = test_mp4.read()
if ret:
frame = cv2.cvtColor(frame, cv2.COLOR_BGR2RGB)
frame = np.rot90(frame)
frame = np.flipud(frame)
frame_list.append(frame)
print(sys.getsizeof(frame_list))
print("mp4_read end")
def main():
global frame_list, is_game_end
pygame.init()
screen = pygame.display.set_mode((1280,720))
clock = pygame.time.Clock()
font = pygame.font.SysFont(None, 50)
try :
while(1):
screen.fill((100,100,100))
for event in pygame.event.get():
if event.type == QUIT:
is_game_end = True
pygame.quit()
sys.exit()
elif event.type == KEYDOWN:
if event.key == K_SPACE:
mp4_reset()
if len(frame_list) > 0:
frame = frame_list.pop(0)
frame = pygame.surfarray.make_surface(frame)
screen.blit(frame, (0,0))
text = font.render(f"frame_size:{len(frame_list)}, fps:{clock.get_fps()}", True, (255,255,255))
screen.blit(text, (0,0))
pygame.display.update()
clock.tick(60)
except Exception as e:
is_game_end = True
print(e)
print(traceback.format_exc())
if __name__ == "__main__":
future_list = []
## ▼マルチプロセスで動かそうとしたもの
with futures.ProcessPoolExecutor(max_workers=2) as executor:
future_list.append(executor.submit(mp4_read))
future_list.append(executor.submit(main))
_ = futures.as_completed(fs=future_list)
## ▼スレッドを使用した時のコード
# with futures.ThreadPoolExecutor(max_workers=2) as executor:
# future_list.append(executor.submit(mp4_read))
# future_list.append(executor.submit(main))
# _ = futures.as_completed(fs=future_list)
print("end")
環境は以下の通りです
- python : 3.9.7
- opencv-python : 4.5.4.60
- numpy : 1.21.4
- pygame : 2.1.0
▼PCスペック(参考)
- OS : Windows10 pro
- CPU : Ryzen 9 5950X
- RAM : 64GB
- GPU : GTX 1050ti