ミュージックプレイヤーを個人で作っています。
言語:python3.7
環境:VS2017 community
OS:windows 10 64bit
cpu:core i3
プログラミング初心者です。頓珍漢なことを書いていたら指摘してください。
音楽CD(wav,16bit,44100Hz)からwavファイルを読み込んでギャップレス再生できるように
するために、numpyの配列で全曲を連結することをしております。
「読み込み&連結」の時間を短縮するために、CDアルバム内の14曲のファイルを
2つのリストに振り分けてから「wavファイルデータの読み込み&連結」を
2プロセスで平行処理したいと思っています。
詳細:
リスト内データサイズは300MBあたりを境界として2つのリスト「self.fl1ba,self.fl1bb」に
分割しております。
そのあと、「self.fl1ba」と「self.fl1bb」からmultiprocessingのProcessクラスを
使用して平行処理で時間短縮をしようとしています。
しかし、Processを設定して「start()」しても平行処理になってくれません。
vstack1 = mp.Process(target=stack.fl_vstack1())
「.fl_vstack1()」の「()」を削除すると動かなくなります。
Poolクラスでも試しましたが、調べてみると、Poolの場合、「map」を使うでnumpy.arrayの
2次元配列は処理できないようでした。
wavファイル読み込みモジュールはpysoundfileを使用しています。
data,fs=soundfile.read(ファイル,dtype='int16')で2次元データ配列(data)と
サンプリング周波数(fs)が得られます。
再生はsounddeviceモジュールを使用。コードをここに入力
ファイル読み込み&連結を平行処理する方法をご教示ください。
よろしくお願いします。
import os
import multiprocessing as mp
import numpy as np
import time
import soundfile as sf
import sounddevice as sd
class Fileread():
def __init__(self):
### ディレクトリから「wavファイル」のみをself.fl1bに取得 ###
os.chdir("C:/Users/Public/Music/Music Center/Shared/Music/Aerosmith/Unplugged 1990 (Live)")
dir1 = os.getcwd()
self.dir2 = os.listdir(dir1)
self.fl1b = []
for j in self.dir2:
base,ext = os.path.splitext(j)
if ext == '.wav':
self.fl1b.append(j)
self.sumflsize1 = 0
self.sumflsize2 = 0
self.fl1c1 = []
self.fl1c2 = []
self.fl1ba = []
self.fl1bb = []
self.sumdata1 = np.array([0,0],dtype='int16')
self.sumdata2 = np.array([0,0],dtype='int16')
self.fl1t1 = []
self.fs = 0
### リスト内ファイルを2分割するメソッドを格納 ###
self.split_album()
### リストとして取得したファイルを別の2つのリストに2分割 ###
def split_album(self):
flsize = []
### アルバム内の各ファイルサイズを取得 ###
for h in self.fl1b:
flsize.append(os.path.getsize(h))
### アルバム内ファイルをリスト「self.fl1ba」と「self.fl1bb」に格納 ###
list_len = len(self.fl1b)
for d in range(list_len):
self.sumflsize1 += flsize[d]
self.fl1ba.append(self.fl1b[d])
if self.sumflsize1 > 300000000:
break
for q in range(list_len):
if q <= d:
pass
else:
self.sumflsize2 += flsize[q]
self.fl1bb.append(self.fl1b[q])
### リスト「self.fl1ba」内の各ファイルを'int16'で取得し、「self.sumdata1」に追加 ###
def fl_vstack1(self):
list_len1 = len(self.fl1ba)
for k in range(list_len1):
data,fs = sf.read(self.fl1ba[k],dtype='int16')
self.fs = fs ### fsはサンプリング周波数 ###
frame_num = len(data)
self.fl1c1.append(frame_num) ### 各ファイルの再生時間を算出するためにフレーム数を取得 ###
self.sumdata1 = np.vstack((self.sumdata1,data)) ### 「self.sumdata1」にwavファイルから読み込んだdataを追加 ###
self.sumdata1 = np.delete(self.sumdata1,0,0)
### 「fl_vstack1」と同じことを「self.fl1bb」内のファイルについても実行 ###
def fl_vstack2(self):
list_len2 = len(self.fl1bb)
if list_len2 > 0: ### リスト「self.fl1bb」にファイルが存在する場合 ###
for k in range(list_len2):
data,fs = sf.read(self.fl1bb[k],dtype='int16')
frame_num = len(data)
self.fl1c2.append(frame_num)
self.sumdata2 = np.vstack((self.sumdata2,data))
self.sumdata2 = np.delete(self.sumdata2,0,0)
else:
pass
### 「fl_vstack1」と「fl_vstack2」で積み上げたデータを連結 ###
def sum_stack(self):
self.sumdata1 = np.vstack((self.sumdata1,self.sumdata2))
### 各ファイル(曲)の演奏時間を算出 ###
def sum_time(self):
self.fl1c1 = self.fl1c1 + self.fl1c2
self.fl1t1 = list(map(lambda x: x/self.fs/60,self.fl1c1))
### 連結したファイルを再生(ギャップレス再生) ###
def sdplay(self):
sd.play(self.sumdata1,self.fs)
status = sd.wait()
if __name__=='__main__':
stack = Fileread()
### プロセス「vstack1」と「vstack2」が平行して動かない ###
### vstack1.start()ではなく下記プロセス設定時に処理が始まっているようです ###
### 「stack.fl_vstack1()」の「()」を削除して実行すると処理してくれません ###
start1 = time.time()
vstack1 = mp.Process(target=stack.fl_vstack1())
print('stack1:',time.time() - start1)
vstack2 = mp.Process(target=stack.fl_vstack2())
print('stack2:',time.time() - start1)
vstack1.start()
vstack2.start()
vstack1.join()
vstack2.join()
tvstack1 = mp.Process(target=stack.sum_stack())
tvstack2 = mp.Process(target=stack.sum_time())
tvstack1.start()
tvstack2.start()
tvstack1.join()
tvstack2.join()
tvstack3 = mp.Process(target=stack.sdplay())
tvstack3.start()