daviddoji/example-code-2e
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

minor edits to taxi_sim.py

Browse Source
This commit is contained in:
Luciano Ramalho
2015-02-11 01:29:42 -02:00
parent 7d7a716f5d
commit d4ba3fed2e
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
control/simulation/taxi_sim.py
View File

@@ -10,10 +10,12 @@ Event = collections.namedtuple('Event', 'time actor action')
def compute_delay(interval): def compute_delay(interval):
"""Compute action delay using exponential distribution"""
return int(random.expovariate(1/interval)) + 1 return int(random.expovariate(1/interval)) + 1
def taxi_process(ident, trips): def taxi_process(ident, trips):
"""Yield to simulator issuing event at each state change"""
trip_ends = 0 trip_ends = 0
for i in range(trips): for i in range(trips):
prowling_ends = trip_ends + compute_delay(FIND_PASSENGER_INTERVAL) prowling_ends = trip_ends + compute_delay(FIND_PASSENGER_INTERVAL)
@@ -33,6 +35,7 @@ class Simulator:
self.time = 0 self.time = 0
def schedule_events(self): def schedule_events(self):
"""Advance each actor to next state, scheduling events"""
for actor in list(self.actors): for actor in list(self.actors):
try: try:
future_event = next(actor) future_event = next(actor)
@@ -42,6 +45,7 @@ class Simulator:
self.events.put(future_event) self.events.put(future_event)
def run(self, end_time): def run(self, end_time):
"""Schedule and execute events until time is up"""
while self.time < end_time: while self.time < end_time:
self.schedule_events() self.schedule_events()
if self.events.empty(): if self.events.empty():
@@ -66,6 +70,7 @@ def extract_seed(args):
def main(args): def main(args):
"""Parse command line, build actors and run simulation"""
extract_seed(args) extract_seed(args)
if args: if args:
end_time = int(args[0]) end_time = int(args[0])