def __init__(self, out, cacheline = 100, flushnow = 0): self.out = out self.cacheline = cacheline self.flushnow = flushnow self.lock = multiprocessing.Lock() self.filter = [] self.__cache = []