5

Python で同時に 2 つのメソッドを実行しようとしています。1 つはサウンドを再生し、もう 1 つはそれを録音します。どちらの方法も問題なく機能しますが、マルチプロセッシングとスレッド化の両方を同時に開始する方法がわかりませんでした。スレッド化では解決できないことはほぼ確実です。

def listen_to_audio()

def play_audio()

何か案は？(同時に終了する必要はありませんが、両方とも 1 秒以内に開始する必要があります。)

それがコードです。最初に投稿しなかったことをお詫びします。

import pyaudio
import wave
import sys
import time
from math import *
from getopt import *
import threading

def make_sin(f0=1000.,ampl=30000,rate=22050,length=5.):
  a = 2. * pi * f0/rate              
  n = int(rate * length)
  wav=''
  for i in range(0, n):
    f = int(ampl*sin(a*i))
    wav += chr(f & 0xFF) + chr((f & 0xFF00) >> 8)
  return wav



def play_audio(forHowLong):
    data = make_sin(f0=1000.,ampl=30000,rate=22050,length=5.)

    p = pyaudio.PyAudio() #sets up portaudio system
    stream = p.open(format=p.get_format_from_width(2),
                channels=1,
                rate=22050,
                output=True)

    start = time.time()
    while time.time() < start + forHowLong*0.5:    
            stream.write(data)

    stream.stop_stream()
    stream.close()
    p.terminate()


def listen_to_audio(forHowLong):
    CHUNK = 1024
    FORMAT = pyaudio.paInt16
    CHANNELS = 2
    RATE = 44100
    RECORD_SECONDS = forHowLong
    WAVE_OUTPUT_FILENAME = "output.wav"

    p = pyaudio.PyAudio()

    stream = p.open(format=FORMAT,
            channels=CHANNELS,
            rate=RATE,
            input=True,
            frames_per_buffer=CHUNK)

    print("* recording")

    frames = []

    for i in range(0, int(RATE / CHUNK * RECORD_SECONDS)):
        data = stream.read(CHUNK)
        frames.append(data)

    print("* done recording")

    stream.stop_stream()
    stream.close()
    p.terminate()

    wf = wave.open(WAVE_OUTPUT_FILENAME, 'wb')
    wf.setnchannels(CHANNELS)
    wf.setsampwidth(p.get_sample_size(FORMAT))
    wf.setframerate(RATE)
    wf.writeframes(b''.join(frames))
    wf.close()


def main():

#start play_audio and record_audio here at the same time



if __name__ == "__main__":
    main()
4

7 に答える 7

4 
import threading,time
def play1():
    while time.time() <= start_time:
        pass
    threading.Thread(target=listen_to_audio).start()
def play2():
    while time.time() <= start_time:
        pass
    threading.Thread(target=play_audio).start()
start_time=time.time()+20
threading.Thread(target=play1).start()
threading.Thread(target=play2).start()

これはうまくいくはずです。各機能を開始し、各機能で適切な時間になるまで待機します:)

于 2012-11-16T18:38:46.990 に答える
2

あなたはから始めることができます：

import threading

threading.Thread(target=listen_to_audio).start()
threading.Thread(target=play_audio).start()
于 2012-11-16T18:24:03.770 に答える
2

私はスレッドを使用します：

import threading

threads = []
threads.append(threading.Thread(target=listen_to_audio))
threads.append(threading.Thread(target=play_audio))

map(lambda x: x.start(), threads)

編集:マップが完全に同時にスレッドを開始するかどうかはわかりませんが、非常に近いはずです

于 2012-11-16T18:23:07.103 に答える
1

IT忍者さん、ありがとうございます。

あなたのコードは仕事をしましたが、少し変更する必要がありました：

def main():
start_time=time.time()+1
def play1():
    while time.time() < start_time:
        pass
    threading.Thread(target=listen_to_audio(5)).start()
def play2():
    while time.time() < start_time:
        pass
    threading.Thread(target=play_audio(5)).start()

threading.Thread(target=play1).start()
threading.Thread(target=play2).start()

今では動作します:) ありがとうございました!!

于 2012-11-16T21:48:49.303 に答える
0

スレッドを使用して両方の関数を開始するのはなぜですか? 最初の関数を呼び出して、最初の関数内のスレッドを使用して 2 番目の関数を開始するだけです。

import threading


def play_audio():
    threading.Thread(target=listen_to_audio).start()
    #rest of code for play_audio

ここでの遅延は非常に少なくなると思います。

于 2012-11-16T18:29:46.393 に答える
0

かなり後になってからですが、

  1. スレッドは同時に開始される場合がありますが、Windows の制限により、再生/録音は同時に開始されません。実際には、舞台裏の両方にバッファがあり、(不明または制御可能な) 遅延が発生しています。

  2. これを行う最善の方法は、非同期の読み取り/書き込みストリーム (読み取りと書き込みの両方を行う 1 つのストリーム) を作成することです。つまり、コールバック関数でストリームを作成し、input=True と output=True の両方を定義します (ここでは pyaudio を想定しています)。

特にオーディオをブロックしている場合、pyaudio が舞台裏でどのようにスレッド化を実装しているかはわかりませんが、別の問題は GIL (グローバル インタープリター ロック) です。現在の状況と、さまざまな python 実装での動作について十分に調査していませんでしたが、IIRC では、特定の時間に 1 つのスレッドしか python コードを実行できないため、ほとんどの部分で python はマルチスレッドに対応していません。瞬間AFAIK

于 2013-12-24T05:46:27.313 に答える
-1

両方の関数をラップする を作成し、def startBoth()必要に応じて listen_to_audio と play_audio の両方をインポートします。を開始startBoth()すると、両方の関数が呼び出されます。

于 2012-11-16T18:20:49.043 に答える