Barrier

Barrier that holds multiple processes until released.

Barrier

Barrier to hold multiple processes.

Source code in src/asimpy/barrier.py

class Barrier:
    """Barrier to hold multiple processes."""

    def __init__(self, env: "Environment"):
        """
        Construct barrier.

        Args:
            env: simulation environment.
        """
        self._env = env
        self._waiters: deque = deque()

    async def wait(self):
        """Wait until barrier released."""
        evt = Event(self._env)
        self._waiters.append(evt)
        await evt

    def release(self):
        """Release processes waiting at barrier."""
        for evt in self._waiters:
            evt.succeed()
        self._waiters.clear()

__init__(env)

Construct barrier.

Parameters:

Name	Type	Description	Default
env	Environment	simulation environment.	required

Source code in src/asimpy/barrier.py

def __init__(self, env: "Environment"):
    """
    Construct barrier.

    Args:
        env: simulation environment.
    """
    self._env = env
    self._waiters: deque = deque()

release()

Release processes waiting at barrier.

Source code in src/asimpy/barrier.py

def release(self):
    """Release processes waiting at barrier."""
    for evt in self._waiters:
        evt.succeed()
    self._waiters.clear()

wait() async

Wait until barrier released.

Source code in src/asimpy/barrier.py

async def wait(self):
    """Wait until barrier released."""
    evt = Event(self._env)
    self._waiters.append(evt)
    await evt