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

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

src/c/o/concurrence-HEAD/lib/concurrence/memcache/client.py   concurrence(Download)
    def _do_command(self, cmd, *args):
        block_channel = Channel()
        self._command_queue.append((cmd, args, block_channel))
        try:
            return block_channel.receive()

src/c/o/concurrence-HEAD/test/testtimer.py   concurrence(Download)
            Tasklet.new(sender)(4)
            for i in range(4):
                ch.receive(Timeout.current())
 
        start = time.time()
        try:            
            with Timeout.push(2.5):
                Tasklet.new(sender)(4)
                for i in range(4):
                    ch.receive(Timeout.current())

src/c/o/concurrence-HEAD/test/testcore.py   concurrence(Download)
        def receiver():
            test_channel.receive()
 
        self.assertEquals(False, test_channel.has_receiver())