Pythonで1つ目の処理が始まった段階で次の処理を開始したい

Question

前提・実現したいこと

動画再生が始まった段階で次の処理に移行したいです。

発生している問題・エラーメッセージ

for文を回し始めた段階で動画も再生したいのですが並列で処理する方法がわかりません。
threadingなどを使用した場合、並列で2つの命令を処理できるのでしょうか？

該当のソースコード

import cv2
import numpy as np

path = "1.mp4"
b = 1
doga_path = path
cap = cv2.VideoCapture(doga_path)
assert cap.isOpened(), 'Failed to open video file.'
cv2.namedWindow('Frame', cv2.WINDOW_NORMAL)
cv2.setWindowProperty('Frame', cv2.WND_PROP_FULLSCREEN, cv2.WINDOW_FULLSCREEN)

ret, frame = cap.read()
for b in range(20):
    print("123123123")
while ret:
    
    cv2.imshow('Frame', frame)
    if cv2.waitKey(1) & 0xFF == ord('q'):
        break

    ret, frame = cap.read()
else:
    print("---動画終了---")
cap.release()
cv2.destroyAllWindows()

試したこと

asyncioを使用して処理できるかもということで試しましたが並列にできなかったです。
1つ目の処理の終了してから2つ目の処理の実行になりました。

補足情報（FW/ツールのバージョンなど）

Python3.6
openCV3.4

回答をもらって変更したコード

import sys
import time
import csv
import cv2
import numpy as np
from threading import Thread


doga = "1.mp4"
b = 1

def func2(b):
    for b in range(100000):
        print("123123123")
    print("END")

def func1(doga): 
    doga_path = doga
    cap = cv2.VideoCapture(doga_path)
    assert cap.isOpened(), 'Failed to open video file.'
    cv2.namedWindow('Frame', cv2.WINDOW_NORMAL)
    cv2.setWindowProperty('Frame', cv2.WND_PROP_FULLSCREEN, cv2.WINDOW_FULLSCREEN)

    ret, frame = cap.read()
    while ret:
    
        cv2.imshow('Frame', frame)
        if cv2.waitKey(1) & 0xFF == ord('q'):
            break

        ret, frame = cap.read()
    else:
        print("---動画終了---")
    cap.release()
    cv2.destroyAllWindows()

if __name__ == '__main__':
    
    p2 = Thread(target = func2(b))
    p1 = Thread(target = func1(doga))
    p2.start()
    #event.set()
    p1.start()

Answer 1

たとえばこんなふうにすれば、複数の関数を同時に走らせることができます

import numpy as np
from threading import Thread

def func_1(num):
    print('func_1 Start')
    tmp = np.sum(np.arange(0, num))
    print('func_1 End')

def func_2(num):
    print('func_2 Start')
    tmp = np.sum(np.arange(0, num))
    print('func_2 End')

def func_3(num):
    print('func_3 Start')
    tmp = np.sum(np.arange(0, num))
    print('func_3 End')

if __name__ == '__main__':
    p1 = Thread(target=func_1, args=(500000000,))
    p2 = Thread(target=func_2, args=(500000000,))
    p1.start()         # func_1が動き始める
    p2.start()         # func_1の終了を待たずにfunc_2が動き始める
    func_3(500000000)  # func_1, func_2の終了を待たずにfunc_3が動き始める

手抜きで各関数の内容は実質同じですが、もちろん全く異なる内容でも大丈夫です

「回答をもらって変更したコード」の最後を、下記のように変えてください

if __name__ == '__main__':
    p2 = Thread(target=func2, args=(b,))
    p1 = Thread(target=func1, args=(doga,))
    p2.start()
    #event.set()
    p1.start()

Comments

[Yun123]

回答ありがとうございます。
コードにthreadingの処理を追加したのですがうまくいかず入れ替えてもみたのですが変更したコードではfunc2の処理が完全に完了して次のfunc1の動画再生処理になっているようなのですが回答では終了を待たずにfuncが動くとありましたが、これはthreadingの処理ができていないのでしょうか？

[jbpb0]

私が提示したコードをそのまま動かしたら、どうなりますか?
私の環境では、func_1 End が表示される前に func_2 Start, func_3 Start が表示されますので、三つの関数は同時に動いてます
質問者さんの環境では、そうならないのでしょうか?
質問者さんの環境でも三つの関数が同時に動くのなら、質問者さんの環境でもthreadingは正常に使えるはずです

[jbpb0]

if __name__ == '__main__':
の次を、こう変えてください (関数名と引数は分けて指定する)
p2 = Thread(target=func2, args=(b,))
p1 = Thread(target=func1, args=(doga,))
(行頭にはインデントを入れてください)
同じ内容を、回答にも追記しました

[Yun123]

回答ありがとうございます。
関数名と引数を分けて指定したら動いてくれました。
ありがとうございました。