work

courses/python_indi/all_any.py

@@ -23,6 +23,6 @@ def test_2():
 
 def test_3():
     words = list(input().split(' '))
-    print(all(['A' in word for word in words]))
+    print(all(['A' in word or 'a' in word for word in words]))
 
-test_3()
+# test_3()

courses/python_threading/les_1.py

@@ -0,0 +1,110 @@
+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()
+
+'''