Python презентация

Python Multi

Str.decode(encoding = 'UTF-8',errors = 'strict’) encoding – это кодирование, которое будут использоваться. errors – здесь могут быть даны установки других схем обработки ошибок. Значение по умолчанию для ошибок «strict», это означает, что ошибки кодирования поднимают UnicodeError. Другие возможные значения: ‘ignore’, ‘replace’, ‘xmlcharrefreplace’, ‘backslashreplace’ и любое другое имя, зарегистрированное через codecs.register_error().

Потоки Thread

bs_str=BS(html.text, 'html.parser') bs_str=BS(html,'lxml')

Логгирование

Использование наследования

Использование Lock() lock.acquire() try: ... доступ к разделяемому ресурсу finally: lock.release() # освободить блокировку, что бы ни произошло

lock = Lock() lock.acquire() # заблокирует выполнение, если блокировка кем-то захвачена ... доступ к разделяемому ресурсу lock.release()

with lock: ... доступ к разделяемому ресурсу

lock.acquire(False) if not lock.acquire(False): ... не удалось заблокировать ресурс else: try: ... доступ к разделяемому ресурсу finally: lock.release()

lock.locked() if not lock.locked(): # другой поток может начать выполняться перед тем как мы перейдём к следующему оператору lock.acquire() # всё равно может заблокировать выполнение

Проблемы Lock() import threading lock = threading.Lock() def get_first_part(): lock.acquire() try: # берем данные для первой части из общих ресурсах. finally: lock.release() return data def get_second_part(): lock.acquire() try: # берем данные для второй части из общих ресурсах. finally: lock.release() return data

Возможное решение def get_both_parts(): lock.acquire() try: first = get_first_part() second = get_second_part() finally: lock.release() return first, second

Решение с RLock() import threading lock = threading.RLock() def get_first_part(): lock.acquire() try: # берем данные для первой части из общих ресурсах. finally: lock.release() return data def get_second_part(): lock.acquire() try: # берем данные для второй части из общих ресурсах. finally: lock.release() return data

RLock() lock = threading.Lock() lock.acquire() lock.acquire() # вызов заблокирует выполнение lock = threading.RLock() lock.acquire() lock.acquire() # вызов не заблокирует выполнение

BoundedSemaphore() semaphore = threading.BoundedSemaphore() semaphore.acquire() # уменьшает счетчик ... доступ к общему ресурсу semaphore.release() # увеличивает счетчик

max_connections = 10 semaphore = threading.BoundedSemaphore(max_connections)

Event() event = threading.Event() # поток клиента может подождать пока флажок будет установлен event.wait() # серверный поток может установить или сбросить флажок event.set() event.clear()

Condition() lock = threading.RLock() condition_1 = threading.Condition(lock) condition_2 = threading.Condition(lock)

# Поток производителя ... генерация товара condition.acquire() ... добавление товара в ресурс condition.notify() # отправляем уведомление о новом товаре condition.release()

subprocess и Timer

Загрузка файлов

Использование очередей

Модуль multiprocessing

Lock()

logging

Pool

Работа с очередями