wxpythonで10秒後にgif動画再生を別のgifへ切り替えたい。

Question

前提・実現したいこと

wxpythonでgif動画を再生するデスクトップアプリを作っています。
10秒後にgif動画を切り替えたいだけなのですが、かなり苦戦しています。

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

wxのメイン画面を開き
↓
GIFクラスを呼び
↓
指定の動画（著作権フリーのgif）をwx.advで再生
↓
MyThreadEventとEVT_MY_THREADをバインド
↓
print("四.一")のwhileループ箇所（秒カウント箇所）でMyThreadEventを呼び
（ここで2重スレッド発生）
↓
EVT_MY_THREADに紐づくOnUpdateメソッドの実行
（この時、10秒経過しているか呼ばれたときに毎回チェック）
（if evt.msg>10 and self.status=='vacant'　ここは常にvacantですので無視して下さい。）
（10秒経過したかどうかだけ検知しています。）
↓
10秒経過した時点でsomeiyoshino1.gifがDestroyもしくはSTOPされ、次のsomeiyoshino2.gifが再生されるはず…
チカチカとsomeiyoshino1.gifとsomeiyoshino2.gifが重なって表示されるだけでした。（Qモジュールの箇所をコメントアウトすればその現象を再現できます。）

q = queue.Queue(1) # あってもなくても変わらない
q.put('go')
if(q.get() == 'stop')

上記の箇所をコメントアウトすれば、2つの動画が10秒後に重なってチカチカとなるところまではできました。
（4/26 21:15 一番下にそのソースコードを追記しました。）

あとは前動画を削除さえできればいいのではと思ってはいます。

queueモジュールを使ってしまうと、毎回('stop')であるか調べて、Destoroyをしようと思いましたが、なぜかコンソール上で停止してしまいました。

該当のソースコード

import smtplib
from email.mime.text import MIMEText
import time
import _thread
import wx
import wx.lib.newevent
import queue
import pdb
import os
import sys
import cv2
import numpy as np
import wx.adv

q = queue.Queue(1) # あってもなくても変わらない
q.put('go')

# 新しいイベントクラスとイベントを定義する
(MyThreadEvent, EVT_MY_THREAD) = wx.lib.newevent.NewEvent()
class MyThread:
    def __init__(self, win):
        self.win = win
        self.i=0
    print("一")
    def Start(self):
        self.keepGoing = True
        self.running = True
        print("MyThread.Start.running")
        _thread.start_new_thread(self.Run, ())
    def Stop(self):
        self.keepGoing = False
    def IsRunning(self):
        return self.running
    def Run(self):
        print("四.一")
        while self.keepGoing:

            # メッセージを格納したイベントを作る
            #データ受信

            self.i=self.i+1
            print(self.i)

            # (MyThreadEvent, EVT_MY_THREAD) = wx.lib.newevent.NewEvent()
            #   ↓　
            #  self.Bind(EVT_MY_THREAD, self.OnUpdate)
            # この紐づきでMyThreadEventが呼ばれたときにEVT_MY_THREADイベントが実行されOnUpdateが呼ばれる

            # つまりMyThreadEvent→EVT_MY_THREADイベント→OnUpdateという10秒経過したかチェックメソッドへ
            evt = MyThreadEvent(msg=self.i)

            # イベントを投げる
            wx.PostEvent(self.win, evt)
            time.sleep(1)

        self.running = False
    print("二")
class dataserver:
    def Start(self):
        _thread.start_new_thread(self.Run, ())
    def Run(self):
        print("八")
        # self.lock=q.get() # あってもなくても変わらない

class GIF(object):
    def __init__(self,anime,id,gifname):
        self.counter = 0
        self.anime = anime
        self.file = gifname
        self.anime = anime
        self.ani = wx.adv.Animation(self.file)
        self.ctrl = wx.adv.AnimationCtrl(anime, -1, self.ani, pos=(10, 10))
        self.ctrl.Play()
class GIF_Stop(object):
    def __init__(self,anime,id,gifname):
        self.counter = 0
        self.anime = anime
        self.file = gifname
        self.anime = anime
        self.ani = wx.adv.Animation(self.file)
        self.ctrl = wx.adv.AnimationCtrl(anime, -1, self.ani, pos=(10, 10))
        self.ctrl.Stop()
        time.sleep(5)
class GIF_Destroy(object):
    def __init__(self,anime,id,gifname):
        self.counter = 0
        self.anime = anime
        self.file = gifname
        self.anime = anime
        self.ani = wx.adv.Animation(self.file)
        self.ctrl = wx.adv.AnimationCtrl(anime, -1, self.ani, pos=(10, 10))
        self.ctrl.Stop()
        self.ctrl.DestroyChildren()


class MainWindow(wx.Frame):
    def __init__(self, parent, id, title):
        wx.Frame.__init__(self, parent, id, title, size=(300, 200))
        self.Center()

        # パネル
        self.display = wx.Panel(self, size=(300, 100), pos=(0, 0))
        self.display.SetBackgroundColour('#FFFAF0')
        self.status = 'vacant'

        # gif
        self.MainPanel = wx.Panel(self, size=(1300, 900))#メイン画面の大きさ
        self.anime = wx.Panel(self.MainPanel, pos=(0, 0),size=(1250, 850))
        self.anime.SetBackgroundColour("WHITE")
        gifname = 'someiyoshino2.gif'
        self.Motion = GIF(self.anime, id, gifname)
        self.Fit()

        print(q.get())
        if(q.get() == 'stop'):
            gifname = 'someiyoshino2.gif'
            self.Motion = GIF_Destroy(self.anime, id, gifname)
            self.Fit()
            gifname = 'someiyoshino1.gif'
            self.Motion = GIF(self.anime, id, gifname)
            self.Fit()


        #テキスト
        self.text1 = wx.StaticText(self.display,id, self.status)
        font = wx.Font(20, wx.FONTFAMILY_DEFAULT, wx.FONTSTYLE_NORMAL, wx.FONTWEIGHT_NORMAL)
        self.text1.SetFont(font)
        self.text1.Center()

        self.reservation = wx.Panel(self,size=(300, 100), pos=(0, 100))
        self.button_1 = wx.Button(self.reservation,id, 'reserve', size=(100, 50))
        self.button_1.SetFont(font)
        self.button_1.Bind(wx.EVT_BUTTON, self.click)


        # 新しく定義したイベントに対応する処理関数をバインドする
        print("三")

        # つまりMyThreadEvent→EVT_MY_THREADイベント→OnUpdateという10秒経過したかチェックメソッドへ
        self.Bind(EVT_MY_THREAD, self.OnUpdate)
        print("四")
        self.Bind(wx.EVT_CLOSE, self.OnCloseWindow)
        # スレッドのインスタンスを作り、起動する
        # pdb.set_trace()
        self.my_thread = MyThread(self)
        self.my_thread.Start()

        # ここから2重スレッド↓↓↓

        self.Centre()
        self.Show(True)
        print("五")

    def click(self, event):
        # mail1=mail()
        if self.status == 'vacant':
            print("六のあとにクリックしたらここにくる　七")
            self.status='reserved'
            self.text1.SetLabel(self.status)
            self.data=dataserver() # あってもなくてもかわらない　クラスの呼び方（インスタンス）
            self.data.Start()
            # q.put('locked')
            self.button_1.Disable()
            # mail1.message()

    def OnCloseWindow(self, evt):
        print("OnCloseWindow")
        # スレッドが停止するまで待ってから、ウィンドウを閉じる
        self.my_thread.Stop()

        while self.my_thread.IsRunning():
            time.sleep(0.1)
        self.Destroy()

    # MyThreadEvent→EVT_MY_THREADイベント→OnUpdateという10秒経過したかチェックメソッドへ
    def OnUpdate(self, evt):
        print("六")
        print("OnUpdate")
        # スレッドからイベントを受信したときの処理
        if evt.msg>10 and self.status=='vacant':
            self.status='occupied'
            self.text1.SetLabel(self.status)
            # 10秒後にGIFをSTOP
            q.put("stop")


app = wx.App()
MainWindow(None, wx.ID_ANY, 'TOTO')
app.MainLoop()

試したこと

sqliteで変数をselectしてチェックする方法や、スレッド同時並行ではなく、プロセスを2つ作る方法なども試しましたが、いずれも次のgif再生はできませんでした。ただ動画の再生の切り替えだけなのですが、どなたかご存じの方教えて頂けないでしょうか。何か単純なミスをしているか、決定的な基礎知識が抜けている気がしてなりません。こんな需要はすぐに見つかるものだと思っていたのですが、調べてもわからなく困っています。どうかよろしくお願い致します。

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

win10
python3.7
wxpython

参考サイト

https://teratail.com/questions/158458
https://teratail.com/questions/233764
https://qiita.com/wikipediia/items/2919362de582a7d8de9e
https://www.python-beginners.com/entry/20191125/1574687207
https://qiita.com/asakbiz/items/5a34cae7b6c00c87a7e6
https://dev.classmethod.jp/articles/python-asyncio/
https://www.rhoboro.com/2019/02/09/coroutine-abstract.html
https://qiita.com/satsukiya/items/f7a3c7fdae566ed96306
https://www.yoheim.net/blog.php?q=20170601

2020/4/26 追記

Qモジュールを使わず、Onupdateメソッド内に動画切り替えメソッドを置いた場合のソースコードは以下になります。

# q = queue.Queue(1) # あってもなくても変わらない
# q.put('go')

～
途中省略
～

        # gif
        self.MainPanel = wx.Panel(self, size=(1300, 900))#メイン画面の大きさ
        self.anime = wx.Panel(self.MainPanel, pos=(0, 0),size=(1250, 850))
        self.anime.SetBackgroundColour("WHITE")
        gifname = 'someiyoshino2.gif'
        self.Motion = GIF(self.anime, id, gifname)
        self.Fit()


        #テキスト
        self.text1 = wx.StaticText(self.display,id, self.status)
        font = wx.Font(20, wx.FONTFAMILY_DEFAULT, wx.FONTSTYLE_NORMAL, wx.FONTWEIGHT_NORMAL)

～
途中省略
～


    # MyThreadEvent→EVT_MY_THREADイベント→OnUpdateという10秒経過したかチェックメソッドへ
    def OnUpdate(self, evt):
        print("六")
        print("OnUpdate")
        # スレッドからイベントを受信したときの処理
        if evt.msg>10 and self.status=='vacant':
            self.status='occupied'
            self.text1.SetLabel(self.status)
            # 10秒後にGIFをSTOP
            gifname = 'someiyoshino2.gif'
            self.Motion = GIF_Destroy(self.anime, id, gifname)
            self.Fit()
            gifname = 'someiyoshino1.gif'
            self.Motion = GIF(self.anime, id, gifname)
            self.Fit()


app = wx.App()
MainWindow(None, wx.ID_ANY, 'TOTO')
app.MainLoop()

Answer 1

短い回答: 10秒ごとの変更でしたら wx.CallLater を使ってはどうでしょう？

スレッドを使う場合、別スレッド内から描画処理等のGUI操作は出来ないので注意です。
スレッドセーフな操作ではない為、大抵のGUIライブラリでは禁止されていたり誤動作を起こします。

もしスレッドで実装する場合は、自分で作成したスレッド側ではデータ変更や通知のみに留め、
描画はメインループに委ねるようにします。(コードは今から拝見します)

---

CallLater利用周りのみになりますが、該当部分周辺のコードとデモ。
スレッドやキューは不要になります。

from glob import glob
from itertools import cycle
from functools import partial

getNextImageFile = partial(next, cycle(glob("*.gif")))

# getNextImageFile 関数は用途に合わせて実装してください。

# 上記は、カレントディレクトリ内の gif ファイルを繰り返す例
# next() で次の要素を取り出せるので、上のように定義が出来ます。
# itertools.cycle で末尾まで到達すると、次は先頭から繰り返します。

def showNextImage():
    filepath = getNextImageFile()
    # NOTE: self.ctrl は wx.adv.AnimationCtrlのインスタンス。適切なスコープにおいてください。
    self.ctrl.SetAnimation(wx.adv.Animation(filepath))
    self.ctrl.Play()
    wx.CallLater(1000*10, showNextImage)

showNextImage()

デモ用(3秒切り替え)

---

追記: コードを追加する場所が解り難かったと思うので、
実行可能なコードを追加します。読み込む gif はカレントディレクトリが対象です。

import wx
import wx.adv


class MainWindow(wx.Frame):
    def __init__(self, parent, id, title):
        wx.Frame.__init__(self, parent, id, title, size=(400, 400))

        self.ctrl = wx.adv.AnimationCtrl(self)
        self.ctrl.Stop()

        from glob import glob
        from itertools import cycle
        from functools import partial

        getNextImageFile = partial(next, cycle(glob("*.gif")))

        def showNextImage():
            filepath = getNextImageFile()
            self.ctrl.SetAnimation(wx.adv.Animation(filepath))
            self.ctrl.Play()

            wx.CallLater(1000*10, showNextImage)
        showNextImage()


if __name__ == '__main__':
    app = wx.App()
    win = MainWindow(None, wx.ID_ANY, 'TOTO')
    win.Centre()
    win.Show()
    app.MainLoop()

Comments

[dendenmushi]

本当にありがとうございます。ぱっと実装したらなぜか動かなかったので今日夜じっくり見させて頂きます。（GWがまだ始まっていません…）

別質問窓にしようか迷っているのですが、同じメモリ内のAスレッドで引数を持たせて、何秒後かにフラグを立たせて、
'''
if __name__ == "__main__":
a = Value('d', 0)
func1_proc = Process(target=func1, args=(a,))
func2_proc = Process(target=func2, args=(a,))
func1_proc.start()
func2_proc.start()

func1_proc.join()
func2_proc.join()
print(a.value)
'''
同じメモリ内のBスレッドでwhileで共有の変数a.Valueが変わったか（フラグが立ったか）、によって動画をチェンジするという方法も考えています。これはwxpythonでは難しいことなのでしょうか。

というのも、秒カウント以外に、何か条件（メールを受信したら等々）で動画をチェンジしたいというのもあります。
（こちらベストアンサーにして再度質問立ち上げた方がいいでしょうかね…）

[teamikl]

コードを置く場所が解り難かったかもしれないので、
スレッド等を省いた、そのまま動くコードを追加しておきます。

＞動画をチェンジするという方法も考えています。これはwxpythonでは難しいことなのでしょうか。

同じアプローチで可能です。AnimationCtrl の SetAnimation や Play() のみを
CallAfter や CallLater を使ってメインスレッドから呼び出すようにします。
まずはタイマー抜きに、画像や動画を変更するメソッドを実装して、
スレッドからはそのメソッドを CallLater で呼び出す形にすると良いです。

(CallLater は、wxのイベント キューに呼び出す関数を追加します。
MainLoop()内部から順番に実行されるので、上記のコードでも再帰呼び出しにはなりません）

[dendenmushi]

＞そのまま動くコードを追加しておきます。
ありがとうございます。

ちょっとその追加の件についても非常に興味があり今日の夜にでも詳しく質問立ち上げますので教えて頂けないでしょうか。よろしくお願い致します。

[dendenmushi]

>teamikl様
以下にて別スレッドを立てました。もしよろしければアドバイス頂けないでしょうか。
よろしくお願い致します。
https://teratail.com/questions/257014

[teamikl]

スレッド先にも書きましたが、訂正です

誤: CallAfter や CallLater を使ってメインスレッドから呼び出すようにします。

結果として解決策がメインスレッドから呼ばれるようにする事には変わりないのですが、
CallLater/CallAfterでスレッドからのタイマー生成に制限がありました。

この説明が誤り不正確でした→: (CallLater は、wxのイベント キューに呼び出す関数を追加します。

メインスレッドにコードを実行させるには、
ここのコードのコメントアウトされている部分でやろうとしてる、イベント通知の方が安全です。
キューによりスレッド安全が保障されます。

※ このコメント欄内での説明の訂正です。回答内の説明およびコードは大丈夫です。