История изменений

Исправление rtxtxtrx, 29.07.25 11:53 (текущая версия) :

import threading
lock = threading.Lock()
Empty = object()
it = iter(data)
def worker(it):
  while True:
    with lock:
      item = next(it, Empty)
    if item is Empty:
      break
    # ...

Исходная версия rtxtxtrx, 29.07.25 11:51:

import threading
lock = threading.Lock()
Empty = object()
it = iter(data)
def worker(it):
  while True:
    whith lock:
      item = next(it, Empty)
    if item is Empty:
      break
    # ...