SPFIFO 1.2.0

FIFO share for multiprocess

FFIFO share for multiprocess

Example

#!/usr/bin/env python
#!/usr/bin/env python
import PArray as pa 
from  spfifo import *
def test():
    pf1 = SPFIFO()
    pf1.init(key = "test", number_element = 5, dtype='|S5',  element_perblock=2, reNewFlag = True, timeout = 0, raseOtherDelete = False)
    pf2 = SPFIFO()
    pf2.init(key = "test")
    pf1.push(["aa123456"]);
    pf1.push(["bb",""]);
    pf1.push(["cc",""]);
    pf1.push(["dd",""]);
    pf1.push(["ee",""]);
    
    
    print("count ", pf2.count(), pf2.pop()[0])
    print("count ", pf2.count(), pf2.pop())
    print("count ", pf2.count(), pf2.pop())
    print("count ", pf2.count(), pf2.pop())
    print("count ", pf2.count(), pf2.pop())  

test()