third_party/blink/tools/blinkpy/common/message_pool.py
def run(self, shards):
        """Posts a list of messages to the pool and waits for them to complete."""
        for message in shards:
            self._messages_to_worker.put(
                _Message(
                    self._name,
                    message[0],
                    message[1:],
                    from_user=True,
                    logs=()))

        for _ in range(self._num_workers):
            self._messages_to_worker.put(
                _Message(
                    self._name,
                    'stop',
                    message_args=(),
                    from_user=False,
                    logs=()))

        self.wait()
Posts a list of messages to the pool and waits for them to complete.
Posts a list of messages to the pool and waits for them to complete.
Posts a list of messages to the pool and waits for them to complete .
def run(self, shards):
        for message in shards:
            self._messages_to_worker.put(
                _Message(
                    self._name,
                    message[0],
                    message[1:],
                    from_user=True,
                    logs=()))
        for _ in range(self._num_workers):
            self._messages_to_worker.put(
                _Message(
                    self._name,
                    'stop',
                    message_args=(),
                    from_user=False,
                    logs=()))
        self.wait()
def run ( self , shards ) : for message in shards : self . _messages_to_worker . put ( _Message ( self . _name , message [ 0 ] , message [ 1 : ] , from_user = True , logs = ( ) ) ) for _ in range ( self . _num_workers ) : self . _messages_to_worker . put ( _Message ( self . _name , 'stop' , message_args = ( ) , from_user = False , logs = ( ) ) ) self . wait ( )
Posts a list of messages to the pool and waits for them to complete.
Posts a list of messages to the pool and waits for them to complete .
"""Posts a list of messages to the pool and waits for them to complete."""
self
shards