pingをスレッドに分けて実行すると正常値が返ってこない

Question

pythonのモジュールpingsを使用してネットワーク上にいるPCの死活管理をしようとしております。
tkinterを用いて全PCを一覧表示してpingが通れば名前の前に□を、通らなければ■を付けて表示する機能を持たせました。

上から順番にpingを飛ばした場合は正常な値が返ってくるのですが、
それだと処理に時間がかかるためPCごとにスレッドに分けてpingを飛ばすと全てpingが通る判定となってしまいます。

ソースは下記の通りですが、なぜこのような現象になるのかご教授ください。

また、終了時に[×]ボタンで終了すると例外エラーが表示されるので
ボタンを押して全スレッドが終了するのを待つような処理を実装しようとしましたが、
これもまたうまく動作しません。
こちらも合わせてご教授いただけると幸甚です。

import tkinter as tk
import pings
import threading as th

PEOPLE = {
        '■  user1':'PC1',
        '■  user2':'PC2',
        '■  user3':'PC3',
        '■  user4':'PC4'
         }

LIST_PEOPLE = list(PEOPLE.keys())
root = tk.Tk()

def callback():
    global thre
    thre = []
    for mem in range(len(LIST_PEOPLE)):
        thre.append(th.Thread(target=pin, args=([mem, PEOPLE[LIST_PEOPLE[mem]]])))
        thre[mem].start()

def pin(mem, pc):
    p = pings.Ping()
    res = p.ping(pc)
    if res.is_reached():
        lbl[mem]['text'] = '□' + lbl[mem]['text'][1:]
    else:
        lbl[mem]['text'] = '■' + lbl[mem]['text'][1:]
    root.after(5000, pin(mem, pc))

def close_win():
    for thread in thre:
        thread.join()
        
lbl = []
j = 0
for i in LIST_PEOPLE:
    lbl.append(tk.Label(root, text=i, font=('consolas', 10)))
    lbl[j].pack(anchor=tk.NW, padx=20)
    j += 1
btn = tk.Button(root, text='close', font=('consolas', 10), command=close_win)
btn.pack()
callback()

root.mainloop()

Answer 1

自信ないですが、pings.Ping()で各スレッド毎にユニークなown_id(16bit整数値)をセットしてやる必要があると思います。

応答が返ってきたときに、自分が送ったpingに対する応答かをown_idで判定しているようです。
own_idのデフォルト値はプロセスIDから作っているので、すべてのスレッドのPingインスタンスで同じ値になってしまっています。
そのため、一つのホストからpingの応答があると、すべてのスレッドのPingインスタンスが、自分への応答が返ってきたと勘違いしてるのではないかと。

元のプログラムだとpings.Ping(own_id=mem)で、とりあえずは動くかな。

Comments

[sky6720]

ご回答ありがとうございます。
own_idで正常に動作することを確認できました。
ただ、スレッドの終了処理が未だ例外エラーとなります。

[bsdfan]

スレッドの終了については、今回のプログラムでは、root.afterのところが間違っていて、コールバックではなく、即時評価の再帰になっています。
そのため、スレッドが再帰のリミットに到達してエラーとなるまで、いつまで待っても終わらないです。

スレッドを終了させる仕組みを取り入れるなら、shiracamusさんの回答が良い例だと思います。

Answer 2

root.after を使うとメインスレッドから呼び出されてしまいます。普通に time.sleep するといいです。
tkinterはシングルスレッドで動作することを前提に作られているようで、サブスレッドからは 変数ガジェット(*Var) にsetするのが無難です。
以下のようにすることで正常終了するようになりました。

import time
import pings
import tkinter as tk
import threading as th

PEOPLE = {
    'user1': 'PC1',
    'user2': 'PC2',
    'user3': 'PC3',
    'user4': 'PC4'
}

root = tk.Tk()
status = {user: tk.StringVar() for user in PEOPLE}

def start_threads():
    ping.running = True
    threads = [th.Thread(target=ping, args=(user,)) for user in PEOPLE]
    for thread in threads:
        thread.start()
    return threads

def stop_threads(threads):
    ping.running = False
    for thread in threads:
        thread.join()

def ping(user):
    print("start ping:", user)
    p = pings.Ping()
    while ping.running:
        res = p.ping(PEOPLE[user])
        print(user, res.messages)
        if res.is_reached():
            status[user].set(f'□  {user}')
        else:
            status[user].set(f'■  {user}')
        time.sleep(5)
    print("stop ping:", user)

def main():
    for user in PEOPLE:
        label = tk.Label(root, textvariable=status[user], font=('consolas', 10))
        label.pack(anchor=tk.NW, padx=20)

    btn = tk.Button(root, text='close', font=('consolas', 10), command=root.destroy)
    btn.pack()

    threads = start_threads()
    print("started")

    try:
        root.mainloop()
    except KeyboardInterrupt:
        print()
        print("killed")
    else:
        print("closed")

    print("stopping...")
    stop_threads(threads)
    print("stopped")

if __name__ == '__main__':
    main()

Comments

[sky6720]

ご回答ありがとうございます。
勉強不足で申し訳ありませんが、いただいた中の「ping.running」の箇所がわからないです。
このpingはdef ping:のものと同一でしょうか。
pingクラス(?)のなかのrunnningメソッドという意味でしょうか。
見当違いな質問であれば申し訳ありません。

[shiracamus]

ping関数オブジェクトに属性設定してます。
関数はFunctionクラスのインスタンスで、インスタンス変数を設定できるんですよ、不思議なことに。
普通は global変数にしますね。わかりにくくてすみません。

[sky6720]

勉強不足で申し訳ありません。
なんとなくですがわかりました。また調べさせていただきます。