codewars/courses/python_threading/les_1.py

import time
import threading

### Базовое использование потоков

def get_data_1(data):
    while True:
        print(f"<< вывод из другого потока {threading.current_thread().name} - {data}>>")
        time.sleep(1)
        data = str(time.time())

def thread_test_1():
    thr = threading.Thread(target=get_data_1, args=(str(time.time()), ), name="Thr-1")
    thr.start()

    ite = 0
    while True:
        time.sleep(3)
        print(f"\n\n Вывод №{(ite:= ite+1)}: ")
        print(f"Наш личный поток работает?: {thr.is_alive()}")
        for ind, val in enumerate(threading.enumerate()):
            print(f"\t Активный поток №{ind+1}: {val}")
        print("\n\n")

### Демонстрация выполнения ТОЛЬКО по завершению работы (ф-я join)

def get_data_2(data, value):
    for _ in range(value):
        print(f"<{threading.current_thread().name} - d:{data}, v:{value}> ")
        time.sleep(1)

def thread_test_2():
    start_val, end_val = 1, 5
    
    # создаем функцию которая создает потоки
    tc = lambda x: threading.Thread(target=get_data_2, args=(str(time.time()), x,), name=f"thr-{x}", daemon=True)
    
    # создаем список потоков
    thr_list = [tc(x) for x in range(start_val, end_val + 1)]
    
    # запускаем потоки
    [x.start() for x in thr_list]
    
    # Ждем пока они завершаться (программа не дойдет до финиша, пока все потоки не завершат раобту)
    for i in thr_list:
        i.join()
    print("finish")


thread_test_2()




'''
def get_data_1(data):
    while True:
        print(f"[{threading.current_thread().name}] - {data}")
        time.sleep(3)

def get_data_2(data, value):
    for _ in range(value):
        print(f"[{threading.current_thread().name}] - {data}")
        time.sleep(1)

# thr = threading.Thread(target=get_data, args=(str(time.time()), ), name="thr-1" )
# thr.start()                


def thr_join():

    thr_list = []

    for i in range(3):
        thr = threading.Thread(target=get_data_2, args=(str(time.time()), i,), name=f"thr-{i}" )
        thr_list.append(thr)
        thr.start()                

    for i in thr_list:
        i.join()

    print("finish")



def set_name():
    print("name:", threading.main_thread().name)
    threading.main_thread().setName("maint_thread_new_name")
    print("result:", threading.main_thread().name)


def print_thread_params():
    for i in range(100):
        print(f"current: {i}")
        time.sleep(1)

        if i%10 == 0:
            # количество активных потоков
            print("active thread:", threading.active_count())

            # выводит все запущенные потоки
            print("enumerate:", threading.enumerate())

            # работает ли поток в данный момент
            print("thr-1 is active", thr.is_alive())


thr_join()

'''