Как создать новый поток с использованием библиотеки `threading`?

Для создания нового потока с использованием библиотеки threading в Python, необходимо выполнить следующие шаги:

1. Импортировать модуль threading:

   import threading

2. Определить функцию, которую будет выполнять поток: Это может быть любая функция, содержащая код, который нужно выполнить в отдельном потоке.

   def my_function():
       # Код, который будет выполняться в потоке
       print("Поток начал работу")
       # ... (выполнение каких-либо задач) ...
       print("Поток завершил работу")
   

3. Создать объект Thread: При создании объекта Thread необходимо указать функцию, которую он должен выполнить, используя аргумент target.

   my_thread = threading.Thread(target=my_function)

   Дополнительно, можно передать аргументы в функцию, используя аргумент args (в виде кортежа):

   def my_function_with_args(arg1, arg2):
       print(f"Поток получил аргументы: {arg1}, {arg2}")
   
   my_thread = threading.Thread(target=my_function_with_args, args=(10, "hello"))
   

4. Запустить поток: Для запуска потока вызывается метод start() у объекта Thread.

   my_thread.start()

   Это запустит функцию my_function в отдельном потоке.

5. Дождаться завершения потока (необязательно): Если необходимо дождаться завершения работы потока перед продолжением выполнения основной программы, можно использовать метод join().

   my_thread.join()
   print("Основная программа продолжает работу после завершения потока")
   

   Если join() не используется, основная программа может продолжить выполнение параллельно с потоком.

Пример полного кода:

import threading
import time

def my_function(name):
    print(f"Поток {name}: начал работу")
    time.sleep(2)  # Имитация длительной работы
    print(f"Поток {name}: завершил работу")

thread1 = threading.Thread(target=my_function, args=("Thread-1",))
thread2 = threading.Thread(target=my_function, args=("Thread-2",))


thread1.start()
thread2.start()

print("Основная программа продолжает работу...")

thread1.join()
thread2.join()

print("Основная программа завершила работу после завершения потоков")

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