Samuele Locatelli
49 lines
1014 B
Python
49 lines
1014 B
Python
import redis
|
|
import time
|
|
|
|
CodaR = redis.Redis(host='localhost', port=6379, db=0, password='24068Seriate')
|
|
queue_name='IOB'
|
|
|
|
#-----------------------------------
|
|
# Gestione code REDIS
|
|
# per sostituzione 1:1 con coda in ram
|
|
|
|
# Function to add an item to the queue (enqueue)
|
|
def enqueue(item):
|
|
CodaR.rpush(queue_name, item)
|
|
print(f"Enqueued: {item}")
|
|
|
|
# Function to remove an item from the queue (dequeue)
|
|
def dequeue():
|
|
item = CodaR.lpop(queue_name)
|
|
if item:
|
|
print(f"Dequeued: {item.decode('utf-8')}")
|
|
return item.decode('utf-8')
|
|
else:
|
|
print("Queue is empty")
|
|
|
|
# Function to count queue actual lenght in Redis
|
|
def rqlen():
|
|
clen = CodaR.llen(queue_name)
|
|
if clen:
|
|
print(f"Queue len: {clen}")
|
|
return clen
|
|
else:
|
|
print("Queue is empty")
|
|
return 0
|
|
|
|
|
|
lung = rqlen()
|
|
print ("queue lenght: "+str(lung))
|
|
|
|
enqueue('prova1')
|
|
enqueue('prova2')
|
|
enqueue('prova3')
|
|
|
|
time.sleep(5)
|
|
|
|
lung = rqlen()
|
|
while lung > 0:
|
|
dequeue()
|
|
lung = rqlen()
|