X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/50315369ab3f6921a3c6c6a266cf1d25b9c56b4d..3f756b051175054c62c4741fdab2a6b934828262:/examples/python/task-variable-load/task-variable-load.py diff --git a/examples/python/task-variable-load/task-variable-load.py b/examples/python/task-variable-load/task-variable-load.py index 5e437e36b5..51dbc1a6c6 100644 --- a/examples/python/task-variable-load/task-variable-load.py +++ b/examples/python/task-variable-load/task-variable-load.py @@ -27,25 +27,24 @@ def parse(): ) return parser.parse_args() -def callback( t): - print(f'[{Engine.clock}] { t} finished ({ t.count})') +def callback(t): + print(f'[{Engine.clock}] {t} finished ({t.count})') -def variable_load( t): +def variable_load(t): print('--- Small load ---') - for i in range(3): - t.enqueue_execs(1) + for _ in range(3): + t.enqueue_firings(1) this_actor.sleep_for(100) this_actor.sleep_for(1000) print('--- Heavy load ---') - for i in range(3): - t.enqueue_execs(1) + for _ in range(3): + t.enqueue_firings(1) this_actor.sleep_for(1) if __name__ == '__main__': args = parse() e = Engine(sys.argv) e.load_platform(args.platform) - Task.init() # Retrieve hosts tremblay = e.host_by_name('Tremblay') @@ -59,7 +58,7 @@ if __name__ == '__main__': comm.add_successor(exec) # Add a function to be called when tasks end for log purpose - Task.on_end_cb(callback) + Task.on_completion_cb(callback) # Create the actor that will inject load during the simulation Actor.create("input", tremblay, variable_load, comm)