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

All Samples(17)  |  Call(17)  |  Derive(0)  |  Import(0)

src/k/a/kamaelia-HEAD/Sketches/MH/Timer/ThreadedComponent.py   kamaelia(Download)
            self._do_threadsafe( throwexception, [exception], {} )
        self._threadrunning = False
        Component.component.unpause(self)
 
 
   def send(self,message, boxname="outbox"):
       try:
           self.outqueues[boxname].put_nowait(message)
           Component.component.unpause(self)        # FIXME: Fragile
       except Queue.Full:
            # exists
            self.threadtoaxonqueue.put( (cmd, argL, argD ) )
            Component.component.unpause(self)
            return self.axontothreadqueue.get()
        else:

src/k/a/kamaelia-HEAD/Code/Python/Axon/Axon/ThreadedComponent.py   kamaelia(Download)
            self._do_threadsafe( throwexception, [exception], {} )
        self._threadrunning = False
        Component.component.unpause(self)
 
 
       # don't forget to wake up _localmain() - it might have been sleeping
       # waiting to put something else into this inqueue
       Component.component.unpause(self)
       # collect message from queue.
       return self.inqueues[boxname].get()
           self.outqueues[boxname].put_nowait(message)
           # wake up _localmain() so it can collect the message and send it on
           Component.component.unpause(self)        # FIXME: Fragile
       except queue.Full:
           raise noSpaceInBox(self.outqueues[boxname].qsize(), self.queuelengths)
            # exists
            self.threadtoaxonqueue.put( (cmd, argL, argD ) )
            Component.component.unpause(self)
            return self.axontothreadqueue.get()
        else:

src/k/a/kamaelia-HEAD/Sketches/RJL/Packages/Kamaelia/Community/RJL/Kamaelia/Protocol/HTTP/HTTPClient.py   kamaelia(Download)
        self.send(producerFinished(self), "signal")
        self.removeChild(self.carousel)        
        self.unpause()
 
    def debug(self, msg):

src/k/a/kamaelia-HEAD/Sketches/RJL/Kamaelia/Community/RJL/Kamaelia/Protocol/HTTP/HTTPClient.py   kamaelia(Download)
        self.send(producerFinished(self), "signal")
        self.removeChild(self.carousel)        
        self.unpause()
 
    def debug(self, msg):

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Protocol/HTTP/HTTPClient.py   kamaelia(Download)
        self.send(producerFinished(self), "signal")
        self.removeChild(self.carousel)
        self.unpause()
 
    def debug(self, msg):

src/k/a/kamaelia-HEAD/Sketches/RJL/HTTP/HTTPClient.py   kamaelia(Download)
        self.send(producerFinished(self), "signal")
        self.removeChild(self.carousel)        
        self.unpause()
 
    def debug(self, msg):

src/k/a/Kamaelia-0.6.0/Kamaelia/Protocol/HTTP/HTTPClient.py   Kamaelia(Download)
        self.send(producerFinished(self), "signal")
        self.removeChild(self.carousel)
        self.unpause()
 
    def debug(self, msg):

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Axon/Axon/ThreadedComponent.py   kamaelia(Download)
            self._do_threadsafe( throwexception, [exception], {} )
        self._threadrunning = False
        Component.component.unpause(self)
 
 
       # don't forget to wake up _localmain() - it might have been sleeping
       # waiting to put something else into this inqueue
       Component.component.unpause(self)
       # collect message from queue.
       return self.inqueues[boxname].get()
           self.outqueues[boxname].put_nowait(message)
           # wake up _localmain() so it can collect the message and send it on
           Component.component.unpause(self)        # FIXME: Fragile
       except queue.Full:
           raise noSpaceInBox(self.outqueues[boxname].qsize(), self.queuelengths)
            # exists
            self.threadtoaxonqueue.put( (cmd, argL, argD ) )
            Component.component.unpause(self)
            return self.axontothreadqueue.get()
        else:

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Kamaelia/Protocol/HTTP/HTTPClient.py   kamaelia(Download)
        self.send(producerFinished(self), "signal")
        self.removeChild(self.carousel)
        self.unpause()
 
    def debug(self, msg):