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

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

src/c/o/concurrence-HEAD/scripts/httpperf.py   concurrence(Download)
 
        #start up sessions, and wait till they are finished
        Tasklet.join_all([Tasklet.new(self.sessions)() for _ in range(self.options.sessions)])
 
        quit()

src/c/o/concurrence-HEAD/test/testcore.py   concurrence(Download)
 
        subs = [Tasklet.new(sub)() for sub in [sub0, sub1, sub2, sub3]]
        results = Tasklet.join_all(subs)
 
        self.assertTrue(isinstance(results[0], JoinError))
        ch2 = Tasklet.new(child)(2)
 
        Tasklet.join_all([ch1, ch2])
 
        self.assertEquals([(1, 0), (2, 0), (1, 1), (2, 1), (1, 2), (2, 2), (1, 3), (2, 3), (1, 4), (2, 4)], l)

src/c/o/concurrence-HEAD/test/testlocal.py   concurrence(Download)
        t2 = Tasklet.new(t)()
 
        Tasklet.join_all([t1,t2])
 
        self.assertEquals(2, len(local._d.keys())) #the 2 tasks are sill around, so local keeps their values
            t1 = Tasklet.new(t)()
            t2 = Tasklet.new(t)()
            Tasklet.join_all([t1, t2])
 
            self.assertEquals(30, AdderInstance.sum(20))

src/c/o/concurrence-HEAD/test/testmysql.py   concurrence(Download)
        ch2 = Tasklet.new(query)(2)
        ch3 = Tasklet.new(query)(3)
        Tasklet.join_all([ch1, ch2, ch3])
 
        end = time.time()