0

問題
threadingを使用して0から100を足すプログラムを2つ立ててその合計値を監視する関数で200%になるまで監視したいのですが、200%になった途端エラーが出力されます。スレッドを使用するプログラムを作成するのは始めてなのでこのような書き方で合っているのか分からないの詳しい方に見て頂きたいと思い質問させて頂きました。

プログラムが最後まで動作するようにしたいです。

よろしくお願いします。

コード

import time
import threading
import sys

class AddingNumber():
    def __init__(self):
        self.sum = 0
    
    def adding(self):
        for i in range(100):
            time.sleep(.1)
            self.sum += 1
    
    def progress(self):
        while True:
            sys.stdout.write('{percent}%\r'.format(percent=self.sum))
        
calculation = AddingNumber()

t2 = threading.Thread(target=calculation.progress)
t2.setDaemon(True) 
t2.start()

for i in range(2):
    t = threading.Thread(target=calculation.adding)
    t.start()
    t.join()

print(calculation.sum)

エラー内容

Fatal Python error: could not acquire lock for <_io.BufferedWriter name='<stdout>'> at interpreter shutdown, possibly due to daemon threads

Current thread 0x00007fffb20a8380 (most recent call first):
Abort trap: 6
1
  • エラーの原因はwhile文が強制的に終了する事でした。
    – wataru
    Commented 2020年10月29日 7:10

1 件の回答 1

0

合計値をstdoutに出力する処理が、while True:で無限ループになっていてメインスレッドの終了監視処理(そんなものが可能か?は不明ですが)も無いので、daemon設定されていたとしても、メインスレッドが終了してstdoutcloseされた後、daemonスレッドが終了させられる前にもsys.stdout.write()処理が走ってしまうのだと思われます。

明示的に監視スレッドを停止させる機能を持たせて、プログラム終了前にそれを呼び出す必要があるでしょう。
以下のような変更が考えられます。####でコメントした所が変更・追加点です。

import time
import threading
import sys

class AddingNumber():
    def __init__(self):
        self.sum = 0
        self.Loop = True  #### ループ制御用のフラグを設ける
    
    def adding(self):
        for i in range(100):
            time.sleep(.1)
            self.sum += 1
    
    def terminate(self):      #### ループ停止用メソッド追加
        self.Loop = False
    
    def progress(self):
        while self.Loop: #### 無限ループでは無く制御用フラグを見て継続・終了する
            sys.stdout.write('{percent}%\r'.format(percent=self.sum))

calculation = AddingNumber()

t2 = threading.Thread(target=calculation.progress)
t2.setDaemon(True) 
t2.start()

for i in range(2):
    t = threading.Thread(target=calculation.adding)
    t.start()
    t.join()

calculation.terminate() #### 監視スレッド停止指示
t2.join()               #### 監視スレッド終了待ち

print(calculation.sum)

ちなみに細かい仕組みについてはこちらの記事の懸賞ポイントの付いた回答で解説されているようです。
Fatal Python error and BufferedWriter


コメント対応:

def adding(self):の中のfor i in range(100):rangeの値をパラメータ指定したい場合は、以下の記事が参考になるでしょう。
Pythonのスレッドで引数を渡せなくて躓いた話。

def adding(self):の部分を以下のようにして:

def adding(self, count):
    for i in range(count):
        time.sleep(.1)
        self.sum += 1

スレッド生成部分を以下のようにすれば良いでしょう(例えば150を指定):

t = threading.Thread(target=calculation.adding, args=(150,))
11
  • すいません、とても助かります。ありがとうございます。
    – wataru
    Commented 2020年10月29日 7:57
  • 上記のプログラムを動かして気になった事があるのですが、最後に出力をターミナルに残るようにしたくprint('{percent}#\r'.format(percent=calculation.sum))を追加したのですが、200%%が2つ表示されてしまいます。なのでprint(calculation.sum)とすると%が一つとなりいい感じになったのですが、なぜこのような挙動をするのか分からないです。
    – wataru
    Commented 2020年10月29日 8:33
  • それは何時の時点でのプログラムでしょう? 質問時点のものだと無限ループからの出力とメインの最後の出力が混じった可能性があるかもしれません。
    – kunif
    Commented 2020年10月29日 8:47
  • time.sleep(3)と遅らせても同じ結果でした。
    – wataru
    Commented 2020年10月29日 9:20
  • メインプログラムの最後のprintの前に改行するだけのprint()を入れてみて結果がどうなるか試してみては? 別に新しく質問としてもよいかもしれませんね。
    – kunif
    Commented 2020年10月29日 9:31

この質問に回答するには、ログインする必要があります。

求めていた回答ではありませんか? のタグが付いた他の質問を参照する。