Delta Cycle
DeltaCycle is a Python library for discrete event simulation (DES).
A simulation has two components: a collection of variables, and a collection of tasks. Variables represent the instantaneous state of the simulation. They may be organized into arbitrary data structures. Tasks define how that state evolves. They may appear concurrent, but are scheduled sequentially.
Task execution is subdivided into a sequence of slots. Slots are assigned a monotonically increasing integer value, called time. Multiple tasks may execute in the same slot, and therefore at the same time. The term "delta cycle" refers to a zero-delay subdivision of a time slot. It is the clockwork mechanism behind the illusion of concurrency.
Read the docs! (WIP)
Features
- Kernel: task scheduler
- Task: coroutine wrapper
- Synchronization Primitives:
- Events
- Semaphores
- Credit Pools
- Queues
- Containers
- Structured Concurrency:
- Task Groups (parent/child hierarchy)
- Interrupts
- Exceptions
- Model Variables:
- Singular
- Aggregate
Example
The following code simulates singing in the round.
Four singers perform "Row, Row, Row Your Boat" in staggered fashion.
Each singer is represented by a coroutine.
A separator coroutine draws lines for readability.
The coroutines are wrapped by tasks,
and tasks are assigned a priority for precise ordering of concurrent events.
>>> from deltacycle import *
>>> song = [
... "Row, row, row your boat",
... "Gently down the stream",
... "Merrily, merrily, merrily, merrily",
... "Life is but a dream",
... ]
>>> async def singer(name: str, delay: int = 0):
... await sleep(delay)
... for line in song:
... print(f"{now()} ♫ {name}: {line:34} ♫")
... await sleep(1)
>>> async def separator():
... while True:
... print(f"{now()} ♫---------------------------------------♫")
... await sleep(1)
>>> async def main():
... t = create_task(separator(), priority=-1)
...
... async with TaskGroup() as tg:
... tg.create_task(singer("A", delay=0), priority=1)
... tg.create_task(singer("B", delay=1), priority=2)
... tg.create_task(singer("C", delay=2), priority=3)
... tg.create_task(singer("D", delay=3), priority=4)
...
... t.interrupt() # Interrupt separator task
...
... return "Bow / Curtsy"
>>> r = run(main())
0 ♫---------------------------------------♫
0 ♫ A: Row, row, row your boat ♫
1 ♫---------------------------------------♫
1 ♫ A: Gently down the stream ♫
1 ♫ B: Row, row, row your boat ♫
2 ♫---------------------------------------♫
2 ♫ A: Merrily, merrily, merrily, merrily ♫
2 ♫ B: Gently down the stream ♫
2 ♫ C: Row, row, row your boat ♫
3 ♫---------------------------------------♫
3 ♫ A: Life is but a dream ♫
3 ♫ B: Merrily, merrily, merrily, merrily ♫
3 ♫ C: Gently down the stream ♫
3 ♫ D: Row, row, row your boat ♫
4 ♫---------------------------------------♫
4 ♫ B: Life is but a dream ♫
4 ♫ C: Merrily, merrily, merrily, merrily ♫
4 ♫ D: Gently down the stream ♫
5 ♫---------------------------------------♫
5 ♫ C: Life is but a dream ♫
5 ♫ D: Merrily, merrily, merrily, merrily ♫
6 ♫---------------------------------------♫
6 ♫ D: Life is but a dream ♫
7 ♫---------------------------------------♫
>>> print(r)
Bow / Curtsy
Installing
DeltaCycle is available on PyPI:
$ pip install deltacycle
It requires Python 3.12+
Developing
DeltaCycle's repository is on GitHub:
$ git clone https://github.com/cjdrake/deltacycle.git
It is 100% Python, and has no runtime dependencies.
Development dependencies are listed in pyproject.toml.
1 maintainer
Metadata
1 maintainer
Release files for deltacycle 0.43.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| deltacycle-0.43.0.tar.gz | 35.8 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| deltacycle-0.43.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 61.4 kB
Release files / deltacycle-0.43.0.tar.gz
| Download URL | deltacycle-0.43.0.tar.gz |
|---|---|
| Size | 35.8 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
1d0df533c63b2ff007c94969936e6ae78a4849765520bbb5c55cd3e0ddeeae26
|
|
BLAKE2b-256 checksum How to use checksums |
e02801f4da5e6f1e82978d7014109d610190efc80eea84d0dc48fa119f071485
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
uv/0.12.5 {"installer":{"name":"uv","version":"0.12.5","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":null,"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":null}
|
Release files / deltacycle-0.43.0-py3-none-any.whl
| Download URL | deltacycle-0.43.0-py3-none-any.whl |
|---|---|
| Size | 25.7 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
c210e7cd25443198a9126f89e0ae396a60870dc41316b93372d493d6e0a63a1a
|
|
BLAKE2b-256 checksum How to use checksums |
9f2f208fcd65402eed56b158ae1afcdaac0d9f09ce729faa668740711dc8e13c
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
uv/0.12.5 {"installer":{"name":"uv","version":"0.12.5","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":null,"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":null}
|
