server_count: int, customer_count: int, priority_chance=0.1, logging=True

):

system = System(server_count)

queue = MQueue()

customer_arrival_times = customer_entry(customer_count)

queued_customers = 0

# Each tick of the clock is 0.01 seconds

clock = 0

finish_events = []

finished_customers = []

waiting_count = {}

busy_servers_count = {}

customer_id = 0

log_text = []

while ( not queue.is_empty() or len(finish_events) > 0 or queued_customers != customer_count):

if queued_customers < customer_count and customer_arrival_times[0] == clock:

customer_id += 1

# Customer entry

new_customer_arrival_time = customer_arrival_times.pop(0)

new_customer_priority_state = np.random.uniform() < priority_chance

queued_customers += 1

customer = Customer(

arrival_time=new_customer_arrival_time,

priority=new_customer_priority_state,

)

if customer.priority:

queue.enqueue_priority(customer)

else:

queue.enqueue(customer)

log = f"{clock} \t # \t New customer arrived and queued.\n"

log_text.append(log)

elif not queue.is_empty() and system.can_serve():

# Job assignment

customer = queue.dequeue()

server, service_time = system.serve()

customer.start_service(clock, server)

finish_events.append(

{

"server": server,

"time": round(clock + service_time, 2),

"customer": customer,

}

)

finish_events = sorted(finish_events, key=lambda e: e["time"])

log = f"{clock} \t @ \t Customer assigned to server {server+1} and is set to finish in {round(clock+service_time, 2)}\n"

log_text.append(log)

elif len(finish_events) > 0 and clock == finish_events[0]["time"]:

# Customer served

event = finish_events.pop(0)

event["customer"].end_service(clock)

system.free_server(event["server"])

finished_customers.append(event["customer"])

log = f"{clock} \t * \t Server {event['server']+1} finished proccessing and is free.\n"

log_text.extend(log)

else:

waiting_count[clock] = len(queue)

busy_servers_count[clock] = system.busy_servers()

clock = round(clock + CLOCK_STEP, 2)

if logging:

with open("out.txt", "w") as wf:

wf.writelines(log_text)

return (

finished_customers,

system.server_stats,

clock,

waiting_count,

busy_servers_count,