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
|
# Copyright (c) 2010-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.
from argparse import ArgumentParser
from dataclasses import dataclass
import sys
from simgrid import Actor, Engine, Host, Mutex, this_actor
def create_parser() -> ArgumentParser:
parser = ArgumentParser()
parser.add_argument(
'--platform',
type=str,
required=True,
help='path to the platform description'
)
parser.add_argument(
'--actors',
type=int,
default=6,
help='how many pairs of actors should be started'
)
return parser
@dataclass
class ResultHolder:
value: int
def worker_context_manager(mutex: Mutex, result: ResultHolder):
# When using a context manager, the lock and the unlock are automatic. This is the easiest approach
with mutex:
this_actor.info("Hello simgrid, I'm ready to compute after acquiring the mutex from a context manager")
result.value += 1
this_actor.info("I'm done, good bye")
def worker(mutex: Mutex, result: ResultHolder):
# If you lock your mutex manually, you also have to unlock it.
# Beware of exceptions preventing your unlock() from being executed!
mutex.lock()
this_actor.info("Hello simgrid, I'm ready to compute after a regular lock")
result.value += 1
mutex.unlock()
this_actor.info("I'm done, good bye")
def main():
settings = create_parser().parse_known_args()[0]
e = Engine(sys.argv)
e.load_platform(settings.platform)
# Create the requested amount of actors pairs. Each pair has a specific mutex and cell in `result`
results = [ResultHolder(value=0) for _ in range(settings.actors)]
for i in range(settings.actors):
mutex = Mutex()
e.add_actor(f"worker-{i}(mgr)", Host.by_name("Jupiter"), worker_context_manager, mutex, results[i])
e.add_actor(f"worker-{i}", Host.by_name("Tremblay"), worker, mutex, results[i])
e.run()
for i in range(settings.actors):
this_actor.info(f"Result[{i}] -> {results[i].value}")
if __name__ == "__main__":
main()
|
