NNTPManager.py 文件源码

def put(self, request):
        """
        Handles the adding to the worker queue

        """

        # Determine if we need to spin a worker or not
        self._work_tracker.lock.acquire(blocking=True)

        if len(self._work_tracker.available) == 0:
            if len(self._work_tracker) < self._settings\
                    .nntp_processing['threads']:
                # Spin up more work
                self.spawn_workers(count=1)

        # Append to Queue for processing
        self._work_queue.put(request)

        # Release our lock
        self._work_tracker.lock.release()