Subversion Repositories SmartDukaan

Rev

Rev 15823 | Rev 16019 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 15823 Rev 15827
Line 78... Line 78...
78 
            data['dealFlag'] = 1
 78 
            data['dealFlag'] = 1
79 
            data['dealType'] = manualDeal['dealType']
 79 
            data['dealType'] = manualDeal['dealType']
80 
            data['dealPoints'] = manualDeal['dealPoints']
 80 
            data['dealPoints'] = manualDeal['dealPoints']
81 
            data['manualDealThresholdPrice'] = manualDeal['dealThresholdPrice']
 81 
            data['manualDealThresholdPrice'] = manualDeal['dealThresholdPrice']
82 
    pool = ThreadPool(cpu_count() *2)
 82 
    pool = ThreadPool(cpu_count() *2)
- 
 
 83 
    offset = 0
- 
 
 84 
    limit =100
- 
 
 85 
    while(offset<=len(toScrapMap.values())):
83 
    pool.map(updatePrices,toScrapMap.values())
 86 
        pool.map(updatePrices,toScrapMap.values()[offset:offset+limit])
- 
 
 87 
        offset = offset + limit
84 
    pool.close()
 88 
    pool.close()
85 
    pool.join()
 89 
    pool.join()
86 
    print "joining threads at %s"%(str(datetime.now()))
 90 
    print "joining threads at %s"%(str(datetime.now()))
87 
 
 91 
 
88 
 
 92