Как решить проблему с многопоточностью?

Question

[DTPlayer]

def new_therad(eth_list, all_string, count):
    list_all = []
    for i in range(len(eth_list)):
        if eth_list[i] in blacklist:
            continue
        list_all.append(Thread(target=get_data, args=(eth_list[i], all_string[i])))
        blacklist.append(eth_list[i])
        if len(list_all) == count:
            print('Собрано нужное количество потоков, запуск')
            for i in range(len(list_all)):
                loop.run_until_complete(run_thread(list_all[i], i+1))
        if len(blacklist) == MainFileLen.count:
            pass
        else:
            new_therad(eth_list, all_string, count)

Вот функция, blacklist изначально пустой

async def run_thread(thread, num):
    thread.start()
    thread.join()
    print(f'Поток номер {num} завершен')

При первом запуске все нормально, но на втором запросе функции начинает добавлять 100+ потоков, в итоге ошибка о нехватке записей в массиве. В многопоточности недавно, хотел бы узнать как это решить.

Comments

[DTPlayer]

Важен кстати параллельный запуск потоков

[Morrowind]

Привет.
Ознакомься с этой статьей пожалуйста.

В твоем случае я бы сделал отдельную функцию и запускал ее.

Вот о чем я говорю.
//returnTradeHistory - это функция.
// daemon = True - это запуск в качестве фонового процесса - демона. То что тебе и нужно вроде бы.

flow1 = Thread(target=returnTradeHistory, daemon=True)
flow2.start() - тут запуск потока.

P.S в качестве примера вот мой пример с гитхаба для Flask. Не самый лучший но все таки.

Надеюсь помог.

[Влад Григорьев]

DTPlayer, у вас тут все прям очень плохо
1.вы стартуете потоки из нескольких мест
2. у вас рекурсия которая запускает потоки
3. вы пытаетесь использовать треды и асинхронность - лучше использовать что-то одно

Переработайте структуру, используйте что-то одно, уберите рекрсию тут она выглядит избыточной

Answer 1

[DTPlayer]

Спасибо тем, кто помог, теперь код выглядит так:

def new_therad(eth_list, all_string, count):
    for i in range(len(eth_list)):
        if threading.active_count() == count-1:
            time.sleep(1)
        flow1 = Thread(target=get_data, args=(eth_list[i], all_string[i]), daemon=True)
        flow1.start()