def run_cceval1(self, nums):
        num_read = nums.get("num_read", 2000)

#        for i in xrange(num_read):
#            res_obj = self.rr.read(self.res_ids[0])
#        self.timer.complete_step('read_same_n')

#        for i in xrange(num_read):
#            res_obj = self.rr.read(self.res_ids[0])
#        self.timer.complete_step('read_same_n2')

#        for i in xrange(num_read):
#            res_obj = self.rr.read(self.res_ids[random.randint(0, len(self.res_ids)-1)])
#        self.timer.complete_step('read_rand_n')

#        for i in xrange(num_read):
#            res_obj = self.rr_store.read_doc(self.res_ids[random.randint(0, len(self.res_ids)-1)])
#        self.timer.complete_step('readdoc_rand_n')

        num_thread = nums.get("num_thread", 5)

        def _proc():
            for i in xrange(int(num_read/num_thread)):
                res_obj = self.rr.read(self.res_ids[random.randint(0, len(self.res_ids)-1)])

        gls = [gevent.spawn(_proc) for i in xrange(num_thread)]
        gevent.joinall(gls)

        self.timer.complete_step('read_conc_same_n')

        def _proc():
            rr_store = DatastoreManager.get_datastore_instance("resources")
            for i in xrange(int(num_read/num_thread)):
                res_obj = rr_store.read(self.res_ids[random.randint(0, len(self.res_ids)-1)])

        gls = [gevent.spawn(_proc) for i in xrange(num_thread)]
        gevent.joinall(gls)

        self.timer.complete_step('read_conc2_same_n')




        self.timer.complete_step('end')
dataset/ETHPy150Open ooici/pyon/prototype/couch/couch_concurrent.py/CouchConcurrencyEval.run_cceval1/original