Форум программистов [Powered by Invision Power Board]

Код


class CacheManager():
    def __init__(self, queryLifeTime = 30):
        self._queryLifeTime = queryLifeTime
        self._cache = []
        
    def _deleteObsoleteResults(self):
        criticalTime = time.time() - self._queryLifeTime
        for i in xrange(len(self._cache) - 1, -1, -1):
            if self._cache[i][0] < criticalTime:
                del self._cache[i]
        
    def getResultFromCache(self, sql):
        ''' Пробует достать результат запроса из кеша, иначе возвращает None '''
        self._deleteObsoleteResults()
        key = crc32(sql)
        for kort in self._cache:
            if kort[1] == key:
                return kort[2]
        
    def putResultToCache(self, sql, result):
        ''' Добавляет результат запроса в кеш '''
        self._deleteObsoleteResults()
        self._cache.append((time.time(), crc32(sql), result))

Код


import bisect

class CacheManager():
    def __init__(self, queryLifeTime = 30):
        self._queryLifeTime = queryLifeTime
        self._timestamps = []
        self._queries = []
        self._cache = {}
        
    def _deleteObsoleteResults(self):
        criticalTime = time.time() - self._queryLifeTime
        i = bisect.bisect_left(self._timestamps, criticalTime)
        self._timestamps = self._timestamps[i:]
        self._queries = self._queries[i:]
        
    def getResultFromCache(self, sql):
        ''' Пробует достать результат запроса из кеша, иначе возвращает None '''
        self._deleteObsoleteResults()
        key = crc32(sql)
        value = self._cache.get(key)
        if value:
            value, i = value
            if i < len(self._queries) and key == self._queries[i]:
                return value

    def putResultToCache(self, sql, result):
        ''' Добавляет результат запроса в кеш '''
        self._deleteObsoleteResults()
        timestamp = time.time()
        sql = crc32(sql)

        i = bisect.bisect_left(self._timestamps, timestamp)
        self._timestamps.insert(i, timestamp)        
        self._queries.insert(i, sql)

        self._cache[sql] = (result, i)

Код


self._cache[sql] = (result, i)))