Example of reprocessing elements in a queue more than once

Simple queues reprocessing.md

Simple queues reprocessing

Executing

python simple_queues.py

Example

simple_queues.py

queue = [{'value': 1,   'requeued': 0},
         {'value': 2,   'requeued': 0},
         {'value': 'a', 'requeued': 0},
         {'value': 3,   'requeued': 0},
         {'value': 4,   'requeued': 0},
         {'value': 'b', 'requeued': 0},
         {'value': 5,   'requeued': 0},
         {'value': 6,   'requeued': 0}]

requeue_times = 3

def display_queue_values():
    return [element['value'] for element in queue]

print(f'-> start\t\t\t(queue now: {display_queue_values()})')

while len(queue) > 0:
    element = queue.pop(0)

    if element['requeued'] > (requeue_times - 1):
        print(f'-> found element requeued more than {requeue_times} times, stoping...')
        break
    
    print(f'processing element:\t{element["value"]}\t(queue now: {display_queue_values()})')
    
    if isinstance(element['value'], str):
        element['requeued'] += 1
        queue.append(element)
        print(f'-> requeued element:\t{element["value"]}\t(queue now: {display_queue_values()})')
        continue