Resource

Shared resource with limited capacity.

Resource

Shared resource with limited capacity.

Source code in src/asimpy/resource.py

class Resource:
    """Shared resource with limited capacity."""

    def __init__(self, env: "Environment", capacity: int = 1):
        """
        Create a new resource.

        Args:
            env: simulation environment.
            capacity: maximum simultaneous users.
        """
        self._env = env
        self._capacity = capacity
        self._count = 0
        self._waiting = []

    async def acquire(self):
        """Acquire one unit of the resource."""
        await _Acquire(self)

    async def release(self):
        """Release one unit of the resource."""
        await _Release(self)

    async def __aenter__(self):
        """Acquire one unit of the resource using `async with`."""
        await self.acquire()
        return self

    async def __aexit__(self, exc_type, exc, tb):
        """Release one unit of the resource acquired with `async with`."""
        await self.release()

__aenter__() async

Acquire one unit of the resource using async with.

Source code in src/asimpy/resource.py

async def __aenter__(self):
    """Acquire one unit of the resource using `async with`."""
    await self.acquire()
    return self

__aexit__(exc_type, exc, tb) async

Release one unit of the resource acquired with async with.

Source code in src/asimpy/resource.py

async def __aexit__(self, exc_type, exc, tb):
    """Release one unit of the resource acquired with `async with`."""
    await self.release()

__init__(env, capacity=1)

Create a new resource.

Parameters:

Name	Type	Description	Default
env	Environment	simulation environment.	required
capacity	int	maximum simultaneous users.	1

Source code in src/asimpy/resource.py

def __init__(self, env: "Environment", capacity: int = 1):
    """
    Create a new resource.

    Args:
        env: simulation environment.
        capacity: maximum simultaneous users.
    """
    self._env = env
    self._capacity = capacity
    self._count = 0
    self._waiting = []

acquire() async

Acquire one unit of the resource.

Source code in src/asimpy/resource.py

async def acquire(self):
    """Acquire one unit of the resource."""
    await _Acquire(self)

release() async

Release one unit of the resource.

Source code in src/asimpy/resource.py

async def release(self):
    """Release one unit of the resource."""
    await _Release(self)