def run(self):
        """Process the work unit, or wait for sentinel to exit"""
        while 1:
            workunit = self._workq.get()
            if is_sentinel(workunit):
                # Got sentinel
                break

            # Run the job / sequence
            workunit.process()
Process the work unit, or wait for sentinel to exit
recipes/Python/576519_Thread_pool_same_API/recipe-576519.py