mirror of
https://github.com/python/cpython.git
synced 2025-12-23 09:19:18 +00:00
Improve multiserver queue recipe (GH-29012) (GH-29014)
This commit is contained in:
parent
1dbf9c86b2
commit
cb34c1ee1b
1 changed files with 6 additions and 5 deletions
|
|
@ -502,7 +502,7 @@ between the effects of a drug versus a placebo::
|
|||
|
||||
Simulation of arrival times and service deliveries for a multiserver queue::
|
||||
|
||||
from heapq import heappush, heappop
|
||||
from heapq import heapify, heapreplace
|
||||
from random import expovariate, gauss
|
||||
from statistics import mean, median, stdev
|
||||
|
||||
|
|
@ -514,14 +514,15 @@ Simulation of arrival times and service deliveries for a multiserver queue::
|
|||
waits = []
|
||||
arrival_time = 0.0
|
||||
servers = [0.0] * num_servers # time when each server becomes available
|
||||
for i in range(100_000):
|
||||
heapify(servers)
|
||||
for i in range(1_000_000):
|
||||
arrival_time += expovariate(1.0 / average_arrival_interval)
|
||||
next_server_available = heappop(servers)
|
||||
next_server_available = servers[0]
|
||||
wait = max(0.0, next_server_available - arrival_time)
|
||||
waits.append(wait)
|
||||
service_duration = gauss(average_service_time, stdev_service_time)
|
||||
service_duration = max(0.0, gauss(average_service_time, stdev_service_time))
|
||||
service_completed = arrival_time + wait + service_duration
|
||||
heappush(servers, service_completed)
|
||||
heapreplace(servers, service_completed)
|
||||
|
||||
print(f'Mean wait: {mean(waits):.1f}. Stdev wait: {stdev(waits):.1f}.')
|
||||
print(f'Median wait: {median(waits):.1f}. Max wait: {max(waits):.1f}.')
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue