Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(6)  |  Call(2)  |  Derive(0)  |  Import(4)

src/b/a/baboon-0.1.4/baboon/baboond/dispatcher.py   baboon(Download)
    def close(self):
        """ Stop all executor threads.
        """
 
        from baboon.baboond.task import EndTask
 
        for executor in self.executors.values():
            executor.tasks.put(EndTask())

src/b/a/baboon-HEAD/baboon/baboond/dispatcher.py   baboon(Download)
    def close(self):
        """ Stop all executor threads.
        """
 
        from baboon.baboond.task import EndTask
 
        for executor in self.executors.values():
            executor.tasks.put(EndTask())

src/b/a/baboon-0.1.4/baboon/baboond/executor.py   baboon(Download)
    def run(self):
        """ Consume on the tasks queue and run each task until an
        endtask.
        """
        from baboon.baboond.task import EndTask

src/b/a/baboon-HEAD/baboon/baboond/executor.py   baboon(Download)
    def run(self):
        """ Consume on the tasks queue and run each task until an
        endtask.
        """
        from baboon.baboond.task import EndTask