soapypower/threadpool.py
def submit(self, fn, *args, **kwargs):
        """Submits a callable to be executed with the given arguments.

        Count maximum reached work queue size in ThreadPoolExecutor.max_queue_size_reached.
        """
        future = super().submit(fn, *args, **kwargs)
        work_queue_size = self._work_queue.qsize()
        if work_queue_size > self.max_queue_size_reached:
            self.max_queue_size_reached = work_queue_size
        return future
def submit(self, fn, *args, **kwargs):
        future = super().submit(fn, *args, **kwargs)
        work_queue_size = self._work_queue.qsize()
        if work_queue_size > self.max_queue_size_reached:
            self.max_queue_size_reached = work_queue_size
        return future
def submit ( self , fn , * args , * * kwargs ) : future = super ( ) . submit ( fn , * args , * * kwargs ) work_queue_size = self . _work_queue . qsize ( ) if work_queue_size > self . max_queue_size_reached : self . max_queue_size_reached = work_queue_size return future
Submits a callable to be executed with the given arguments.

        Count maximum reached work queue size in ThreadPoolExecutor.max_queue_size_reached.
Submits a callable to be executed with the given arguments .