threading時に起こるpyaudioのエラー

Question

こちらの質問にあるように常時音を監視して一定異常の音量が鳴った回数を記録するプログラムとLEDの点灯を切り替えるプログラムをthreadingで並列処理させるプログラムを組んだのですが、並列処理はできているようなのデスがpyaudioでエラーが発生してしまいました。

Start
Expression 'alsa_snd_pcm_mmap_begin( self->pcm, &areas, &self->offset, numFrames )' failed in 'src/hostapi/alsa/pa_linux_alsa.c', line: 3983
Expression 'PaAlsaStreamComponent_RegisterChannels( &self->capture, &self->bufferProcessor, &captureFrames, &xrun )' failed in 'src/hostapi/alsa/pa_linux_alsa.c', line: 4098
Expression 'PaAlsaStream_SetUpBuffers( stream, &framesGot, &xrun )' failed in 'src/hostapi/alsa/pa_linux_alsa.c', line: 4426
Exception in thread Thread-1:
Traceback (most recent call last):
  File "/usr/lib/python2.7/threading.py", line 801, in __bootstrap_inner
    self.run()
  File "/usr/lib/python2.7/threading.py", line 754, in run
    self.__target(*self.__args, **self.__kwargs)
  File "/home/pi/Desktop/py/final/judgeFunction.py", line 32, in judgeFunc
    data = stream.read(CHUNK)
  File "/usr/lib/python2.7/dist-packages/pyaudio.py", line 608, in read
    return pa.read_stream(self._stream, num_frames, exception_on_overflow)
IOError: [Errno -9999] Unanticipated host error

End

このstartとendはLEDの切り替えの合図です
コードと関数を記します

import threading
import elcFunc as ef
import judgeFunction as jf

if __name__ == "__main__":
	thread1 = threading.Thread(target = jf.judgeFunc)
	thread2 = threading.Thread(target = ef.noteStart)

	thread2.start()
	thread1.start()

	jf.judgeEnd()

def judgeFunc():
	while True:
		global score
		data = stream.read(CHUNK)
		x = np.frombuffer(data, dtype="int16") / 32768.0
		if x.max() > threshold:
			score += 1
			print(score)

def noteStart():

	global a,i
	initAll()

	while a == True:
		print("Start")
		wiringpi.digitalWrite(GPIO26, LOW)
		wiringpi.digitalWrite(GPIO21, LOW)

		lf.noteLeft(random.randint(0, 15))
		suc = rf.noteRight(random.randint(0, 15))
		time.sleep(2)

		while i < 28:
			lf.noteLeft(suc)
			suc = rf.noteRight(random.randint(0, 15))
			time.sleep(2)
			i = i+1

		wiringpi.digitalWrite(GPIO21, HIGH)
		rf.endRight()

		lf.noteLeft(suc)
		time.sleep(2)

		wiringpi.digitalWrite(GPIO26, HIGH)
		lf.endLeft()
	
		a = False

エラーコードで検索をかけても情報が少なく解決できませんでした。
分かる方回答の方よろしくお願いいたします。

追記
jf.judgeEnd関数です。

def judgeEnd():
	stream.close()
	p.terminate()

Comments

[umyu]

jf.judgeEnd()の処理を質問文のコードに追記してくださいな。

[YMD_kts]

追記しました。

Answer 1

jf.judgeEnd()関数の追記ありがとうございました。
環境が無いので、憶測の回答になってしまいますが。

def judgeEnd():
    stream.close() #←原因はこの行です。
    p.terminate()

そう判断した理由を書きます。

[Errno -9999] Unanticipated host errorで検索すると一番最初のページとして
Using any other values in pyaudio for rate / format / chunk give me the error: [Errno Input overflowed] -9981のページがHITします。

"open" and "close"がポイントだと分かります。

    thread1 = threading.Thread(target = jf.judgeFunc)
    thread2 = threading.Thread(target = ef.noteStart)

    thread2.start()
    thread1.start()

    jf.judgeEnd()

Threadはstart()を行った後もメインスレッドの処理は続きます。
stream.close()を実行後に、data = stream.read(CHUNK)が呼び出されて、
質問文のエラーが発生したと思われます。

一度余分な機能のない、スレッドプログラム。
スレッドid(threading.get_ident())と時刻を出力するprint文のみを作成してみるのがいいと思います。

対策方法は
案1)judgeFunc内で、ループ終了時にjudgeEndを呼び出す。
案2)jf.judgeEnd()の前の行にthread1.join()を追加して、終了待ちをする。

Comments

[YMD_kts]

試しにjudgeEnd()をコメントアウトしたら無事並列処理できました！
勝手にThreadのstart()の部分で処理が止まっているもの太戸勘違いしてました...
お早い回答有難うございました。