【imageio| python】複数の画像データ読み込みをマルチスレッドで高速化

import imageio
import cv2
import numpy as np

import os

import threading

def imread_worker(input_path, filelist, q_img):
    for fi1 in filelist:
        img = imageio.imread(os.path.join(input_path, fi1))
        q_img.put([fi1, img])

def imread_multi_thread(input_path, workers=8):
    q_img = queue.Queue()
    imgs = []
    filelist = os.listdir(input_path)
    imgs_per_thread = len(filelist) // workers
    quotient = len(filelist) % workers
    filelists = [filelist[imgs_per_thread * i:imgs_per_thread * (i + 1)] for i in range(workers)]
    quot_list = filelist[imgs_per_thread * workers:imgs_per_thread * workers + quotient]
    filelists.append(quot_list)

    threads = []
    for fl in filelists:
        t = threading.Thread(target=imread_worker, args=(input_path, fl, q_img))
        t.setDaemon(True)
        t.start()
        threads.append(t)

    filelist = []

    for thread in threads:
        thread.join()

    while not q_img.empty():
        temp = q_img.get()
        filelist.append(temp[0])
        imgs.append(temp[1])

    return imgs, filelist

import queue

#マルチスレッドのためのキューの定義
q_img = queue.Queue()

#８スレッドで画像読み込み
img_list, img_path_list = imread_multi_thread(image_path, q_img, 8)

#ファイル名のリストを作成
filelist = os.listdir(input_path)

#スレッド数で割った商計算
imgs_per_thread = len(filelist) // workers

#スレッド数で割った余りを計算
quotient = len(filelist) % workers

#余り以外のファイル名を分割して１つのリストにする
filelists = [filelist[imgs_per_thread * i:imgs_per_thread * (i + 1)] for i in range(workers)]
#余りのファイル名のリストを作成
quot_list = filelist[imgs_per_thread * workers:imgs_per_thread * workers + quotient]
#合体させて１つのリストにする
filelists.append(quot_list)

#スレッドを格納するリスト
threads = []
#分割したファイル名のリスト分だけfor文を回す
for fl in filelists:
    #マルチスレッド用の画像読み込み関数（imread_worker）のスレッドを立てる
    t = threading.Thread(target=imread_worker, args=(input_path, fl, q_img))
    #デーモン化
    t.setDaemon(True)
    #スレッドの開始
    t.start()
    #スレッドリストへ格納
    threads.append(t)
#全てのスレッドが終わるまで待つ
for thread in threads:
    thread.join()

def imread_worker(input_path, filelist, q_img):
    for fi1 in filelist:
        img = imageio.imread(os.path.join(input_path, fi1))
        q_img.put([fi1, img])

    #キューから取り出した後の格納用の出力リスト定義
    imgs = []
    filelist = []
        
    #キューが空になるまで取り出し出力リストへ格納
    while not q_img.empty():
        temp = q_img.get()
        filelist.append(temp[0])
        imgs.append(temp[1])

def imread_worker(input_path, filelist, q_img):
    for fi1 in filelist:
        img = imageio.imread(os.path.join(input_path, fi1))
        img = cv2.resize(img, (224, 224))
        q_img.put([fi1, img])