mirror of
https://github.com/Pardus-LiderAhenk/ahenk
synced 2024-11-15 09:02:17 +03:00
36 lines
988 B
Python
36 lines
988 B
Python
|
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)
|