1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
/* Copyright (c) 2017-2025. The SimGrid Team. All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
* under the terms of the license (GNU LGPL) which comes with this package. */
import org.simgrid.s4u.*;
class executor extends Actor {
private void suspend_activity_for(Exec activity, double seconds)
{
activity.suspend();
double remaining_computations_before_sleep = activity.get_remaining();
this.sleep_for(seconds);
activity.resume();
// Sanity check: remaining computations have to be the same before and after this period
Engine.info("Activity hasn't advanced: %s. (remaining before sleep: %f, remaining after sleep: %f)",
remaining_computations_before_sleep == activity.get_remaining() ? "yes" : "no",
remaining_computations_before_sleep, activity.get_remaining());
}
public void run() throws SimgridException
{
double computation_amount = this.get_host().get_speed();
// Execution will take 3 seconds
var activity = this.exec_init(3 * computation_amount);
// Add functions to be called when the activity is resumed or suspended
activity.on_this_suspend_cb(new CallbackExec() {
@Override public void run(Exec t)
{
Engine.info("Task is suspended (remaining: %f)", t.get_remaining());
}
});
activity.on_this_resume_cb(new CallbackExec() {
@Override public void run(Exec t)
{
Engine.info("Task is resumed (remaining: %f)", t.get_remaining());
}
});
// The first second of the execution
activity.start();
this.sleep_for(1);
// Suspend the activity for 10 seconds
suspend_activity_for(activity, 10);
// Run the activity for one second
this.sleep_for(1);
// Suspend the activity for the second time
suspend_activity_for(activity, 10);
// Finish execution
activity.await();
Engine.info("Finished");
}
}
public class exec_suspend {
public static void main(String[] args)
{
Engine e = new Engine(args);
e.load_platform(args[0]);
e.host_by_name("Tremblay").add_actor("executor", new executor());
// Start the simulation
e.run();
// The following call is useless in your code, but our continuous integration uses it to track memleaks
e.force_garbage_collection();
}
}
|
