Juliusを使用したGUIアプリケーション（音声認識を使ったクイズ）を作成したい。

Question

前提・実現したいこと

Juliusを使用したGUIアプリケーションを作成しています。
最終目標は、問題をGUIに表示→音声で入力→正解・不正解を表示といったアプリを作成したいと考えています。
その途中段階で、
スタートボタンをクリック→Juliusをモジュールモードで起動→出力結果をTCP/IP経由で取得・GUIに表示
まで作成しました。
次のステップとして
ストップボタンをクリック→Juliusとの接続を停止させる
を実現したいのですが、以下のソースコードすとストップボタンが押される。次の
音声入力が行われると接続が停止されるという状態しか作れませんでした。
停止ボタンが押されたら即接続を停止させたいのですが、どういった方法がありますでしょうか。
ご教示いただければ幸いです。

発生している問題

ストップボタンが押されてから即接続を停止できない。

該当のソースコード

# -*- coding: utf-8 -*-

import tkinter # Tkinterモジュールのインポート
import socket
import string
import subprocess
import time
import threading

stopFlag = 0

# コンソールに"Button is clicked."を出力する関数
def startButtonClicked():
  # ボタン非表示化
    #startButton.pack_forget()  
    # スレッディング処理
    thread1 = threading.Thread(target=juliusWork)
    thread1.start()    
    
def stopButtonClicked():
	#stopButton.pack_forget()
	global stopFlag
	stopFlag = 1
	print("stop")

def juliusWork():
	
	#Juliusをモジュールモードで起動（自作辞書使用）
	p = subprocess.Popen("julius -C ~/julius/dictation-kit-4.5/am-gmm.jconf -nostrip -gram ~/julius/test/test -input mic -module", stdout=subprocess.PIPE, shell=True)
	print('Initiating')
	time.sleep(2)
	print('Done')
	pid = str(p.pid)
	print(pid)
	
	host = 'localhost'   # IPアドレス
	port = 10500         # juliusの待ち受けポート

	# TCP/IPで、juliusサーバに接続
	sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
	sock.connect((host, port))

	data = ""
	while True:
		#stopFlagが立った時の終了処理
		global stopFlag 
		if stopFlag == 1:				
			print("finished")
			sock.close()
			stopFlag = 0
			break

		# 音声認識結果のみをXMLで取得		
		while (data.find("</RECOGOUT>\n.") == -1):
			soc = sock.recv(1024)
			data = data + soc.decode('utf-8')

		# 音声認識結果のXMLから単語部分のみを抜き出して連結
		recog_text = ""
		for line in data.split('\n'):
			index = line.find('WORD="')
			if index != -1:
				line = line[index+6:line.find('"', index+6)]
				if line != "[s]" and line != "[/s]":
					recog_text = recog_text + line

		print("認識結果: " + recog_text)
		
		resultTextWidget.insert('end', "認識結果=" + recog_text+"\n")  #テキストフィールドに検出結果を表示
		data = "" #dataの中身（検出結果）を空に
		
# ウィンドウ（フレーム）の作成
root = tkinter.Tk()
# ウィンドウの名前を設定
root.title("demo_Tkinter")
# ウィンドウの大きさを設定
root.geometry("400x400")

resultTextWidget = tkinter.Text(root)
resultTextWidget.pack()

# ボタンの作成（text=ボタンに表示されるテキスト, command=押下時に呼び出す関数）
startButton = tkinter.Button(root, text="スタート", command=startButtonClicked)
startButton.pack()# ボタンの表示
stopButton = tkinter.Button(root, text="ストップ", command=stopButtonClicked)
stopButton.pack()# ボタンの表示

# イベントループ
root.mainloop()

Answer 1

下の3行目で、音声データが来るまでスレッドがブロックされてしまっていることが原因ではないでしょうか。

        # 音声認識結果のみをXMLで取得        
        while (data.find("</RECOGOUT>\n.") == -1):
            soc = sock.recv(1024)

解決策として、
１.

def stopButtonClicked():
    #stopButton.pack_forget()
    global stopFlag
    stopFlag = 1
    print("stop")

の中で、ストップボタンが押されたらsockにダミーのデータを送るようにする。
（sockをグローバル変数にする等、何らかの組み換えが必要）

２.

sock.settimeout(value)

として、ソケットにタイムアウトを設定し、タイムアウト例外が発生したらループを回すようにする。

https://docs.python.org/ja/3/library/socket.html#socket.socket.settimeout

３. sockをノンブロッキングモードにして全面的に作り変える。

等が考えられます。

Comments

[dice1989]

教えていただいた解決策２で希望の動作を実現することができました。
ありがとうございます。解決策１や３についても勉強したいと思います。
複数の解決策をご提案いただき大変助かりました。

以下に、修正したソースコードを載せます（正しいでしょうか？）。
# -*- coding: utf-8 -*-

import tkinter # Tkinterモジュールのインポート
import socket
import string
import subprocess
import time
import threading

stopFlag = False

# コンソールに"Button is clicked."を出力する関数
def startButtonClicked():
# ボタン非表示化
#startButton.pack_forget()
# スレッディング処理
thread1 = threading.Thread(target=juliusWork)
thread1.start()

def stopButtonClicked():
#stopButton.pack_forget()
print("stop")
global stopFlag
stopFlag = True

def juliusWork():

#Juliusをモジュールモードで起動（自作辞書使用）
p = subprocess.Popen("julius -C ~/julius/dictation-kit-4.5/am-gmm.jconf -nostrip -gram ~/julius/test/test -input mic -module", stdout=subprocess.PIPE, shell=True)
print('Initiating')
time.sleep(2)
print('Done')
#pid = str(p.pid)
#print(pid)

host = 'localhost' # IPアドレス
port = 10500 # juliusの待ち受けポート

# TCP/IPで、juliusサーバに接続
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect((host, port))

data = ""
while True:
try:
sock.settimeout(1)
# 音声認識結果のみをXMLで取得
while (data.find("</RECOGOUT>\n.") == -1):
soc = sock.recv(1024)
data = data + soc.decode('utf-8')

# 音声認識結果のXMLから単語部分のみを抜き出して連結
recog_text = ""
for line in data.split('\n'):
index = line.find('WORD="')
if index != -1:
line = line[index+6:line.find('"', index+6)]
if line != "[s]" and line != "[/s]":
recog_text = recog_text + line

print("認識結果: " + recog_text)

resultTextWidget.insert('end', "認識結果=" + recog_text+"\n") #テキストフィールドに検出結果を表示
data = "" #dataの中身（検出結果）を空に

except Exception as e:
global stopFlag
print(stopFlag)
if stopFlag:
sock.close()
p.kill()
stopFlag = False
break

# ウィンドウ（フレーム）の作成
root = tkinter.Tk()
# ウィンドウの名前を設定
root.title("demo_Tkinter")
# ウィンドウの大きさを設定
root.geometry("400x400")

resultTextWidget = tkinter.Text(root)
resultTextWidget.pack()

# ボタンの作成（text=ボタンに表示されるテキスト, command=押下時に呼び出す関数）
startButton = tkinter.Button(root, text="スタート", command=startButtonClicked)
startButton.pack()# ボタンの表示
stopButton = tkinter.Button(root, text="ストップ", command=stopButtonClicked)
stopButton.pack()# ボタンの表示

# イベントループ
root.mainloop()

[kotori_a]

OKと思います。