for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
# -*- coding: utf-8 -*-
import threading
class threadsafe_iter(object):
"""
Takes an iterator/generator and makes it thread-safe by serializing call to
the `next` method of given iterator/generator.
def __init__(self, original):
self.original = original
self.lock = threading.Lock()
def __iter__(self):
return self
def __next__(self):
with self.lock:
return next(self.original)
def next(self):
return self.__next__()
oblalex /
isotopic-logging
