Ahenk/opt/ahenk/base/command/fifo.py

import threading


class Fifo(object):
    def __init__(self):
        self.lock = threading.Lock()
        self.path = '/tmp/liderahenk.fifo'

    def push(self, content):
        file = None
        self.lock.acquire()
        try:
            file = open(self.path, 'a+')
            file.write(content)
        except Exception as e:
            print('Error:{}'.format(str(e)))
        finally:
            file.close()
            self.lock.release()

    def pull(self, queue):
        result = None
        self.lock.acquire()
        try:
            lines = open(self.path, 'rb').readlines()
            if lines is not None and len(lines) > 0:
                result = lines[0].decode("unicode_escape")
                w_file = open(self.path, 'wb')
                w_file.writelines(lines[1:])
                w_file.close()
        except Exception as e:
            print('Error:{}'.format(str(e)))
        finally:
            self.lock.release()
        queue.put(result)