write_txt() :test.txtに不定期的に1,2,3を書き込む関数
check_file.over5s() : 5秒間test.txtが更新されなければ"5秒"と返すメソッド
write_txt()とcheck_file.over5s()を同時に動かすことでtest.txtが5秒間更新されなければ処理を停止するプログラムを書きたいと考えています.
下のコードは5秒間test.txtが更新されなければ"5秒"と出力され,逆に5秒以内にtest.txtが更新され続ければ"書き込み完了"と期待どおり出力されます.
しかし,"5秒"と出力された後もwrite_txt()は動き続けるため,ファイルが更新されてしまいます.
2つの処理を同時に行い,一方の処理が早く終了すれば,もう一方の処理を強制終了させるためにはどのようにすれば良いでしょうか?
python
1from concurrent.futures import ThreadPoolExecutor 2import concurrent 3import random,time,pathlib 4 5 6def write_txt(text): 7 for i in range(10): 8 with open("test.txt","a") as f: 9 f.write(f"{i}\n") 10 sleep_time = random.random()*10 11 time.sleep(sleep_time) 12 return text 13 14class check_file(): 15 def __init__(self): 16 self.file = pathlib.Path('test.txt') 17 self.update_time = self.file.stat().st_mtime 18 19 def over5s(self,text): 20 while True: 21 time.sleep(5) 22 if self.update_time != self.file.stat().st_mtime: 23 self.update_time = self.file.stat().st_mtime 24 else: 25 break 26 return text 27 28with open("test.txt","w") as f: 29 pass 30with ThreadPoolExecutor(max_workers=2) as executor: 31 file_checker = check_file() 32 results = [] 33 results.append(executor.submit(file_checker.over5s, "5秒")) 34 results.append(executor.submit(write_txt, "書き込み完了")) 35 concurrent.futures.wait(results, return_when=concurrent.futures.FIRST_COMPLETED) 36 for f in concurrent.futures.as_completed(results): 37 f_success = f.result() 38 print(f_success) 39
concurrent.futures.wait(results, return_when=concurrent.futures.FIRST_COMPLETED)でうまくいくかなと思ったのですが,うまくいきませんでした.
もう一方の処理を停止するコードも書かなきゃだめそうな事はわかるのですが,ドキュメントを調べてもよくやり方が分かりませんでした.
![guest](/img/icon/icnUserSample.jpg)
回答2件
あなたの回答
tips
プレビュー
バッドをするには、ログインかつ
こちらの条件を満たす必要があります。
2022/07/25 13:55
2022/07/25 14:04
2022/07/25 14:17
2022/07/25 14:20
2022/07/25 15:48