pythonで一定間隔でマルチスレッド処理

Question

表題の通り、pythonで一定間隔で関数実行（マルチスレッド）したいと考えています。
UNIX系OSでは、下記で簡単に実行できるようです。

import signal
import time

def task(arg1, arg2):
    print(time.time())

signal.signal(signal.SIGALRM, task)
signal.setitimer(signal.ITIMER_REAL, 0.1, 0.1)

while True:
    time.sleep(1)

ですが、OSがwindowsなので、上記は使用できません。
良い方法はないでしょうか。
調べてはいるのですが、これと言った回答が見つかりませんでした。

Comments

[y_waiwai]

「python タイマ」でぐぐると、Windowsでも実行できる方法が出てきますが、それではだめなんでしょうか

[uer03108]

関数の実行時間が影響しないものであれば大丈夫です。

[y_waiwai]

ならその条件を質問に追記しましょう

Answer 1

そんなに小難しく書かなくても実現できますよ。

from concurrent.futures import ThreadPoolExecutor
import time

def task(arg1, arg2):
    print(time.time())

with ThreadPoolExecutor() as pool:
    while True:
        pool.submit(task, "arg1", "arg2")
        time.sleep(1)

Comments

[uer03108]

有難うございます。
こちらの方が簡単ですね。

Answer 2

解決いたしました。
有難うございます。

import time
import threading

StartTime = time.time()

def action() :
    print('action ! -> time : {:.1f}s'.format(time.time()-StartTime))
    time.sleep(2)
    print("dummy")


class setInterval :
    def __init__(self,interval,action) :
        self.interval  = interval
        self.action    = action
        self.stopEvent = threading.Event()
        thread         = threading.Thread(target=self.__setInterval)
        thread.start()

    def __setInterval(self) :
        nextTime = time.time()+self.interval
        while not self.stopEvent.wait(nextTime-time.time()) :
            nextTime += self.interval
            #関数実行時間が考慮されない
            #self.action()
            #関数実行時間を考慮する
            t = threading.Thread(target=self.action)
            #t = threading.Thread(target=self.action, args=(i,))
            t.start()

    def cancel(self) :
        self.stopEvent.set()

# start action every 0.6s
inter=setInterval(0.6,action)
print('just after setInterval -> time : {:.1f}s'.format(time.time()-StartTime))

# will stop interval in 5s
t=threading.Timer(5,inter.cancel)
t.start()