Модуль Threading Python
Модуль threading позволяет запускать несколько потоков в одном процессе и координировать их с помощью блокировок.
import threading
Потоки полезны, когда нужно ждать ввода-вывода, например сетевых запросов или операций с файлами. Обычно это не лучший способ ускорить Python-код, сильно нагружающий CPU.
Запуск потока
import threading
def worker():
print('working')
thread = threading.Thread(target=worker)
thread.start()
thread.join()
working
start() запускает поток. join() ждет его завершения, прежде чем продолжить основную программу.
Передача аргументов
import threading
def greet(name):
print(f'hello {name}')
thread = threading.Thread(target=greet, args=('Ada',))
thread.start()
thread.join()
hello Ada
Используйте args для позиционных аргументов и kwargs для именованных.
Использование блокировки
Блокировки помогают защищать общее состояние.
import threading
counter = 0
lock = threading.Lock()
with lock:
counter += 1
print(counter)
1
Запуск нескольких потоков
import threading
results = []
lock = threading.Lock()
def worker(number):
with lock:
results.append(f'worker {number}')
threads = []
for number in range(3):
thread = threading.Thread(target=worker, args=(number,))
threads.append(thread)
thread.start()
for thread in threads:
thread.join()
print(sorted(results))
['worker 0', 'worker 1', 'worker 2']
Фактический порядок завершения может отличаться, потому что потоки работают одновременно, поэтому пример сортирует результат перед выводом.