Skip to main content
本文に 464 文字追加
ソース リンク
kunif
  • 1.8万
  • 3
  • 18
  • 28

コメント対応:

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,))

コメント対応:

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,))
本文に 152 文字追加
ソース リンク
kunif
  • 1.8万
  • 3
  • 18
  • 28

合計値を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

合計値を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)

合計値を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

ソース リンク
kunif
  • 1.8万
  • 3
  • 18
  • 28

合計値を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)