Как прерывать поток в python?

Question

[motya88]

Добрый день. Подскажите, как остановить создание новых потоков если в момент работы X потока длина списка list2 стала >0?

from multiprocessing.pool import ThreadPool

list_1=[1,2,3,4,5]
list2 =[]

def srch_1(ppp):
    # тут некая логика при которой я добавляю запись в list2


p1 = ThreadPool(10)
for ppp in list_1:
    p1.apply_async(srch_1, args=(ppp,))

p1.close()
p1.join()

Answer 1

[milssky]

break по нужному условию не работает?

Comments

[motya88]

не получается.