マルチスレッド化における優先度について

Question

下記のプログラムを実行した際に、"GPS情報"と"「ok」の表示"を並列処理させたかったのですが、「ok」がGPSとほぼ同時に表示されてしまい並列動作していることが確認できませんでした。

本来は、1秒毎にGPS表示しながら同時進行で2秒毎にokを表示させたかったのですがうまく動作しませんでした。

どこか不備が有ればおしえていただきたいです。
よろしくお願いします。。

import time, datetime, threading, serial, micropyGPS

gps = micropyGPS.MicropyGPS(9, 'dd')

#関数------------------------------------------------------
def rungps():
        s = serial.Serial('/dev/serial0', 9600, timeout=10)
        s.readline()
        while True:
                sentence = s.readline().decode('utf-8')
                if sentence[0] != '$':
                        continue
                for x in sentence:
                        gps.update(x)

                if gps.clean_sentences > 20:
                        print('緯度経度: %2.8f, %2.8f' % (gps.latitude[0], gps.longitu$
                        other()
                time.sleep(1.0)
#----------------------------------------------------------

def other():
        print('ok')
        time.sleep(2.0)
#----------------------------------------------------------
if __name__ == "__main__":
        gpsthread = threading.Thread(target=rungps, args=())
        otherthread = threading.Thread(target=other)
#gpsthread.daemon = True
        gpsthread.start()
        otherthread.start()

Answer 1

質問に書かれたプログラムは、以下のように動作しているはずです。

1. rungpsを実行するgpsthreadスレッドが、mainの中の"gpsthread.start()"で起動される。

　gpsthreadは、シリアル通信からデータを読みだし（シリアル通信に残っているごみデータの読み飛ばし(?))、以下の動作を行う無限ループを実行する
1-1) シリアル通信からデータを読み出し、それでgpsの更新(?)を行う
1-2) rungpsの中の "print('緯度経度: %2.8f, %2.8f' % (gps.latitude[0], gps.longitu$"で緯度、経度が表示される。
1-3) rungpsの中の次の行 "other()"でother関数が呼び出され、'ok'の表示と、２秒間の待ち(sleep(2.0))が行われる。(緯度経度の表示をするコードと'ok'を表示するコードは連続しているので、当然ながら「ok」がGPSとほぼ同時に表示されることになります。
1-4) rungpsの中の次の行 "sleep(1.0)"で１秒間の待ちが行われた後に、ループの最初に戻って、1-1からの動作を繰り返す

1. other()を実行するotherthreadスレッドが、mainの中の次の行"otherthread.start()"で起動される。

2-1) other()関数は、'ok'の表示と、２秒間の待ち(sleep(2.0))を行うだけなので、otherthreadスレッドは起動から２秒後には（実行が終わったので）消滅する。

＝＝＝
「本来は、1秒毎にGPS表示しながら、同時進行で2秒毎にokを表示させたかったのですがうまく動作しませんでした」の理由

A)　[1秒毎にGPS表示しながら]
rungpsのループの中に、シリアル通信からの読み出し("sentence = s.readline().decode('utf-8')")をするコードが含まれています。
シリアル通信にどのようなデータが送られていることになっているのかわかりませんが、シリアル通信からデータが来なければループはデータ待ちで止まることになります。１秒の時間待ち以外に、シリアル通信待ちが入る（データが来るのを待つ時間、届いたデータを読み出す時間が発生する）ので、不定期にループが実行されているのではと思われます。
ループの前にシリアル通信から一連の指示データを読み込むようにして、ループ内では指示データに従って動作する（シリアル通信は使わない）ようにすれば、１秒ごとに動作するように出来ると思われます。(２秒の待ちを含む other()の呼び出しをやめてください。そうすれば３秒＋α間隔で回っていたループが、１秒＋アルファ間隔で回るようになるはず）
また、"if sentence[0] != '$':"の付近は、シリアル通信から'$'が送られてきたら、何かの動作をさせるコードの断片（残骸）だと思われますが、今はcontinueで何もなかったことにしてしまっているので改良が必要だと思います。　

B) [2秒毎にokを表示]
他の方も指摘しているように、other関数はループを含まないので、一度'ok'を表示したら終わりです。（other関数を実行するotherthreadスレッドも、実行が終わったら消滅します）
以下のように修正すれば、otherthreadスレッドが無限ループで2秒毎にokを表示するようになります。

def other():
        While True:
                print('ok')
                time.sleep(2.0)

Comments

[退会済みユーザー]

.................................................................................
ご回答ありがとうございます。
ご指摘受けまして以下のように変更致しました。
ですが、今度は「ok」ばかり出て「緯度経度」は一度しか出ませんでした。
そのターミナルの様子も載せますのでご確認下さい。
..................................................................................
以下変更後の全文
..................................................................................
import time, datetime, threading, serial, micropyGPS

gps = micropyGPS.MicropyGPS(9, 'dd')

#関数------------------------------------------------------
def rungps():
s = serial.Serial('/dev/serial0', 9600, timeout=10)
s.readline()
while True:
sentence = s.readline().decode('utf-8')
if sentence[0] != '$':
continue
for x in sentence:
gps.update(x)
#----------------------------------------------------------

def other():
while True:
print('ok')
time.sleep(2.0)
#----------------------------------------------------------
gpsthread = threading.Thread(target=rungps, args=())
otherthread = threading.Thread(target=other)
gpsthread.daemon = True
gpsthread.start()
otherthread.start()

while True:
if gps.clean_sentences > 20:
print('緯度経度: %2.8f, %2.8f' % (gps.latitude[0], gps.longitude[0]))
other()
time.sleep(1.0)
..................................................................................
..................................................................................
..................................................................................
以下実行結果
..................................................................................
pi@raspberrypi:~/Desktop $ python3 09.py
ok
ok
ok
緯度経度: 0.00000000, 0.00000000
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok
ok

[coco_bauer]

緯度経度の表示が1度しか起こらないのは、if文の条件 "gps.clean_sentences > 20"が成立するのが１度しか起こっていないからだと思います。表示される緯度経度が(0.0,0.0)であることを考え合わせると、GPSモジュールの制御がうまくいっていないのではないかと思われます。　まず、GPSモジュールに指示を送って、緯度経度を表示するプログラムで動作確認をしてみてはいかがでしょうか。

Answer 2

other() はループされてないので、１回しか実行されませんよ。

Comments

[退会済みユーザー]

いえ。もう一度実行してみたのですが繰り返し表示されます

Answer 3

落ち着いて考えれば分かると思います。

otherスレッドは最初に一度start()で起動されて終わりで、その後は、GPSスレッドのなかで緯度経度表示の後で呼び出されるだけです。

#コメントを受けて追記

当方、これが初めてのPythonでして

おそらく、プログラミングが初めてですよね？
・otherをrungps同様に無限ループにする
・rungpsからotherを呼び出すのをやめる
の2箇所を修正します。

import time, datetime, threading, serial, micropyGPS

gps = micropyGPS.MicropyGPS(9, 'dd')

#関数------------------------------------------------------
def rungps():
        s = serial.Serial('/dev/serial0', 9600, timeout=10)
        s.readline()
        while True:
                sentence = s.readline().decode('utf-8')
                if sentence[0] != '$':
                        continue
                for x in sentence:
                        gps.update(x)

                if gps.clean_sentences > 20:
                        print('緯度経度: %2.8f, %2.8f' % (gps.latitude[0], gps.longitu$
                time.sleep(1.0)
#----------------------------------------------------------

def other():
        while True:
                print('ok')
                time.sleep(2.0)
#----------------------------------------------------------
if __name__ == "__main__":
        gpsthread = threading.Thread(target=rungps, args=())
        otherthread = threading.Thread(target=other)
#gpsthread.daemon = True
        gpsthread.start()
        otherthread.start()

Comments

[退会済みユーザー]

申し訳ありませんが、当方、これが初めてのPythonでしておっしゃっている意味がよく理解できません。
どこをどのように直すとこの症状は改善されるのでしょうか？