hephy-dd / comet

COMET - Control and Measurement Toolkit
GNU General Public License v3.0
2 stars 2 forks source link

Thread safe immutable data exchange #41

Closed arnobaer closed 4 years ago

arnobaer commented 4 years ago

Introduce thread save immutable data exchange mechanism (exchanging only deep copies) using methods get(key, default=None) and set(key, value)

>>> def run(p):
...     for i in range(42):
...         value = p.get('count', default=0)
...         value += 1
...         p.set('count', value)
>>> p = comet.Process(target=run)
>>> p.set('count', 0)
>>> p.start()
>>> p.join()
>>> p.get('count')
42