【Python】非同期プログラムでマルチスレッドが動かない場合と対処方法
2021.12.20
非同期プログラムでマルチスレッドが思ったように動かない場合は？
Python（パイソン）では、非同期プログラムを作成する場合、一般的に、Threadクラスを使って「マルチスレッド」にします。
しかし、これが思うように動かないことが、稀にあります。
今回は、「非同期プログラムで、マルチスレッドが思ったように動かない場合」と、「その対処方法」について、ご紹介したいと思います！
通常のマルチスレッドの実現方法
言語によっては面倒なマルチスレッドも、Python では非常に簡単に実現できます。
例えば、「メインスレッドで a ～ g」、「サブスレッドで 1 ～ 7」を出力する場合、以下のようなコードになります。
コード
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 | import threading # サブスレッドで実行する関数 def sub_thread(): for i in range(7): print(i) # メイン処理 if __name__ == "__main__": # サブスレッドを起動 sub = threading.Thread(target=sub_thread) sub.start() # メインスレッドでループ処理 for s in range(ord('a'), ord('g')): print(chr(s)) |
コードの解説
コードを、簡単に解説します。
threading
threading は、スレッド操作するためのモジュールです。
まず、これを import します。
sub_thread()
sub_thread() は、サブスレッドで動かすための関数です。
この中で、「1 ～ 7」をループで出力しています。
サブスレッドの起動
メイン処理では、まずサブスレッドを起動しています。
サブスレッドにセット
Threadクラスの、コンストラクタの引数に、先程の関数 sub_thread を渡します。
これで、この関数は、サブスレッドにセットされました。
サブスレッドを開始
start() メソッドで、サブスレッドを開始します。
ループ出力
メインスレッド内で「a ～ f」をループで出力しています。
実行結果
このプログラムの実行結果は、以下のようになります。
0
1
a
b
c
d
e
f
2
3
4
5
6
非同期で実行しているので、「a ～ f」と「1 ～ 7」が、適当に混ざって出力されています。
これが、非同期のマルチスレッド処理の例です。
マルチスレッドで画像を動画として再生してみる
さて、それではマルチスレッドを使って、画像を動画として表示してみましょう！
動画として表示するコード
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 | import wx import cv2 import threading import time class VideoBitmap(wx.StaticBitmap): def __init__(self, parent, file_name): self.video = cv2.VideoCapture(file_name) ret, frame = self.video.read() bmp = self.create_wx_bitmap_from_cv2_image(frame) super().__init__(parent, wx.ID_ANY, bmp, (0, 0), (1024, 768), style=0, name='') def create_wx_bitmap_from_cv2_image(self, cv2_image): height, width = cv2_image.shape[:2] cv2_image_rgb = cv2.cvtColor(cv2_image, cv2.COLOR_BGR2RGB) return wx.BitmapFromBuffer(width, height, cv2_image_rgb) def run(self): frame_rate = int(self.video.get(cv2.CAP_PROP_FPS)) while True: is_read, frame = self.video.read() if not is_read: break bmp = self.create_wx_bitmap_from_cv2_image(frame) self.SetBitmap(bmp) time.sleep(frame_rate/1000) if __name__ == "__main__": app = wx.App(False) file_name = "video/video.mp4" frame = wx.Frame(None, wx.ID_ANY, "", size=(1024,768)) panel = wx.Panel(frame, size=(1024,768)) layout = wx.FlexGridSizer(rows=1, cols=1, gap=(0,0)) panel.SetSizer(layout) video = VideoBitmap(panel, file_name) layout.Add(video) frame.Show(True) thread = threading.Thread(target=video.run) thread.start() app.MainLoop() |
このコードを動かすには、ソースをおいたフォルダ直下に「videoフォルダ」を作成。
そこに、動画ファイル「video.mp4」を置いてください。（動画の内容は問いません）
コードの解説
コードの解説をします。
動画取得とGUI操作
動画の画像取得に「cv2 モジュール（OpenCV）」、GUI操作には「wx モジュール（wxPython）」を使っています。
動画再生
動画再生用に、簡単なクラス「VideoBitmap」を作成し、それの実行メソッド run() を、サブスレッドとして実行しています。
VideoBitmap
VideoBitmap は、「wxPython」の「StaticBitmap」を継承しています。
つまり、「動画も再生できる Bitmap クラス」というわけです。
動画からの画像取得
動画からの画像取得は、 create_wx_bitmap_from_cv2_image() メソッドで行っています。
run() メソッド
run() メソッドでは、
１、OpenCV でフレームを読み込み
２、それをこのメソッドで画像に変換
３、自身にセットして描画する
という処理を、フレームが読み込める間、ループで繰り返します。
sleep()
sleep() は再生速度の調整 (frame_rate) に使っています。
実行後の状態
さて、このコードを実行すると、以下のどちらかの状態になるかと思います。
- １枚めの画像は表示されるが、あとは真っ白
- 動画が表示されるが、ちらつきが激しい
いずれにしても、このままだと使い物になりません…。
マルチスレッドで動画が正常に表示されない理由
理屈的には、先ほど紹介したコードで正しいはずです。
しかし「思ったように動かない！」
こういう時は、その「クラスがマルチスレッドに対応しているか」どうかを疑ってみましょう。
wxPython の StaticBitmap クラスがマルチスレッドに対応しているかは不明
今回は、wxPython の StaticBitmap を継承して、動画再生クラスを作りました。
しかし、そもそも wxPython の StaticBitmap クラスが、マルチスレッドに対応しているかどうか分かりません。
（wxPython のドキュメントを見ても、対応しているかどうか明記されておりません。）
マルチスレッド対応しているかチェックする必要性がある
今回の事象は、使用しているクラスが、「マルチスレッドに対応していないことが原因」である可能性が高いと考えられます。
Python の場合、マルチプラットフォーム対応なので、更に話が複雑になります。
つまり、例えば「Windows10 では動作しても、Linux や Mac では動作しない」といった事象も、あり得るということです。
マルチスレッドでクラスを使う場合は、それが（対象プラットフォームで）マルチスレッド対応しているかどうか、をチェックする必要があります。
マルチスレッドで思ったように動かないときの対処方法
マルチスレッドが正しく動かないのなら、「シングルスレッド」で処理します。つまり、メインスレッドだけで処理を行うしかありません。
マルチスレッドは、複数のスレッドが並行して走ることを指します。
ですが、これは見方を変えれば、スレッドを切り替えながら実行しているということです。
ということは、シングルスレッドでも、処理の流れを切り替えながら並行して実行できれば、擬似的にマルチスレッドを実現できるわけです。
timerイベントを使う
今回、このために「timer イベント」を使ってみたいと思います！
timer は、指定した間隔でタイマー割り込みをかけ、現在処理中の箇所から、timer イベントに処理を切り替えるものです。
それでは、先のコードを、 timer を使って書き換えてみましょう。
timerを使ったコード
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 | import wx import cv2 import threading import time class VideoBitmap(wx.StaticBitmap): def __init__(self, parent, file_name): self.video = cv2.VideoCapture(file_name) ret, frame = self.video.read() bmp = self.create_wx_bitmap_from_cv2_image(frame) super().__init__(parent, wx.ID_ANY, bmp, (0, 0), (1024, 768), style=0, name='') # timer処理用 self.interval = 1000/int(self.video.get(cv2.CAP_PROP_FPS)) self.timer = wx.Timer(self) self.Bind(wx.EVT_TIMER, self.on_timer) def create_wx_bitmap_from_cv2_image(self, cv2_image): height, width = cv2_image.shape[:2] cv2_image_rgb = cv2.cvtColor(cv2_image, cv2.COLOR_BGR2RGB) return wx.BitmapFromBuffer(width, height, cv2_image_rgb) # 再生開始 def start(self): self.timer.Start(self.interval) # タイマーイベント（動画を１フレーム再生） def on_timer(self, event): self.timer.Stop() is_read, frame = self.video.read() if not is_read: return bmp = self.create_wx_bitmap_from_cv2_image(frame) self.SetBitmap(bmp) self.timer.Start(self.interval) if __name__ == "__main__": app = wx.App(False) file_name = "video/video.mp4" frame = wx.Frame(None, wx.ID_ANY, "", size=(1024,768)) panel = wx.Panel(frame, size=(1024,768)) layout = wx.FlexGridSizer(rows=1, cols=1, gap=(0,0)) panel.SetSizer(layout) video = VideoBitmap(panel, file_name) layout.Add(video) frame.Show(True) # 動画再生スタート video.start() app.MainLoop() |
コードの変更点
コードに下記の変更を行いました！
初期処理内にて
初期処理内で timer イベント用の処理を、３行追加しています。
interval
interval は、timer イベントの発生間隔を示すもので、フレームの再生レートをセットしています。
timer インスタンスが、timer イベントを制御する本体で、これを使うと、timer イベント（EVT_TIMER）を発生させることができます。
Bind() メソッド
最後の、 Bind() メソッドは、イベントとメソッドを紐付ける（Bind する）ために、実行しています。
on_timer() メソッド
timer イベントで呼ばれる、 on_timer() メソッド内では、動画を１フレーム読み込み、それを bitmap に変換して自身にセットしています。
この timer イベントを使うと、擬似的にマルチスレッド的な処理を行うことができます。
処理後の画像
動画だったので、画像を入れても伝わらないので入れるかどうか迷いましたが…。分かりにくい画像で申し訳ありません（笑）
さいごに
今回は、Pythonにおいて「マルチスレッドが思ったように動作しない時の原因」と、「その回避方法」をご紹介しました！
通常は、３つ以上のスレッドが行き交うような複雑なスレッド処理でなく、２つのスレッドを並行処理する場合が大半です。
そうした場合に、思ったようなスレッディングができない場合は、利用しているクラスが「マルチスレッド非対応」である可能性を疑いましょう。
そして、それを回避するためには timer イベントを利用した、疑似並行処理が有効です。
困った時には、ぜひお試しください！
こちらの記事もオススメ！
書いた人はこんな人
- 「好きを仕事にするエンジニア集団」の（株）ライトコードです！
ライトコードは、福岡、東京、大阪の3拠点で事業展開するIT企業です。
現在は、国内を代表する大手IT企業を取引先にもち、ITシステムの受託事業が中心。
いずれも直取引で、月間PV数1億を超えるWebサービスのシステム開発・運営、インフラの構築・運用に携わっています。
システム開発依頼・お見積もり大歓迎！
また、現在「WEBエンジニア」「モバイルエンジニア」「営業」「WEBデザイナー」「WEBディレクター」を積極採用中です！
インターンや新卒採用も行っております。
以下よりご応募をお待ちしております！
https://rightcode.co.jp/recruit
ライトコードの日常12月 1, 2023ライトコードクエスト〜東京オフィス歴史編〜- ITエンタメ10月 13, 2023Netflixの成功はレコメンドエンジン？
- ライトコードの日常8月 30, 2023退職者の最終出社日に密着してみた！
- ITエンタメ8月 3, 2023世界初の量産型ポータブルコンピュータを開発したのに倒産!?アダム・オズボーン
関連記事
採用情報
\ あの有名サービスに参画!? /
バックエンドエンジニア
\ クリエイティブの最前線 /
フロントエンドエンジニア
\ 世界を変える…！ /
Androidエンジニア
\ みんなが使うアプリを創る /
iOSエンジニア
