質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

ただいまの
回答率

90.51%

  • Python

    11741questions

    Pythonは、コードの読みやすさが特徴的なプログラミング言語の1つです。 強い型付け、動的型付けに対応しており、後方互換性がないバージョン2系とバージョン3系が使用されています。 商用製品の開発にも無料で使用でき、OSだけでなく仮想環境にも対応。Unicodeによる文字列操作をサポートしているため、日本語処理も標準で可能です。

  • Raspberry Pi

    1065questions

    Raspberry Piは、ラズベリーパイ財団が開発した、名刺サイズのLinuxコンピュータです。 学校で基本的なコンピュータ科学の教育を促進することを意図しています。

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

解決済

回答 3

投稿

  • 評価
  • クリップ 0
  • VIEW 590

py-berry-thon

score 25

下記のプログラムを実行した際に、"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()
  • 気になる質問をクリップする

    クリップした質問は、後からいつでもマイページで確認できます。

    またクリップした質問に回答があった際、通知やメールを受け取ることができます。

    クリップを取り消します

  • 良い質問の評価を上げる

    以下のような質問は評価を上げましょう

    • 質問内容が明確
    • 自分も答えを知りたい
    • 質問者以外のユーザにも役立つ

    評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

    質問の評価を上げたことを取り消します

  • 評価を下げられる数の上限に達しました

    評価を下げることができません

    • 1日5回まで評価を下げられます
    • 1日に1ユーザに対して2回まで評価を下げられます

    質問の評価を下げる

    teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

    • プログラミングに関係のない質問
    • やってほしいことだけを記載した丸投げの質問
    • 問題・課題が含まれていない質問
    • 意図的に内容が抹消された質問
    • 広告と受け取られるような投稿

    評価が下がると、TOPページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

    質問の評価を下げたことを取り消します

    この機能は開放されていません

    評価を下げる条件を満たしてません

    評価を下げる理由を選択してください

    詳細な説明はこちら

    上記に当てはまらず、質問内容が明確になっていない質問には「情報の追加・修正依頼」機能からコメントをしてください。

    質問の評価を下げる機能の利用条件

    この機能を利用するためには、以下の事項を行う必要があります。

回答 3

checkベストアンサー

+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'の表示と、2秒間の待ち(sleep(2.0))が行われる。(緯度経度の表示をするコードと'ok'を表示するコードは連続しているので、当然ながら「ok」がGPSとほぼ同時に表示されることになります。
1-4) rungpsの中の次の行 "sleep(1.0)"で1秒間の待ちが行われた後に、ループの最初に戻って、1-1からの動作を繰り返す

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

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

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

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

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

投稿

編集

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

  • 2018/11/20 18:04

    .................................................................................
    ご回答ありがとうございます。
    ご指摘受けまして以下のように変更致しました。
    ですが、今度は「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

    キャンセル

  • 2018/11/21 09:24

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

    キャンセル

0

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

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

コメントを受けて追記

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

おそらく、プログラミングが初めてですよね?
otherrungps同様に無限ループにする
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()

投稿

編集

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

  • 2018/11/16 02:19

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

    キャンセル

0

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

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

  • 2018/11/16 12:36

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

    キャンセル

同じタグがついた質問を見る

  • Python

    11741questions

    Pythonは、コードの読みやすさが特徴的なプログラミング言語の1つです。 強い型付け、動的型付けに対応しており、後方互換性がないバージョン2系とバージョン3系が使用されています。 商用製品の開発にも無料で使用でき、OSだけでなく仮想環境にも対応。Unicodeによる文字列操作をサポートしているため、日本語処理も標準で可能です。

  • Raspberry Pi

    1065questions

    Raspberry Piは、ラズベリーパイ財団が開発した、名刺サイズのLinuxコンピュータです。 学校で基本的なコンピュータ科学の教育を促進することを意図しています。