python：thread内でのschedule利用時に多重実行される

Question

実現したいこと

毎10秒ごとに実行される処理をthreadで2つ実行させる

発生している問題・分からないこと

毎10秒ごとの処理がスレッドの数だけ多重実行されることがある。

該当のソースコード

import time
import datetime
import schedule
import threading

class Check():
    def __init__(self, i):
        self.int = i

    def start(self):
        print(f'started / {self.int}: {datetime.datetime.now()}')

        for i in range(0, 60, 10):
            schedule.every().minute.at(":{}".format(str(i).zfill(2))).do(
                self.check
            )

        while True:
            schedule.run_pending()
            time.sleep(1.5)

    def check(self):
        print(f'{self.int}: {datetime.datetime.now()}')


def main():
    checkers = []
    for i in range(2):
        checker = Check(i)
        checkers.append(checker)

    threads = []
    for checker in checkers:
        checker_thread = threading.Thread(target=checker.start)
        threads.append(checker_thread)
        checker_thread.start()

    for thread in threads:
        thread.join()

main()

started / 0: 2024-11-12 14:28:05.355389
started / 1: 2024-11-12 14:28:05.355636
0: 2024-11-12 14:28:11.361782
1: 2024-11-12 14:28:11.362020
0: 2024-11-12 14:28:11.361897
1: 2024-11-12 14:28:11.362468
0: 2024-11-12 14:28:20.372013
1: 2024-11-12 14:28:20.372288
0: 2024-11-12 14:28:20.372198
1: 2024-11-12 14:28:20.372359
0: 2024-11-12 14:28:30.882826
1: 2024-11-12 14:28:30.882955
0: 2024-11-12 14:28:41.394638
1: 2024-11-12 14:28:41.394807
0: 2024-11-12 14:28:41.394730
1: 2024-11-12 14:28:41.394881

試したこと・調べたこと

• teratailやGoogle等で検索した
• ソースコードを自分なりに変更した
• 知人に聞いた
• その他

上記の詳細・結果

ChatGPTでも解決できず。

補足

特になし

Answer 1

今のコードでは、schedule.run_pending() が二つのスレッドで実行されているので、そういう動きになってしまいます。(よくない使い方になっています)

やり方としては、二つあると思います。

1. schedule.run_pending() はメインのスレッドでひとつだけ動かして、そこから起動するものがスレッドで実行されるような形にする。 https://schedule.readthedocs.io/en/stable/parallel-execution.html

2. スレッドごとに別のスケジューラーを用意する。 https://schedule.readthedocs.io/en/stable/multiple-schedulers.html

今のコードから変更が少ないのは後者だと思います。

class Check():
    def __init__(self, i):
        self.int = i
        self.scheduler = schedule.Scheduler()

    def start(self):
        print(f'started / {self.int}: {datetime.datetime.now()}')

        for i in range(0, 60, 10):
            self.scheduler.every().minute.at(":{}".format(str(i).zfill(2))).do(
                self.check
            )

        while True:
            self.scheduler.run_pending()
            time.sleep(1.5)

    def check(self):
        print(f'{self.int}: {datetime.datetime.now()}')

Comments

[keruuuu]

ご提案の方法で解決できました。
ありがとうございます。