Method acquire

opencompass/models/base_api.py:89–98

Acquire concurrent resources if exists. This behavior will fall back to wait with query_per_second if there are no concurrent resources.

(self)

            sys.stderr.flush()

    def acquire(self):
        """Acquire concurrent resources if exists.

        This behavior will fall back to wait with query_per_second if there are
        no concurrent resources.
        """
        if hasattr(self, 'tokens'):
            self.tokens.acquire()
        else:
            self.wait()

    def release(self):
        """Release concurrent resources if acquired.