Mon, 22 Jan 2018 21:07:34 +0000
Generalisation of scheduler thread to general queue threads
# # FIFO memory logger # from logging.handlers import BufferingHandler class FIFOHandler(BufferingHandler): def shouldFlush(self, record): return False def emit(self, record): self.buffer.append(record) l=len(self.buffer) if l>self.capacity: self.buffer=self.buffer[(l-self.capacity):(l-1)] def formatAll(self): return [self.format(record) for record in self.buffer]