Многопоточность доработка

# -*- coding: utf-8 -*-
 
 
# Задача: вычислить 3 тикера с максимальной и 3 тикера с минимальной волатильностью в МНОГОПОТОЧНОМ стиле
#
# Бумаги с нулевой волатильностью вывести отдельно.
# Результаты вывести на консоль в виде:
#   Максимальная волатильность:
#       ТИКЕР1 - ХХХ.ХХ %
#       ТИКЕР2 - ХХХ.ХХ %
#       ТИКЕР3 - ХХХ.ХХ %
#   Минимальная волатильность:
#       ТИКЕР4 - ХХХ.ХХ %
#       ТИКЕР5 - ХХХ.ХХ %
#       ТИКЕР6 - ХХХ.ХХ %
#   Нулевая волатильность:
#       ТИКЕР7, ТИКЕР8, ТИКЕР9, ТИКЕР10, ТИКЕР11, ТИКЕР12
# Волатильности указывать в порядке убывания. Тикеры с нулевой волатильностью упорядочить по имени.
#
import os
import csv
from operator import itemgetter
from heapq import nlargest, nsmallest
from threading import Thread
import time
 
global_file_list = []
global_volatility = {}
zero_volatility = []
 
 
def time_track(func):
    def surrogate(*args, **kwargs):
        started_at = time.time()
 
        result = func(*args, **kwargs)
 
        ended_at = time.time()
        elapsed = round(ended_at - started_at, 4)
        print(f'Функция работала {elapsed} секунд(ы)\n')
        return result
    return surrogate
 
 
class Informer(Thread):
    def __init__(self, thread_name):
        super().__init__()
        self.thread_name = thread_name
 
    @time_track
    def run(self):
        for item in global_file_list[:]:
            try:
                print(f'Поток {Informer.getName(self)} берет файл {item}')
                with open(item) as csvfile:
                    global_file_list.remove(item)
                    prices_list = []
                    reader = csv.DictReader(csvfile)
                    for row in reader:
                        secid = row['SECID']
                        price = round(float(row['PRICE']), 4)
                        if price not in prices_list:
                            prices_list.append(price)
                    average_price = round((max(prices_list) + min(prices_list)) / 2, 4)
                    volatility = round(((max(prices_list) - min(prices_list)) / average_price) * 100, 2)
                    if volatility > 0.0:
                        global_volatility[secid] = volatility
                    else:
                        zero_volatility.append(secid)
            except ValueError as exc:
                print(f'{self.thread_name}: {item}, {exc}')
                continue
 
 
def get_file_list(input_path):
    for d, dirs, files in os.walk(input_path):
        for f in files:
            path = os.path.join(d, f)
            global_file_list.append(path)
    print(f'Список файлов получен, всего {len(global_file_list)} файлов\n', flush=True)
    # print(global_file_list)
 
 
def printer():
    print('Максимальная волатильность:', flush=True)
    max_volatility = nlargest(3, global_volatility.items(), key=itemgetter(1))
    for key, value in max_volatility:
        print(f'{key} {value} %', flush=True)
 
    print('Минимальная волатильность:', flush=True)
    min_volatility = nsmallest(3, global_volatility.items(), key=itemgetter(1))
    min_volatility = sorted(min_volatility, key=itemgetter(1), reverse=True)
    for key, value in min_volatility:
        print(f'{key} {value} %', flush=True)
 
    print('Нулевая волатильность:', flush=True)
    print(', '.join(sorted(zero_volatility)), flush=True)
 
 
if __name__ == '__main__':
 
    get_file_list('trades')
 
    print_max = Informer('1')
    print_min = Informer('2')
    print_zero = Informer('3')
 
    print_max.start()
    print_min.start()
    print_zero.start()
 
    print_max.join()
    print_min.join()
    print_zero.join()
 
    printer()